package org.onap.ccsdk.features.sdnr.wt.mountpointstateprovider.test;
/*******************************************************************************
 * ============LICENSE_START========================================================================
 * ONAP : ccsdk feature sdnr wt
 * =================================================================================================
 * Copyright (C) 2019 highstreet technologies GmbH 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==========================================================================
 ******************************************************************************/

import java.io.IOException;
import java.util.Collection;
import java.util.List;
import java.util.Properties;
import java.util.concurrent.TimeUnit;

import org.json.JSONObject;
import org.junit.Before;
import org.junit.Test;
import org.onap.ccsdk.features.sdnr.wt.common.configuration.Configuration;
import org.onap.ccsdk.features.sdnr.wt.common.configuration.ConfigurationFileRepresentation;
import org.onap.ccsdk.features.sdnr.wt.mountpointstateprovider.impl.GeneralConfig;
import org.onap.ccsdk.features.sdnr.wt.mountpointstateprovider.impl.MountpointStatePublisher;
import org.onap.dmaap.mr.client.MRBatchingPublisher;
import org.onap.dmaap.mr.client.response.MRPublisherResponse;
import org.slf4j.Logger;

public class TestMountpointStatePublisher {

	private static final String CONFIGURATIONTESTFILE = "test.properties";
	public Thread publisher;

	@Before
	public void testMountpointStatePublisherData() {
		String testJsonData = "{\"NodeId\":\"69322972e178_50001\",\"NetConfNodeState\":\"Connecting\",\"TimeStamp\":\"2019-11-12T12:45:08.604Z\"}";
		JSONObject jsonObj = new JSONObject(testJsonData);
		MountpointStatePublisher.stateObjects.add(jsonObj);
	}

	@Test
	public void testMountpointStatePublisherConfiguration() throws InterruptedException {
		ConfigurationFileRepresentation configFileRepresentation = new ConfigurationFileRepresentation(CONFIGURATIONTESTFILE);
		GeneralConfig cfg = new GeneralConfig(configFileRepresentation);

		MountpointStatePublisher pub = new MountpointStatePublisherMock(cfg);
		pub.createPublisher(null);
		pub.publishMessage(pub.createPublisher(null), "Test DMaaP Message");

	}

	public class MountpointStatePublisherMock extends MountpointStatePublisher {

		public MountpointStatePublisherMock(Configuration config) {
			super(config);
		}

		@Override
		public MRBatchingPublisher createPublisher(Properties publisherProperties) {

			return new MRBatchingPublisher() {

				@Override
				public int send(String msg) throws IOException {
					// TODO Auto-generated method stub
					System.out.println("Message to send - "+msg);
					return 0;
				}

				@Override
				public int send(String partition, String msg) throws IOException {
					// TODO Auto-generated method stub
					return 0;
				}

				@Override
				public int send(message msg) throws IOException {
					// TODO Auto-generated method stub
					return 0;
				}

				@Override
				public int send(Collection<message> msgs) throws IOException {
					// TODO Auto-generated method stub
					return 0;
				}

				@Override
				public void close() {
					// TODO Auto-generated method stub

				}

				@Override
				public void logTo(Logger log) {
					// TODO Auto-generated method stub

				}

				@Override
				public void setApiCredentials(String apiKey, String apiSecret) {
					// TODO Auto-generated method stub

				}

				@Override
				public void clearApiCredentials() {
					// TODO Auto-generated method stub

				}

				@Override
				public int getPendingMessageCount() {
					// TODO Auto-generated method stub
					return 0;
				}

				@Override
				public List<message> close(long timeout, TimeUnit timeoutUnits)
						throws IOException, InterruptedException {
					// TODO Auto-generated method stub
					return null;
				}

				@Override
				public MRPublisherResponse sendBatchWithResponse() {
					// TODO Auto-generated method stub
					return null;
				}

			};
		}
	}

}