X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2FdmaapMMAgent%2FTestMirrorMakerAgent.java;h=fdcb1edb58d10cb556c4d28969ebe2b9410baf17;hb=refs%2Fchanges%2F21%2F83921%2F1;hp=def9f395a6911f51ac74a25ee62398ca0bddf006;hpb=e5b378ca8f3c6667ab8b8bc6cfce6aead463f447;p=dmaap%2Fmessagerouter%2Fmirroragent.git

diff --git a/src/test/java/org/onap/dmaap/mr/dmaapMMAgent/TestMirrorMakerAgent.java b/src/test/java/org/onap/dmaap/mr/dmaapMMAgent/TestMirrorMakerAgent.java
index def9f39..fdcb1ed 100644
--- a/src/test/java/org/onap/dmaap/mr/dmaapMMAgent/TestMirrorMakerAgent.java
+++ b/src/test/java/org/onap/dmaap/mr/dmaapMMAgent/TestMirrorMakerAgent.java
@@ -24,42 +24,117 @@ package org.onap.dmaap.mr.dmaapMMAgent;
 
 import static org.junit.Assert.*;
 
-import java.io.DataOutputStream;
-import java.io.FileInputStream;
-import java.io.FileNotFoundException;
-import java.net.HttpURLConnection;
 import java.util.ArrayList;
 
+import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
-import org.powermock.api.mockito.PowerMockito;
-import org.powermock.core.classloader.annotations.Mock;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
 import org.powermock.modules.junit4.PowerMockRunner;
 
-import  org.onap.dmaap.mr.dmaapMMAgent.dao.ListMirrorMaker;
-import  org.onap.dmaap.mr.dmaapMMAgent.dao.MirrorMaker;
+import org.onap.dmaap.mr.dmaapMMAgent.dao.ListMirrorMaker;
+import org.onap.dmaap.mr.dmaapMMAgent.dao.MirrorMaker;
+import com.google.gson.Gson;
+import com.google.gson.internal.LinkedTreeMap;
+
+@RunWith(PowerMockRunner.class)
+public class TestMirrorMakerAgent {
 
-//@RunWith(PowerMockRunner.class)
-public class TestMirrorMakerAgent {/*
 	MirrorMakerAgent mirrorMakerAgent = new MirrorMakerAgent();
 	ListMirrorMaker listMirrorMaker = new ListMirrorMaker();
 	MirrorMaker mirrorMaker = new MirrorMaker();
 	MirrorMaker mirrorMaker2 = new MirrorMaker();
 	ArrayList<MirrorMaker> listsMirrorMaker = new ArrayList<MirrorMaker>();
+	Gson g = new Gson();
+	@InjectMocks
+	private MirrorMakerAgent agent;
+	@Mock
+	private TopicUtil topicUtil;
+
+	@Before
+	public void setUp() {
+		MockitoAnnotations.initMocks(this);
+	}
 
 	@Test
 	public void testcheckStartup() {
 		String currentDirectory = System.getProperty("user.dir");
 		String MMAGENTHOME = currentDirectory + "/src/test/resources/";
-		String parameters[] = {"-encrypt", "test"};
+		String parameters[] = { "-encrypt", "test" };
 		String args[] = null;
-		
+
 		System.setProperty("MMAGENTHOME", MMAGENTHOME);
-		
 		mirrorMakerAgent.main(args);
-		
+
 	}
 	
+	@Test
+	public void testcheckStartupWtOneParam() {
+		String parameters[] = { "test" };
+		mirrorMakerAgent.main(parameters);
+
+	}
+	
+
+	@Test
+	public void testReadAgentTopics() {
+
+		agent.exitLoop = true;
+		agent.readAgentTopic();
+	}
+
+	@Test
+	public void testReadCreateMirrorMaker() throws Exception {
+
+		String topicMessage = "{ messageID:\"test\", createMirrorMaker: {   name:\"test\",   consumer:\"test\",  producer:\"test\"}}";
+		LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+		agent.exitLoop = true;
+		agent.readAgent(object, topicMessage);
+
+	}
+
+	@Test
+	public void testReadUpdateMirrorMaker() throws Exception {
+
+		String topicMessage = "{ messageID:\"test\", updateMirrorMaker: {   name:\"test\",   consumer:\"test\",  producer:\"test\"}}";
+		LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+		testReadCreateMirrorMaker();
+		agent.readAgent(object, topicMessage);
+
+	}
+
+	@Test
+	public void testReadDeleteMirrorMaker() throws Exception {
+
+		String topicMessage = "{ messageID:\"test\", deleteMirrorMaker: {   name:\"test\",   consumer:\"test\",  producer:\"test\",  whitelist:\"test\",status:\"test\" }}";
+		LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+		testReadCreateMirrorMaker();
+		agent.readAgent(object, topicMessage);
+
+	}
+
+	@Test
+	public void testReadListMirrorMaker() throws Exception {
+
+		String topicMessage = "{ messageID:\"test\", listAllMirrorMaker: {   name:\"test\",   consumer:\"test\",  producer:\"test\",  whitelist:\"test\",status:\"test\" }}";
+		LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+		testReadCreateMirrorMaker();
+		agent.readAgent(object, topicMessage);
+
+	}
+
+	@Test
+	public void testReadWhitelistMirrorMaker() throws Exception {
+
+		String topicMessage = "{ messageID:\"test\", updateWhiteList: {   name:\"test\",   consumer:\"test\",  producer:\"test\",  whitelist:\"test\",status:\"test\" }}";
+		LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+		testReadCreateMirrorMaker();
+		agent.readAgent(object, topicMessage);
+
+	}
+
 	@Test
 	public void testCreateMirrorMaker() {
 		mirrorMaker.setConsumer("consumer");
@@ -67,21 +142,34 @@ public class TestMirrorMakerAgent {/*
 		mirrorMaker.setProducer("producer");
 		mirrorMaker.setStatus("200");
 		mirrorMaker.setWhitelist("whitelist");
-		
+
 		mirrorMaker2.setConsumer("consumer");
 		mirrorMaker2.setName("MirrorMaker2");
 		mirrorMaker2.setProducer("producer");
 		mirrorMaker2.setStatus("200");
 		mirrorMaker2.setWhitelist("whitelist");
-		
+
 		listsMirrorMaker.add(mirrorMaker2);
 		listMirrorMaker.setListMirrorMaker(listsMirrorMaker);
-		
+
 		mirrorMakerAgent.mirrorMakers = listMirrorMaker;
-		
+
 		mirrorMakerAgent.createMirrorMaker(mirrorMaker);
-		
+
 		assertEquals(2, mirrorMakerAgent.mirrorMakers.getListMirrorMaker().size());
 	}
 
-*/}
+	@Test
+	public void testPublish() {
+		TopicUtil util = new TopicUtil();
+		util.publishTopic("http://localhost:3904/events/testtopic", "topicname", "mechid", "password", "message");
+
+	}
+
+	@Test
+	public void testSubscribe() {
+		TopicUtil util = new TopicUtil();
+		util.subscribeTopic("http://localhost:3904/events/testtopic/cg/c", "topicname", "1", "mechid", "password");
+
+	}
+}