/*******************************************************************************
 *  ============LICENSE_START=======================================================
 *  org.onap.dmaap
 *  ================================================================================
 *  Copyright © 2017 AT&T Intellectual Property. 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.
 *  ============LICENSE_END=========================================================
 *
 *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
 *  
 *******************************************************************************/
package org.onap.dmaap.mr.test.dme2;

import java.net.URI;
import java.net.URISyntaxException;
import java.util.HashMap;
import java.util.Properties;

import org.apache.log4j.Logger;

import junit.framework.TestCase;

import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;

public class DME2ConsumerTest extends TestCase {
	private static final Logger LOGGER = Logger.getLogger(DME2ConsumerTest.class);

	public void testConsumer() {
		LOGGER.info("Test case subcribing initiated");
		
		Properties props = LoadPropertyFile.getPropertyFileDataProducer();
		String latitude = props.getProperty("Latitude");
		String longitude = props.getProperty("Longitude");
		String version = props.getProperty("Version");
		String serviceName = props.getProperty("ServiceName");
		String env = props.getProperty("Environment");
		String partner = props.getProperty("Partner");
		String protocol = props.getProperty("Protocol");
		String methodType = props.getProperty("MethodTypeGet");
		String user = props.getProperty("user");
		String password = props.getProperty("password");
		String contenttype = props.getProperty("contenttype");
		String url = protocol + "://DME2SEARCH/" + "service=" + serviceName + "/" + "version=" + version + "/"
				+ "envContext=" + env + "/" + "partner=" + partner;
		LoadPropertyFile.loadAFTProperties(latitude, longitude);
		HashMap<String, String> hm = new HashMap<String, String>();
		hm.put("AFT_DME2_EP_READ_TIMEOUT_MS", "50000");
		hm.put("AFT_DME2_ROUNDTRIP_TIMEOUT_MS", "240000");
		hm.put("AFT_DME2_EP_CONN_TIMEOUT", "5000");
		try {

			// topic exist logic is commented
			// if (!topicTestObj.topicExist(url, props, hm)) {
			// throw new Exception("Topic does not exist");
			// } else {
			DME2Client sender = new DME2Client(new URI(url), 5000L);
			sender.setAllowAllHttpReturnCodes(true);
			sender.setMethod(methodType);
			String subContextPathConsumer = props.getProperty("SubContextPathConsumer") + props.getProperty("newTopic")
					+ "/" + props.getProperty("group") + "/" + props.getProperty("id");
			sender.setSubContext(subContextPathConsumer);
			sender.setPayload("");

			sender.addHeader("Content-Type", contenttype);
			sender.setCredentials(user, password);
			sender.setHeaders(hm);

			LOGGER.info("Consuming Message");
			String reply = sender.sendAndWait(5000L);

			assertNotNull(reply);
			LOGGER.info("Message received = " + reply);
			// }
		} catch (DME2Exception e) {
			e.printStackTrace();
		} catch (URISyntaxException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}