coverage sli-northbound

adding junit test files for AsdcApiSliClient, AsdcApiUtil, DataChangeClient, SdncFlatJsonDmaapConsumer, SdncARModel, SdncNodeModel, SdncVFCModel, SdncVFModuleModel, SdncUebCallback

Change-Id: Ia7fb307b84957292f9080654c7ae31992434317f
Issue-ID: CCSDK-230
Signed-off-by: Jeremy Wolf <jw720x@us.att.com>

9 files changed, 378 insertions, 1 deletions

diff --git a/asdcApi/provider/src/test/java/org/onap/ccsdk/sli/northbound/asdcapi/AsdcApiSliClientTest.java b/asdcApi/provider/src/test/java/org/onap/ccsdk/sli/northbound/asdcapi/AsdcApiSliClientTest.java
new file mode 100644
index 000000000..5e6a9daf7
--- /dev/null
+++ b/asdcApi/provider/src/test/java/org/onap/ccsdk/sli/northbound/asdcapi/AsdcApiSliClientTest.java
@@ -0,0 +1,59 @@
+package org.onap.ccsdk.sli.northbound.asdcapi; 
+ 
+import static org.junit.Assert.*; 
+import static org.mockito.Mockito.*; 
+ 
+import java.util.Properties; 
+ 
+import org.junit.Before; 
+import org.junit.Test; 
+import org.onap.ccsdk.sli.core.sli.SvcLogicException; 
+import org.onap.ccsdk.sli.core.sli.provider.SvcLogicService; 
+ 
+public class AsdcApiSliClientTest { 
+	Properties mockProp; 
+	Properties propReturn; 
+	AsdcApiSliClient testAsdcApiSliClient; 
+ 
+	@Before 
+	public void setup() { 
+		SvcLogicService mockSvcLogic = mock(SvcLogicService.class); 
+		mockProp = new Properties(); 
+		mockProp.setProperty("test-value1", "value1"); 
+		propReturn = new Properties(); 
+		propReturn.setProperty("SvcLogic.status", "Success"); 
+		propReturn.setProperty("Object1", "value1"); 
+		try { 
+			when(mockSvcLogic.hasGraph("TestModule", "TestRPC", "TestVersion", "TestMode")).thenReturn(true); 
+			when(mockSvcLogic.hasGraph("NotExist", "TestRPC", "TestVersion", "TestMode")).thenReturn(false); 
+			when(mockSvcLogic.execute("TestModule", "TestRPC", "TestVersion", "TestMode", mockProp)).thenReturn(propReturn); 
+		} catch (Exception e) { 
+			System.out.println(e); 
+		} 
+ 
+		testAsdcApiSliClient = new AsdcApiSliClient(mockSvcLogic); 
+	} 
+ 
+	@Test 
+	public void testhasGraphGraphExsists() throws SvcLogicException { 
+		assertTrue(testAsdcApiSliClient.hasGraph("TestModule", "TestRPC", "TestVersion", "TestMode")); 
+	} 
+ 
+	@Test 
+	public void testhasGraphnoGraph() throws SvcLogicException { 
+		assertFalse(testAsdcApiSliClient.hasGraph("NotExist", "TestRPC", "TestVersion", "TestMode")); 
+	} 
+ 
+	@Test 
+	public void testExecutewithSvcLogicSuccess() throws SvcLogicException { 
+		Properties result = testAsdcApiSliClient.execute("TestModule", "TestRPC", "TestVersion", "TestMode", mockProp); 
+		assertEquals(result.getProperty("error-code"), "200"); 
+	} 
+ 
+	@Test 
+	public void testExecutewithSvcLogicFailure500() throws SvcLogicException { 
+		propReturn.setProperty("SvcLogic.status", "failure"); 
+		Properties result = testAsdcApiSliClient.execute("TestModule", "TestRPC", "TestVersion", "TestMode", mockProp); 
+		assertEquals(result.getProperty("error-code"), "500"); 
+	} 
+}
\ No newline at end of file
diff --git a/asdcApi/provider/src/test/java/org/onap/ccsdk/sli/northbound/asdcapi/AsdcApiUtilTest.java b/asdcApi/provider/src/test/java/org/onap/ccsdk/sli/northbound/asdcapi/AsdcApiUtilTest.java
new file mode 100644
index 000000000..463e5ea0b
--- /dev/null
+++ b/asdcApi/provider/src/test/java/org/onap/ccsdk/sli/northbound/asdcapi/AsdcApiUtilTest.java
@@ -0,0 +1,15 @@
+package org.onap.ccsdk.sli.northbound.asdcapi; 
+ 
+import static org.junit.Assert.*; 
+ 
+import org.junit.Test; 
+ 
+public class AsdcApiUtilTest { 
+ 
+	@Test 
+	public void testAsdcApiUtilConstructor() { 
+		AsdcApiUtil asdcApiUtilTest = new AsdcApiUtil(); 
+		assertNotNull(asdcApiUtilTest); 
+	} 
+ 
+}
\ No newline at end of file
diff --git a/dataChange/provider/src/test/java/org/onap/sdnc/northbound/dataChange/DataChangeClientTest.java b/dataChange/provider/src/test/java/org/onap/sdnc/northbound/dataChange/DataChangeClientTest.java
new file mode 100644
index 000000000..9ba6c8742
--- /dev/null
+++ b/dataChange/provider/src/test/java/org/onap/sdnc/northbound/dataChange/DataChangeClientTest.java
@@ -0,0 +1,56 @@
+package org.onap.sdnc.northbound.dataChange; 
+ 
+import static org.junit.Assert.*; 
+import static org.mockito.Mockito.*; 
+ 
+import java.util.Properties; 
+ 
+import org.junit.Before; 
+import org.junit.Test; 
+import org.onap.ccsdk.sli.core.sli.SvcLogicException; 
+import org.onap.ccsdk.sli.core.sli.provider.MdsalHelper; 
+import org.onap.ccsdk.sli.core.sli.provider.SvcLogicService; 
+import org.onap.ccsdk.sli.northbound.DataChangeClient; 
+import org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.datachange.rev150519.DataChangeNotificationOutputBuilder; 
+ 
+public class DataChangeClientTest { 
+ 
+	SvcLogicService mockSvcLogicService; 
+	String module = "test-module"; 
+	String rpc = "test-rpc"; 
+	String version = "test-version"; 
+	String mode = "test-mode"; 
+	Properties localProp = new Properties(); 
+ 
+	@Before 
+	public void setUp() throws Exception { 
+		mockSvcLogicService = mock(SvcLogicService.class); 
+		when(mockSvcLogicService.hasGraph(module, rpc, version, mode)).thenReturn(true); 
+	} 
+ 
+	@Test 
+	public void testDataChangeClientConstructor() { 
+		DataChangeClient dataChangeClient = new DataChangeClient(mockSvcLogicService); 
+		assertNotNull(dataChangeClient); 
+	} 
+ 
+	@Test 
+	public void testHasGraph() throws SvcLogicException { 
+		DataChangeClient dataChangeClient = new DataChangeClient(mockSvcLogicService); 
+		boolean result = dataChangeClient.hasGraph(module, rpc, version, mode); 
+		assertTrue(result); 
+	} 
+ 
+	@Test 
+	public void testExecuteSvcLogicStatusFailure() throws SvcLogicException { 
+		DataChangeNotificationOutputBuilder serviceData = mock(DataChangeNotificationOutputBuilder.class); 
+		Properties parms = mock(Properties.class); 
+		SvcLogicService svcLogicService = mock(SvcLogicService.class); 
+		Properties properties = new Properties(); 
+		properties.setProperty("SvcLogic.status", "failure"); 
+		when(svcLogicService.execute(module, rpc, version, mode, properties)).thenReturn(properties); 
+		DataChangeClient sliClient = new DataChangeClient(svcLogicService); 
+		Properties prop = sliClient.execute(module, rpc, version, mode, serviceData, properties); 
+		assertTrue(prop != null); 
+	} 
+}
\ No newline at end of file
diff --git a/dmaap-listener/src/test/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncFlatJsonDmaapConsumerTest.java b/dmaap-listener/src/test/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncFlatJsonDmaapConsumerTest.java
new file mode 100644
index 000000000..d1aee634d
--- /dev/null
+++ b/dmaap-listener/src/test/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncFlatJsonDmaapConsumerTest.java
@@ -0,0 +1,41 @@
+package org.onap.ccsdk.sli.northbound.dmaapclient; 
+ 
+import static org.junit.Assert.*; 
+ 
+ 
+import java.io.File; 
+ 
+import org.junit.Before; 
+import org.junit.Test; 
+ 
+public class SdncFlatJsonDmaapConsumerTest { 
+ 
+	private static final String DMAAP_LISTENER_PROPERTIES = "dmaap-listener.properties"; 
+    private static final String DMAAP_LISTENER_PROPERTIES_DIR = "src/test/resources"; 
+ 
+    SdncFlatJsonDmaapConsumer consumer; 
+ 
+	@Before 
+	public void setUp() throws Exception { 
+		consumer = new SdncFlatJsonDmaapConsumer(); 
+	} 
+ 
+	@Test(expected = InvalidMessageException.class) 
+	public void testProcessMsgString_NullInvalidMessageException() throws InvalidMessageException { 
+		// expected = InvalidMessageException: Null message 
+		consumer.processMsg(null); 
+	} 
+ 
+	@Test(expected = InvalidMessageException.class) 
+	public void testProcessMsgString_UnformatedMessageInvalidMessageException() throws InvalidMessageException { 
+		// expected = InvalidMessageException: Cannot parse json object 
+		consumer.processMsg("TESTING", null); 
+	} 
+ 
+	@Test(expected = InvalidMessageException.class) 
+	public void testing()throws InvalidMessageException  { 
+		// Expected = InvalidMessageException: Unable to process message - cannot load field mappings 
+		String msg = "{\"test\":\"string\"}"; 
+		consumer.processMsg(msg, null); 
+	} 
+}
\ No newline at end of file
diff --git a/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncARModelTest.java b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncARModelTest.java
new file mode 100644
index 000000000..0d152e5e0
--- /dev/null
+++ b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncARModelTest.java
@@ -0,0 +1,21 @@
+package org.onap.ccsdk.sli.northbound.uebclient;
+ 
+ import static org.junit.Assert.*;
+ import static org.mockito.Mockito.*;
+ 
+ import org.junit.Test;
+ import org.openecomp.sdc.tosca.parser.api.ISdcCsarHelper;
+ import org.openecomp.sdc.toscaparser.api.NodeTemplate;
+ 
+ public class SdncARModelTest {
+ 
+ 	@Test
+ 	public void testSdncARModelConstructor() {
+ 		ISdcCsarHelper mockCsarHelper = mock(ISdcCsarHelper.class);
+ 		NodeTemplate nodeTemplate = mock(NodeTemplate.class);
+ 		SdncARModel testSdncARModel = new SdncARModel(mockCsarHelper,nodeTemplate);
+ 		assertNotNull(testSdncARModel);
+ 	}
+ 
+ }
+ 
diff --git a/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncNodeModelTest.java b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncNodeModelTest.java
new file mode 100644
index 000000000..4a66c0201
--- /dev/null
+++ b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncNodeModelTest.java
@@ -0,0 +1,49 @@
+package org.onap.ccsdk.sli.northbound.uebclient; 
+ 
+import static org.junit.Assert.*; 
+ 
+import static org.mockito.Mockito.*; 
+ 
+import org.junit.Before; 
+import org.junit.Test; 
+import org.openecomp.sdc.tosca.parser.api.ISdcCsarHelper; 
+import org.openecomp.sdc.toscaparser.api.NodeTemplate; 
+ 
+public class SdncNodeModelTest { 
+ 
+	SdncNodeModel sdncNodeModel; 
+ 
+	@Before 
+	public void setUp() throws Exception { 
+		ISdcCsarHelper isdcCsarHelper = mock(ISdcCsarHelper.class); 
+		NodeTemplate nodeTemplate = mock(NodeTemplate.class); 
+		sdncNodeModel = new SdncNodeModel(isdcCsarHelper, nodeTemplate); 
+		sdncNodeModel.setServiceUUID("0e8d757f-1c80-40af-85de-31d64f1f5af8"); 
+		sdncNodeModel.setEcompGeneratedNaming("hello-world"); 
+	} 
+ 
+	@Test 
+	public void testGetServiceUUID() { 
+		String result = sdncNodeModel.getServiceUUID(); 
+		assertNotNull(result != null); 
+	} 
+ 
+	@Test 
+	public void testGetEcompGeneratedNaming() { 
+		String result = sdncNodeModel.getEcompGeneratedNaming(); 
+		assertEquals("hello-world", result); 
+	} 
+ 
+	@Test 
+	public void testGetSqlString() { 
+		String result = sdncNodeModel.getSql("TEST-HELLO"); 
+		String test = "INSERT into NETWORK_MODEL (service_uuid, customization_uuid, model_yaml, ecomp_generated_naming) values (0e8d757f-1c80-40af-85de-31d64f1f5af8, \"\", \"TEST-HELLO\", \"hello-world\");"; 
+		assertEquals(test, result); 
+	} 
+ 
+	@Test 
+	public void testGetVpnBindingsSql() { 
+		String result = sdncNodeModel.getVpnBindingsSql(); 
+		assertNotNull(result); 
+	} 
+}
\ No newline at end of file
diff --git a/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncVFCModelTest.java b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncVFCModelTest.java
new file mode 100644
index 000000000..d2bafbf42
--- /dev/null
+++ b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncVFCModelTest.java
@@ -0,0 +1,36 @@
+package org.onap.ccsdk.sli.northbound.uebclient; 
+ 
+import static org.junit.Assert.*; 
+import static org.mockito.Mockito.*; 
+ 
+ 
+import org.junit.Before; 
+import org.junit.Test; 
+import org.openecomp.sdc.tosca.parser.api.ISdcCsarHelper; 
+import org.openecomp.sdc.toscaparser.api.NodeTemplate; 
+ 
+public class SdncVFCModelTest { 
+ 
+	SdncVFCModel testSdncVFCModel; 
+ 
+	@Before 
+	public void setup() { 
+		ISdcCsarHelper mockCsarHelper = mock(ISdcCsarHelper.class); 
+		NodeTemplate mockNodeTemplate = mock(NodeTemplate.class); 
+		testSdncVFCModel = new SdncVFCModel(mockCsarHelper, mockNodeTemplate); 
+		testSdncVFCModel.setVmType("Test-type"); 
+		testSdncVFCModel.setVmCount("5"); 
+ 
+	} 
+ 
+	@Test 
+	public void testSdncVFCModelGetVmType() { 
+		assertEquals(testSdncVFCModel.getVmType(), "Test-type"); 
+	} 
+ 
+	@Test 
+	public void testSdncVFCModelGetVmCount() { 
+		assertEquals(testSdncVFCModel.getVmCount(), "5"); 
+	} 
+ 
+}
\ No newline at end of file
diff --git a/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncVFModuleModelTest.java b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncVFModuleModelTest.java
new file mode 100644
index 000000000..218554357
--- /dev/null
+++ b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/SdncVFModuleModelTest.java
@@ -0,0 +1,20 @@
+package org.onap.ccsdk.sli.northbound.uebclient; 
+ 
+import static org.junit.Assert.*; 
+import static org.mockito.Mockito.mock; 
+ 
+import org.junit.Test; 
+import org.openecomp.sdc.tosca.parser.api.ISdcCsarHelper; 
+import org.openecomp.sdc.toscaparser.api.Group; 
+ 
+public class SdncVFModuleModelTest { 
+ 
+	@Test 
+	public void testSdncVFModuleModelConstructor() { 
+		Group mockGroup = mock(Group.class); 
+		ISdcCsarHelper mockCsarHelper = mock(ISdcCsarHelper.class); 
+		SdncVFModuleModel testSdncVFModel = new SdncVFModuleModel(mockCsarHelper, mockGroup); 
+		assertNotNull(testSdncVFModel); 
+	} 
+ 
+}
\ No newline at end of file
diff --git a/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/TestSdncUebCallback.java b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/TestSdncUebCallback.java
index 79a598ce5..21854f990 100644
--- a/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/TestSdncUebCallback.java
+++ b/ueb-listener/src/test/java/org/onap/ccsdk/sli/northbound/uebclient/TestSdncUebCallback.java
@@ -1,6 +1,7 @@
 package org.onap.ccsdk.sli.northbound.uebclient;
 
-import static org.mockito.Mockito.mock;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.*;
 
 import java.io.File;
 import java.io.InputStream;
@@ -9,6 +10,8 @@ import java.nio.file.DirectoryStream;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.StandardCopyOption;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Properties;
 
 import org.junit.After;
@@ -16,7 +19,9 @@ import org.junit.Before;
 import org.junit.Test;
 import org.onap.ccsdk.sli.core.dblib.DBResourceManager;
 import org.openecomp.sdc.api.IDistributionClient;
+import org.openecomp.sdc.api.notification.IArtifactInfo;
 import org.openecomp.sdc.api.notification.INotificationData;
+import org.openecomp.sdc.api.notification.IResourceInstance;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -149,6 +154,15 @@ public class TestSdncUebCallback {
 	SdncUebConfiguration config;
 	DBResourceManager dblibSvc;
 	DB db;
+	List<IArtifactInfo > processLevelArtifactList;
+	List<IArtifactInfo > serviceLevelArtifactList;
+	ArrayList<IResourceInstance> resourceList;
+	IArtifactInfo mockProcessArtifact1;
+	IArtifactInfo mockProcessArtifact2;
+	IArtifactInfo mockProcessArtifact3;
+	IArtifactInfo mockServiceArtifact1;
+	IResourceInstance resource;
+	
 
 	@Before
 	public void setUp() throws Exception {
@@ -186,6 +200,42 @@ public class TestSdncUebCallback {
 		dblibSvc.writeData(CRTBL_VF_MODEL, null, null);
 		dblibSvc.writeData(CRTBL_VF_MODULE_MODEL, null, null);
 		dblibSvc.writeData(CRTBL_ALLOTTED_RESOURCE_MODEL, null, null);
+		
+		processLevelArtifactList = new ArrayList<>();
+		serviceLevelArtifactList = new ArrayList<>();
+		resourceList = new ArrayList<>();
+
+		
+		mockProcessArtifact1 = mock(IArtifactInfo.class);
+		when(mockProcessArtifact1.getArtifactName()).thenReturn("mockProcessArtifact1");
+		when(mockProcessArtifact1.getArtifactType()).thenReturn("HEAT");
+		when(mockProcessArtifact1.getArtifactURL()).thenReturn("https://asdc.sdc.com/v1/catalog/services/srv1/2.0/resources/aaa/1.0/artifacts/aaa.yml");
+		when(mockProcessArtifact1.getArtifactChecksum()).thenReturn("123tfg123 1234ftg");
+		when(mockProcessArtifact1.getArtifactTimeout()).thenReturn(110);
+		
+		mockProcessArtifact2 = mock(IArtifactInfo.class);
+		when(mockProcessArtifact1.getArtifactName()).thenReturn("mockProcessArtifact2");
+		when(mockProcessArtifact1.getArtifactType()).thenReturn("DG_XML");
+		when(mockProcessArtifact1.getArtifactURL()).thenReturn("https://asdc.sdc.com/v1/catalog/services/srv1/2.0/resources/aaa/1.0/artifacts/aaa.yml");
+		when(mockProcessArtifact1.getArtifactChecksum()).thenReturn("456jhgt 1234ftg");
+		when(mockProcessArtifact1.getArtifactTimeout()).thenReturn(110);
+		
+		mockProcessArtifact3 = mock(IArtifactInfo.class);
+		when(mockProcessArtifact1.getArtifactName()).thenReturn("mockProcessArtifact3");
+		when(mockProcessArtifact1.getArtifactType()).thenReturn("HEAT");
+		when(mockProcessArtifact1.getArtifactURL()).thenReturn("https://asdc.sdc.com/v1/catalog/services/srv1/2.0/resources/aaa/1.0/artifacts/aaa.yml");
+		when(mockProcessArtifact1.getArtifactChecksum()).thenReturn("123tfg123 543gtd");
+		when(mockProcessArtifact1.getArtifactTimeout()).thenReturn(110);
+		
+		
+		mockServiceArtifact1 = mock(IArtifactInfo.class);
+		when(mockServiceArtifact1.getArtifactName()).thenReturn("mockProcessArtifact4");
+		when(mockServiceArtifact1.getArtifactType()).thenReturn("HEAT");
+		when(mockServiceArtifact1.getArtifactURL()).thenReturn("https://asdc.sdc.com/v1/catalog/services/srv1/2.0/resources/aaa/1.0/artifacts/aaa.yml");
+		when(mockServiceArtifact1.getArtifactChecksum()).thenReturn("123t3455 543gtd");
+		when(mockServiceArtifact1.getArtifactTimeout()).thenReturn(110);
+		
+		resource = mock(IResourceInstance.class);
 	}
 
 	@After
@@ -219,5 +269,35 @@ public class TestSdncUebCallback {
 		INotificationData iData = mock(INotificationData.class);
 		cb.activateCallback(iData);
 	}
+	
+	
+	
+	@Test
+	public void testServiceAndProcessArtifactsactivateCallback() {
+
+		try {
+		processLevelArtifactList.add(mockProcessArtifact1);
+		processLevelArtifactList.add(mockProcessArtifact2);
+		processLevelArtifactList.add(mockProcessArtifact3);
+		
+		resourceList.add(resource);
+		serviceLevelArtifactList.add(mockServiceArtifact1);
+		when(resource.getArtifacts()).thenReturn(serviceLevelArtifactList);
+		when(resource.getResourceName()).thenReturn("Resource_service_name");
+
+
+		IDistributionClient iDistClient1 = mock(IDistributionClient.class);
+		INotificationData mockData = mock(INotificationData.class);
+		when(mockData.getResources()).thenReturn(resourceList);
+		when(mockData.getServiceName()).thenReturn("Test_service_name");
+		when(mockData.getServiceArtifacts()).thenReturn(processLevelArtifactList);
+		
+		SdncUebCallback cb1 = new SdncUebCallback(iDistClient1, config);
+		cb1.activateCallback(mockData);
+		assertTrue(true);
+		} catch (Exception e) {
+			assertTrue(false);
+		}
+	}
 
 }