Skip to content

Commit

Permalink
Merge pull request #3833 from SanojPunchihewa/log-mediator-test
Browse files Browse the repository at this point in the history 
Add test cases for Log mediator inline expressions
  • Loading branch information
@SanojPunchihewa
SanojPunchihewa authored Dec 16, 2024
2 parents 1d70536 + 7507c18 commit 75f735d
Show file tree
Hide file tree
Showing 2 changed files with 273 additions and 0 deletions.
169 changes: 169 additions & 0 deletions ...ts-mediator-1/src/test/java/org/wso2/carbon/esb/mediator/test/v2/LogMediatorTestCase.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,169 @@
/*
* Copyright (c) 2024, WSO2 LLC. (https://www.wso2.com) All Rights Reserved.
*
* WSO2 LLC. licenses this file to you under the Apache License,
* Version 2.0 (the "License"); you may not use this file except
* in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/

package org.wso2.carbon.esb.mediator.test.v2;

import org.apache.http.HttpResponse;
import org.apache.http.util.EntityUtils;
import org.testng.Assert;
import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
import org.wso2.esb.integration.common.utils.CarbonLogReader;
import org.wso2.esb.integration.common.utils.ESBIntegrationTest;
import org.wso2.esb.integration.common.utils.clients.SimpleHttpClient;

import java.io.IOException;

public class LogMediatorTestCase extends ESBIntegrationTest {

SimpleHttpClient httpClient = new SimpleHttpClient();

@BeforeClass(alwaysRun = true)
public void init() throws Exception {

super.init();
}

@Test(groups = {"wso2.esb"}, description = "Testing Log mediator INFO level")
public void testLogMediatorINFO() throws IOException, InterruptedException {

CarbonLogReader carbonLogReader = new CarbonLogReader();
carbonLogReader.start();

String requestPayload = "{\n" +
" \"data\": {\n" +
" \"name\": \"John\",\n" +
" \"food\": {\n" +
" \"cal\": \"55\",\n" +
" \"sugar\": \"none\"\n" +
" }\n" +
" }\n" +
"}";

String serviceURL = getMainSequenceURL() + "log-mediator-template/info";
HttpResponse httpResponse = httpClient.doPost(serviceURL, null, requestPayload, "application/json");
Assert.assertEquals(httpResponse.getStatusLine().getStatusCode(), 200, "Response code mismatched");
EntityUtils.consumeQuietly(httpResponse.getEntity());

boolean logLine1 = carbonLogReader
.checkForLog("Processing info message: {\"name\":\"John\",\"food\":{\"cal\":\"55\",\"sugar\":\"none\"}} " +
"using endpoint http://localhost:8480/log-mediator-template/mock-backend-json", DEFAULT_TIMEOUT);
Assert.assertTrue(logLine1, "Log mediator INFO message Line 1 not logged");

boolean logLine2 = carbonLogReader
.checkForLog("Backend result = {\"pet\":{\"name\":\"pet3\",\"type\":\"mock-backend\"}}|" +
"requestID = John_123123|test = abc123", DEFAULT_TIMEOUT);
Assert.assertTrue(logLine2, "Log mediator INFO message Line 2 not logged");

carbonLogReader.stop();
}

@Test(groups = {"wso2.esb"}, description = "Testing Log mediator WARN level")
public void testLogMediatorWARN() throws IOException, InterruptedException {

CarbonLogReader carbonLogReader = new CarbonLogReader();
carbonLogReader.start();

String requestPayload = "{\n" +
" \"data\": {\n" +
" \"name\": \"John\",\n" +
" \"food\": {\n" +
" \"cal\": \"55\",\n" +
" \"sugar\": \"none\"\n" +
" }\n" +
" }\n" +
"}";

String serviceURL = getMainSequenceURL() + "log-mediator-template/warn";
HttpResponse httpResponse = httpClient.doPost(serviceURL, null, requestPayload, "application/json");
Assert.assertEquals(httpResponse.getStatusLine().getStatusCode(), 200, "Response code mismatched");
EntityUtils.consumeQuietly(httpResponse.getEntity());

boolean logLine1 = carbonLogReader
.checkForLog("Processing message: {\"name\":\"John\",\"food\":{\"cal\":\"55\",\"sugar\":\"none\"}} " +
"using endpoint", DEFAULT_TIMEOUT);
Assert.assertTrue(logLine1, "Log mediator WARN message Line 1 not logged");

boolean logLine2 = carbonLogReader
.checkForLog("Log warn message, payload = {\"pet\":{\"name\":\"pet3\",\"type\":\"mock-backend\"}}, " +
"content-type-header = application/json; charset=UTF-8", DEFAULT_TIMEOUT);
Assert.assertTrue(logLine2, "Log mediator WARN message Line 2 not logged");

carbonLogReader.stop();
}

@Test(groups = {"wso2.esb"}, description = "Testing Log mediator ERROR level")
public void testLogMediatorERROR() throws IOException, InterruptedException {

CarbonLogReader carbonLogReader = new CarbonLogReader();
carbonLogReader.start();

String requestPayload = "{\n" +
" \"data\": {\n" +
" \"name\": \"John\",\n" +
" \"food\": {\n" +
" \"cal\": \"55\",\n" +
" \"sugar\": \"none\"\n" +
" }\n" +
" }\n" +
"}";

String serviceURL = getMainSequenceURL() + "log-mediator-template/error";
HttpResponse httpResponse = httpClient.doPost(serviceURL, null, requestPayload, "application/json");
Assert.assertEquals(httpResponse.getStatusLine().getStatusCode(), 200, "Response code mismatched");
EntityUtils.consumeQuietly(httpResponse.getEntity());

boolean logLine1 = carbonLogReader
.checkForLog("Processing error message: {\"name\":\"John\",\"food\":{\"cal\":\"55\",\"sugar\":\"none\"}}",
DEFAULT_TIMEOUT);
Assert.assertTrue(logLine1, "Log mediator ERROR message Line 1 not logged");

boolean logLine2 = carbonLogReader
.checkForLog("Error occurred while processing backend response, STATUS_CODE = 200", DEFAULT_TIMEOUT);
Assert.assertTrue(logLine2, "Log mediator ERROR message Line 2 not logged");

carbonLogReader.stop();
}

@Test(groups = {"wso2.esb"}, description = "Testing Log mediator FATAL level")
public void testLogMediatorFATAL() throws IOException, InterruptedException {

CarbonLogReader carbonLogReader = new CarbonLogReader();
carbonLogReader.start();

String requestPayload = "<data><name>John</name><food><cal>55</cal><sugar>none</sugar></food></data>";

String serviceURL = getMainSequenceURL() + "log-mediator-template/fatal";
HttpResponse httpResponse = httpClient.doPost(serviceURL, null, requestPayload, "application/xml");
Assert.assertEquals(httpResponse.getStatusLine().getStatusCode(), 200, "Response code mismatched");
EntityUtils.consumeQuietly(httpResponse.getEntity());

boolean logLine1 = carbonLogReader
.checkForLog("Critical issue detected: <food><cal>55</cal><sugar>none</sugar></food>, prop1 = synapse_prop1",
DEFAULT_TIMEOUT);
Assert.assertTrue(logLine1, "Log mediator FATAL message Line 1 not logged");
carbonLogReader.stop();
}

@AfterClass(alwaysRun = true)
private void destroy() throws Exception {

super.cleanup();
}
}
104 changes: 104 additions & 0 deletions ...er/repository/deployment/server/synapse-configs/default/api/TestLogMediatorTemplating.xml
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,104 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright (c) 2024, WSO2 LLC. (https://www.wso2.com) All Rights Reserved.
~
~ WSO2 LLC. licenses this file to you under the Apache License,
~ Version 2.0 (the "License"); you may not use this file except
~ in compliance with the License.
~ You may obtain a copy of the License at
~
~ http://www.apache.org/licenses/LICENSE-2.0
~
~ Unless required by applicable law or agreed to in writing,
~ software distributed under the License is distributed on an
~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
~ KIND, either express or implied. See the License for the
~ specific language governing permissions and limitations
~ under the License.
~
-->
<api xmlns="http://ws.apache.org/ns/synapse" name="LogMediatorTemplateAPI" context="/log-mediator-template">
<resource methods="POST" url-mapping="/info">
<inSequence>
<variable name="requestID" expression="${payload.data.name + '_123123'}"/>
<variable name="endpoint" value="http://localhost:8480/log-mediator-template/mock-backend-json"/>
<log category="INFO">
<message>Processing info message: ${payload.data} using endpoint ${var.endpoint}</message>
</log>
<call>
<endpoint>
<http method="post" uri-template="http://localhost:8480/log-mediator-template/mock-backend-json"/>
</endpoint>
</call>
<log category="INFO" separator="|">
<message>Backend result = ${payload}</message>
<property name="requestID" expression="${var.requestID}"/>
<property name="test" value="abc123"/>
</log>
<respond/>
</inSequence>
</resource>
<resource methods="POST" url-mapping="/warn">
<inSequence>
<log category="WARN">
<message>Processing message: ${payload.data} using endpoint ${var.undefined}</message>
</log>
<call>
<endpoint>
<http method="post" uri-template="http://localhost:8480/log-mediator-template/mock-backend-json"/>
</endpoint>
</call>
<log category="WARN">
<message>Log warn message</message>
<property name="payload" expression="${payload}"/>
<property name="content-type-header" expression="${headers['Content-Type']}"/>
</log>
<respond/>
</inSequence>
</resource>
<resource methods="POST" url-mapping="/error">
<inSequence>
<log category="ERROR">
<message>Processing error message: ${payload.data}</message>
</log>
<call>
<endpoint>
<http method="post" uri-template="http://localhost:8480/log-mediator-template/mock-backend-json"/>
</endpoint>
</call>
<log category="ERROR">
<message>Error occurred while processing backend response</message>
<property name="STATUS_CODE" expression="${properties.axis2.HTTP_SC}"/>
</log>
<respond/>
</inSequence>
</resource>

<!-- Resource for testing FATAL log category -->
<resource methods="POST" url-mapping="/fatal">
<inSequence>
<property name="prop1" value="synapse_prop1"/>
<log category="FATAL">
<message>Critical issue detected: ${xpath('//data/food')}</message>
<property name="prop1" expression="${properties.synapse.prop1}"/>
</log>
<respond/>
</inSequence>
</resource>
<resource methods="POST GET" uri-template="/mock-backend-json">
<inSequence>
<payloadFactory media-type="json" template-type="default">
<format>{
"pet": {
"name": "pet3",
"type": "mock-backend"
}
}
</format>
</payloadFactory>
<respond/>
</inSequence>
<faultSequence>
</faultSequence>
</resource>
</api>

0 comments on commit 75f735d

Please sign in to comment.