CDS-SDC Listener application

Things done-
CDS-SDC listener able to register for SDC distribution.
Download the artifacts.

Things to do-
Add logic to parse the blueprint from CSAR and store it into CDS DB.

Change-Id: I2fe01af73814e749f93a62d3a90e1f05947c0505
Issue-ID: CCSDK-349
Signed-off-by: prathamesh morde <prathamesh.morde@bell.ca>

2 files changed, 112 insertions, 0 deletions

diff --git a/ms/cds-sdc-listener/application/src/test/java/org/onap/ccsdk/apps/cdssdclistener/CdsSdcListenerClientTest.java b/ms/cds-sdc-listener/application/src/test/java/org/onap/ccsdk/apps/cdssdclistener/CdsSdcListenerClientTest.java
new file mode 100644
index 000000000..3a634b8c9
--- /dev/null
+++ b/ms/cds-sdc-listener/application/src/test/java/org/onap/ccsdk/apps/cdssdclistener/CdsSdcListenerClientTest.java
@@ -0,0 +1,71 @@
+/*
+ * Copyright (C) 2019 Bell Canada. All rights reserved.
+ *
+ * NOTICE:  All the intellectual and technical concepts contained herein are
+ * proprietary to Bell Canada and are protected by trade secret or copyright law.
+ * Unauthorized copying of this file, via any medium is strictly prohibited.
+ */
+
+package org.onap.ccsdk.apps.cdssdclistener;
+
+import mockit.Expectations;
+import mockit.Injectable;
+import mockit.Mock;
+import mockit.MockUp;
+import mockit.Tested;
+import mockit.VerificationsInOrder;
+import mockit.integration.junit4.JMockit;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.onap.ccsdk.apps.cdssdclistener.exceptions.CdsSdcListenerException;
+import org.onap.sdc.api.IDistributionClient;
+import org.onap.sdc.api.results.IDistributionClientResult;
+import org.onap.sdc.impl.DistributionClientFactory;
+import org.onap.sdc.impl.DistributionClientResultImpl;
+import org.onap.sdc.utils.DistributionActionResultEnum;
+
+@RunWith(JMockit.class)
+public class CdsSdcListenerClientTest {
+
+    @Tested
+    private CdsSdcListenerClient cdsSdcListenerClient;
+
+    @Test
+    public void testInitCdsClientSuccesfully(@Injectable IDistributionClient distributionClient,
+        @Injectable CdsSdcListenerConfiguration configuration,
+        @Injectable CdsSdcListenerNotificationCallback notification,
+        @Injectable CdsSdcListenerDto cdsSdcListenerDto) throws CdsSdcListenerException {
+
+        // Arrange
+        new MockUp<DistributionClientFactory>() {
+            @Mock
+            public IDistributionClient createDistributionClient() {
+                return distributionClient;
+            }
+        };
+
+        new Expectations() {{
+            distributionClient.init(configuration, notification);
+            result = getResult();
+        }};
+
+        new Expectations() {{
+            distributionClient.start();
+            result = getResult();
+        }};
+
+        // Act
+        cdsSdcListenerClient.initSdcClient();
+
+        // Verify
+        new VerificationsInOrder() {{
+            distributionClient.init(configuration, notification);
+            distributionClient.start();
+        }};
+    }
+
+    public IDistributionClientResult getResult() {
+        return new DistributionClientResultImpl(DistributionActionResultEnum.SUCCESS,
+            DistributionActionResultEnum.SUCCESS.name());
+    }
+}
diff --git a/ms/cds-sdc-listener/application/src/test/java/org/onap/ccsdk/apps/cdssdclistener/CdsSdcListenerConfigurationTest.java b/ms/cds-sdc-listener/application/src/test/java/org/onap/ccsdk/apps/cdssdclistener/CdsSdcListenerConfigurationTest.java
new file mode 100644
index 000000000..886049df7
--- /dev/null
+++ b/ms/cds-sdc-listener/application/src/test/java/org/onap/ccsdk/apps/cdssdclistener/CdsSdcListenerConfigurationTest.java
@@ -0,0 +1,41 @@
+/*
+ * Copyright (C) 2019 Bell Canada. All rights reserved.
+ *
+ * NOTICE:  All the intellectual and technical concepts contained herein are
+ * proprietary to Bell Canada and are protected by trade secret or copyright law.
+ * Unauthorized copying of this file, via any medium is strictly prohibited.
+ */
+
+package org.onap.ccsdk.apps.cdssdclistener;
+
+import static org.junit.Assert.assertEquals;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@EnableConfigurationProperties(CdsSdcListenerConfiguration.class)
+@SpringBootTest(classes = {CdsSdcListenerConfigurationTest.class})
+public class CdsSdcListenerConfigurationTest {
+
+    @Autowired
+    private CdsSdcListenerConfiguration listenerConfiguration;
+
+    @Test
+    public void testCdsSdcListenerConfiguration() {
+        assertEquals(listenerConfiguration.getAsdcAddress(), "localhost:8443");
+        assertEquals(listenerConfiguration.getMsgBusAddress().stream().findFirst().get(), "localhost");
+        assertEquals(listenerConfiguration.getUser(), "vid");
+        assertEquals(listenerConfiguration.getPassword(), "Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U");
+        assertEquals(listenerConfiguration.getPollingInterval(), 15);
+        assertEquals(listenerConfiguration.getPollingTimeout(), 15);
+        assertEquals(listenerConfiguration.getRelevantArtifactTypes().stream().findFirst().get(), "TOSCA_CSAR");
+        assertEquals(listenerConfiguration.getConsumerGroup(), "cds-id-local");
+        assertEquals(listenerConfiguration.getEnvironmentName(), "AUTO");
+        assertEquals(listenerConfiguration.getConsumerID(), "cds-id-local");
+        assertEquals(listenerConfiguration.activateServerTLSAuth(), false);
+    }
+}