/*
 * Copyright (c) 2015, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
 * 
 * Licensed 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.json;

import java.io.File;
import java.io.IOException;

import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.testng.Assert;
import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
import org.wso2.carbon.integration.common.admin.client.LogViewerClient;
import org.wso2.carbon.logging.view.stub.LogViewerLogViewerException;
import org.wso2.carbon.logging.view.stub.types.carbon.LogEvent;
import org.wso2.esb.integration.common.utils.ESBIntegrationTest;

public class ESBJAVA_3698_MessageBuildingWithDifferentPayloadAndContentTypeTestCase extends
                                                                                   ESBIntegrationTest {
	private final DefaultHttpClient httpClient = new DefaultHttpClient();
    private LogViewerClient logViewerClient;

	@BeforeClass(alwaysRun = true)
	public void setEnvironment() throws Exception {
		super.init();
		loadESBConfigurationFromClasspath("artifacts" + File.separator + "ESB" + File.separator +
		                                  "json" + File.separator + "StockQuoteAPI.xml");
        logViewerClient = new LogViewerClient(contextUrls.getBackEndUrl(), getSessionCookie());
	}

	@Test(groups = { "wso2.esb" }, description = "Check for Axis Fault when xml payload is sent with application/json" +
	                                             " content type", enabled = true)
	public void testAxisFaultWithXmlPayloadAndJSONContentType() throws ClientProtocolException,
	                                                           IOException, InterruptedException,
                                                               LogViewerLogViewerException {
		final HttpPost post = new HttpPost("http://localhost:8480/stockquote/test");
		post.addHeader("Content-Type", "application/json");
		post.addHeader("SOAPAction", "urn:getQuote");
		StringEntity se = new StringEntity(getPayload());
		post.setEntity(se);

        logViewerClient.clearLogs();

		httpClient.execute(post);

		Thread.sleep(10000);

        boolean isError = false;

        LogEvent[] logs = logViewerClient.getAllRemoteSystemLogs();
        for (int i = 0; i < logs.length; i++) {
            if (logs[i].getMessage().contains("Could not save JSON payload")) {
                isError = true;
                break;
            }
        }

        Assert.assertEquals(isError, true, "Expected SOAP Response was NOT found in the LOG stream.");
	}

	private String getPayload() {
		final String payload =
		                       "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://services.samples/xsd\" xmlns:ser=\"http://services.samples\">"
		                               + "<soapenv:Header/>"
		                               + "<soapenv:Body>"
		                               + "<ser:getQuote>"
		                               + "<ser:request>"
		                               + "<xsd:symbol>IBM</xsd:symbol>"
		                               + "</ser:request>"
		                               + "</ser:getQuote>"
		                               + "</soapenv:Body>"
		                               + "</soapenv:Envelope>";
		return payload;
	}

	@AfterClass(alwaysRun = true)
	public void destroy() throws Exception {
        logViewerClient = null;
		super.cleanup();
	}
}

@@ -3050,35 +3050,69 @@
 ns(%22
-Could not save JSON payload
+Error occurred while processing document for application/json
 %22)) 

Fix test failure