SDC Listner Docker touchup

[ccsdk/cds.git] / ms / sdclistener / application / src / main / java / org / onap / ccsdk / cds / sdclistener / SdcListenerNotificationCallback.java

diff --git a/ms/cds-sdc-listener/application/src/main/java/org/onap/ccsdk/cds/cdssdclistener/CdsSdcListenerNotificationCallback.java b/ms/sdclistener/application/src/main/java/org/onap/ccsdk/cds/sdclistener/SdcListenerNotificationCallback.java
similarity index 83%
rename from ms/cds-sdc-listener/application/src/main/java/org/onap/ccsdk/cds/cdssdclistener/CdsSdcListenerNotificationCallback.java
rename to ms/sdclistener/application/src/main/java/org/onap/ccsdk/cds/sdclistener/SdcListenerNotificationCallback.java
index 58c667c..eb339ae 100644 (file)
--- a/ms/cds-sdc-listener/application/src/main/java/org/onap/ccsdk/cds/cdssdclistener/CdsSdcListenerNotificationCallback.java
+++ b/ms/sdclistener/application/src/main/java/org/onap/ccsdk/cds/sdclistener/SdcListenerNotificationCallback.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.onap.ccsdk.cds.cdssdclistener;
+package org.onap.ccsdk.cds.sdclistener;
 
 import static org.onap.sdc.utils.DistributionActionResultEnum.SUCCESS;
 import java.io.File;
@@ -22,10 +22,10 @@ import java.nio.file.Paths;
 import java.util.List;
 import java.util.Objects;
 import java.util.Optional;
-import org.onap.ccsdk.cds.cdssdclistener.dto.CdsSdcListenerDto;
-import org.onap.ccsdk.cds.cdssdclistener.service.ListenerService;
-import org.onap.ccsdk.cds.cdssdclistener.status.CdsSdcListenerStatus;
-import org.onap.ccsdk.cds.cdssdclistener.util.FileUtil;
+import org.onap.ccsdk.cds.sdclistener.dto.SdcListenerDto;
+import org.onap.ccsdk.cds.sdclistener.service.ListenerService;
+import org.onap.ccsdk.cds.sdclistener.status.SdcListenerStatus;
+import org.onap.ccsdk.cds.sdclistener.util.FileUtil;
 import org.onap.sdc.api.IDistributionClient;
 import org.onap.sdc.api.consumer.INotificationCallback;
 import org.onap.sdc.api.notification.IArtifactInfo;
@@ -43,10 +43,10 @@ import org.springframework.stereotype.Component;
 @ConfigurationProperties("listenerservice")
 @Component
 @ComponentScan("org.onap.ccsdk.cds.cdssdclistener.dto")
-public class CdsSdcListenerNotificationCallback implements INotificationCallback {
+public class SdcListenerNotificationCallback implements INotificationCallback {
 
     @Autowired
-    private CdsSdcListenerDto cdsSdcListenerDto;
+    private SdcListenerDto sdcListenerDto;
 
     @Autowired
     private ListenerService listenerService;
@@ -55,20 +55,20 @@ public class CdsSdcListenerNotificationCallback implements INotificationCallback
     private String pathToStoreArchives;
 
     @Autowired
-    private CdsSdcListenerStatus listenerStatus;
+    private SdcListenerStatus listenerStatus;
 
-    private static final Logger LOGGER = LoggerFactory.getLogger(CdsSdcListenerNotificationCallback.class);
+    private static final Logger LOGGER = LoggerFactory.getLogger(SdcListenerNotificationCallback.class);
 
     @Override
     public void activateCallback(INotificationData notificationData) {
         final String distributionId = notificationData.getDistributionID();
-        cdsSdcListenerDto.setDistributionId(distributionId);
+        sdcListenerDto.setDistributionId(distributionId);
         LOGGER.info("Received service distribution from SDC with the id {}", distributionId);
         processNotification(notificationData);
     }
 
     private void processNotification(INotificationData notificationData) {
-        final IDistributionClient distributionClient = cdsSdcListenerDto.getDistributionClient();
+        final IDistributionClient distributionClient = sdcListenerDto.getDistributionClient();
         notificationData.getServiceArtifacts()
             .forEach(artifactInfo -> downloadCsarArtifacts(artifactInfo, distributionClient));
     }
@@ -83,7 +83,7 @@ public class CdsSdcListenerNotificationCallback implements INotificationCallback
         final String url = info.getArtifactURL();
         final String id = info.getArtifactUUID();
 
-        if (Objects.equals(info.getArtifactType(), CdsSdcListenerConfiguration.TOSCA_CSAR)) {
+        if (Objects.equals(info.getArtifactType(), SdcListenerConfiguration.TOSCA_CSAR)) {
             LOGGER.info("Trying to download the artifact from : {} and UUID is {} ", url, id);
 
             // Download the artifact
@@ -92,7 +92,7 @@ public class CdsSdcListenerNotificationCallback implements INotificationCallback
             if (!Objects.equals(result.getDistributionActionResult(), SUCCESS)) {
                 String errorMessage = String.format("Failed to download the artifact from : %s due to %s ", url,
                     result.getDistributionActionResult());
-                listenerStatus.sendResponseStatusBackToSDC(cdsSdcListenerDto.getDistributionId(),
+                listenerStatus.sendResponseStatusBackToSDC(sdcListenerDto.getDistributionId(),
                     DistributionStatusEnum.COMPONENT_DONE_ERROR, errorMessage);
                 LOGGER.error(errorMessage);
             } else {
@@ -124,6 +124,6 @@ public class CdsSdcListenerNotificationCallback implements INotificationCallback
             }
         }
 
-        listenerService.saveBluePrintToCdsDatabase(cbaArchivePath, cdsSdcListenerDto.getManagedChannelForGrpc());
+        listenerService.saveBluePrintToCdsDatabase(cbaArchivePath, sdcListenerDto.getManagedChannelForGrpc());
     }
 }