-/*-
- * ============LICENSE_START=======================================================
- * OPENECOMP - MSO
- * ================================================================================
- * Copyright (C) 2017 AT&T 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=========================================================
- */
-
-package org.openecomp.mso.asdc.client;
-
-
-import java.io.IOException;
-import java.io.UnsupportedEncodingException;
-import org.openecomp.sdc.api.IDistributionClient;
-import org.openecomp.sdc.api.consumer.IDistributionStatusMessage;
-import org.openecomp.sdc.api.consumer.INotificationCallback;
-import org.openecomp.sdc.api.notification.IArtifactInfo;
-import org.openecomp.sdc.api.notification.INotificationData;
-import org.openecomp.sdc.api.notification.IResourceInstance;
-import org.openecomp.sdc.api.results.IDistributionClientDownloadResult;
-import org.openecomp.sdc.api.results.IDistributionClientResult;
-import org.openecomp.sdc.impl.DistributionClientFactory;
-import org.openecomp.sdc.utils.DistributionActionResultEnum;
-import org.openecomp.sdc.utils.DistributionStatusEnum;
-import org.openecomp.mso.asdc.client.exceptions.ASDCControllerException;
-import org.openecomp.mso.asdc.client.exceptions.ASDCDownloadException;
-import org.openecomp.mso.asdc.client.exceptions.ASDCParametersException;
-import org.openecomp.mso.asdc.client.exceptions.ArtifactInstallerException;
-import org.openecomp.mso.asdc.installer.IVfResourceInstaller;
-import org.openecomp.mso.asdc.installer.VfResourceStructure;
-import org.openecomp.mso.asdc.installer.heat.VfResourceInstaller;
-import org.openecomp.mso.asdc.util.ASDCNotificationLogging;
-import org.openecomp.mso.logger.MessageEnum;
-import org.openecomp.mso.logger.MsoAlarmLogger;
-import org.openecomp.mso.logger.MsoLogger;
-import org.openecomp.mso.utils.UUIDChecker;
-
-public class ASDCController {
-
- protected static final MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.ASDC);
-
- protected static MsoAlarmLogger alarmLogger = new MsoAlarmLogger ();
-
- protected boolean isAsdcClientAutoManaged = false;
-
- protected String controllerName;
-
- /**
- * Inner class for Notification callback
- *
- *
- */
- private final class ASDCNotificationCallBack implements INotificationCallback {
-
- private ASDCController asdcController;
-
- ASDCNotificationCallBack (ASDCController controller) {
- asdcController = controller;
- }
-
- /**
- * This method can be called multiple times at the same moment.
- * The controller must be thread safe !
- */
- @Override
- public void activateCallback (INotificationData iNotif) {
- long startTime = System.currentTimeMillis ();
- UUIDChecker.generateUUID (LOGGER);
- MsoLogger.setServiceName ("NotificationHandler");
- MsoLogger.setLogContext (iNotif.getDistributionID (), iNotif.getServiceUUID ());
- String event = "Receive a callback notification in ASDC, nb of resources: " + iNotif.getResources ().size ();
- LOGGER.debug(event);
- asdcController.treatNotification (iNotif);
- LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Completed the treatment of the notification");
- }
- }
-
- // ***** Controller STATUS code
-
- protected int nbOfNotificationsOngoing = 0;
-
- public int getNbOfNotificationsOngoing () {
- return nbOfNotificationsOngoing;
- }
-
- private ASDCControllerStatus controllerStatus = ASDCControllerStatus.STOPPED;
-
- protected synchronized final void changeControllerStatus (ASDCControllerStatus newControllerStatus) {
- switch (newControllerStatus) {
-
- case BUSY:
- ++this.nbOfNotificationsOngoing;
- this.controllerStatus = newControllerStatus;
- break;
-
- case IDLE:
- if (this.nbOfNotificationsOngoing > 1) {
- --this.nbOfNotificationsOngoing;
- } else {
- this.nbOfNotificationsOngoing = 0;
- this.controllerStatus = newControllerStatus;
- }
-
- break;
- default:
- this.controllerStatus = newControllerStatus;
- break;
-
- }
- }
-
- public synchronized final ASDCControllerStatus getControllerStatus () {
- return this.controllerStatus;
- }
-
- // ***** END of Controller STATUS code
-
- protected ASDCConfiguration asdcConfig;
- private IDistributionClient distributionClient;
- private IVfResourceInstaller resourceInstaller;
-
- public ASDCController (String controllerConfigName) {
- isAsdcClientAutoManaged = true;
- this.controllerName = controllerConfigName;
- this.resourceInstaller = new VfResourceInstaller();
- }
-
- public ASDCController (String controllerConfigName, IDistributionClient asdcClient, IVfResourceInstaller resourceinstaller) {
-
- distributionClient = asdcClient;
- this.resourceInstaller = resourceinstaller;
- this.controllerName = controllerConfigName;
- }
-
- public ASDCController (String controllerConfigName,IDistributionClient asdcClient) {
- distributionClient = asdcClient;
- this.controllerName = controllerConfigName;
- this.resourceInstaller = new VfResourceInstaller();
- }
-
- /**
- * This method refresh the ASDC Controller config and restart the client.
- *
- * @return true if config has been reloaded, false otherwise
- * @throws ASDCControllerException If case of issue with the init or close called during the config reload
- * @throws ASDCParametersException If there is an issue with the parameters
- * @throws IOException In case of the key file could not be loaded properly
- */
- public boolean updateConfigIfNeeded () throws ASDCParametersException, ASDCControllerException, IOException {
- LOGGER.debug ("Checking whether ASDC config must be reloaded");
-
- try {
- if (this.asdcConfig != null && this.asdcConfig.hasASDCConfigChanged ()) {
- LOGGER.debug ("ASDC Config must be reloaded");
- this.closeASDC ();
- this.asdcConfig.refreshASDCConfig ();
- this.initASDC ();
- return true;
- } else {
- LOGGER.debug ("ASDC Config must NOT be reloaded");
- return false;
- }
- } catch (ASDCParametersException ep) {
- // Try to close it at least to make it consistent with the file specified
- // We cannot let it run with a different config file, even if it's bad.
- // This call could potentially throw a ASDCController exception if the controller is currently BUSY.
- this.closeASDC ();
-
- throw ep;
- }
- }
-
- /**
- * This method initializes the ASDC Controller and the ASDC Client.
- *
- * @throws ASDCControllerException It throws an exception if the ASDC Client cannot be instantiated or if an init
- * attempt is done when already initialized
- * @throws ASDCParametersException If there is an issue with the parameters provided
- * @throws IOException In case of issues when trying to load the key file
- */
- public void initASDC () throws ASDCControllerException, ASDCParametersException, IOException {
- String event = "Initialize the ASDC Controller";
- MsoLogger.setServiceName ("InitASDC");
- LOGGER.debug (event);
- if (this.getControllerStatus () != ASDCControllerStatus.STOPPED) {
- String endEvent = "The controller is already initialized, call the closeASDC method first";
- throw new ASDCControllerException (endEvent);
- }
-
- if (asdcConfig == null) {
- asdcConfig = new ASDCConfiguration (this.controllerName);
-
- }
- // attempt to refresh during init as MsoProperties is may be pointing to an old file
- // Be careful this is static in MsoProperties
- asdcConfig.refreshASDCConfig ();
-
- if (this.distributionClient == null) {
- distributionClient = DistributionClientFactory.createDistributionClient ();
- }
- long initStartTime = System.currentTimeMillis ();
- IDistributionClientResult result = this.distributionClient.init (asdcConfig,
- new ASDCNotificationCallBack (this));
- if (!result.getDistributionActionResult ().equals (DistributionActionResultEnum.SUCCESS)) {
- String endEvent = "ASDC distribution client init failed with reason:"
- + result.getDistributionMessageResult ();
- LOGGER.recordMetricEvent (initStartTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.UnknownError, "Initialization of the ASDC Controller failed with reason:" + result.getDistributionMessageResult (), "ASDC", "init", null);
- LOGGER.debug (endEvent);
- asdcConfig = null;
-
- this.changeControllerStatus (ASDCControllerStatus.STOPPED);
- throw new ASDCControllerException ("Initialization of the ASDC Controller failed with reason: "
- + result.getDistributionMessageResult ());
- }
- LOGGER.recordMetricEvent (initStartTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully initialize ASDC Controller", "ASDC", "init", null);
-
- long clientstartStartTime = System.currentTimeMillis ();
- result = this.distributionClient.start ();
- if (!result.getDistributionActionResult ().equals (DistributionActionResultEnum.SUCCESS)) {
- String endEvent = "ASDC distribution client start failed with reason:"
- + result.getDistributionMessageResult ();
- LOGGER.recordMetricEvent (clientstartStartTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.UnknownError, endEvent, "ASDC", "start", null);
- LOGGER.debug (endEvent);
- asdcConfig = null;
- this.changeControllerStatus (ASDCControllerStatus.STOPPED);
- throw new ASDCControllerException ("Startup of the ASDC Controller failed with reason: "
- + result.getDistributionMessageResult ());
- }
- LOGGER.recordMetricEvent (clientstartStartTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully start ASDC distribution client", "ASDC", "start", null);
-
-
- this.changeControllerStatus (ASDCControllerStatus.IDLE);
- LOGGER.info (MessageEnum.ASDC_INIT_ASDC_CLIENT_SUC, "ASDC", "changeControllerStatus");
- }
-
- /**
- * This method closes the ASDC Controller and the ASDC Client.
- *
- * @throws ASDCControllerException It throws an exception if the ASDC Client cannot be closed because
- * it's currently BUSY in processing notifications.
- */
- public void closeASDC () throws ASDCControllerException {
-
- MsoLogger.setServiceName ("CloseController");
- if (this.getControllerStatus () == ASDCControllerStatus.BUSY) {
- throw new ASDCControllerException ("Cannot close the ASDC controller as it's currently in BUSY state");
- }
- if (this.distributionClient != null) {
- this.distributionClient.stop ();
- // If auto managed we can set it to Null, ASDCController controls it.
- // In the other case the client of this class has specified it, so we can't reset it
- if (isAsdcClientAutoManaged) {
- // Next init will initialize it with a new ASDC Client
- this.distributionClient = null;
- }
-
- }
- this.changeControllerStatus (ASDCControllerStatus.STOPPED);
- }
-
- private boolean checkResourceAlreadyDeployed (VfResourceStructure resource) throws ArtifactInstallerException {
-
- if (this.resourceInstaller.isResourceAlreadyDeployed (resource)) {
- LOGGER.info (MessageEnum.ASDC_ARTIFACT_ALREADY_EXIST,
- resource.getResourceInstance().getResourceInstanceName(),
- resource.getResourceInstance().getResourceUUID(),
- resource.getResourceInstance().getResourceName(), "", "");
-
- this.sendDeployNotificationsForResource(resource,DistributionStatusEnum.ALREADY_DOWNLOADED,null);
- this.sendDeployNotificationsForResource(resource,DistributionStatusEnum.ALREADY_DEPLOYED,null);
-
- return true;
- } else {
- return false;
- }
-
- }
-
- private final static String UUID_PARAM = "(UUID:";
-
- private IDistributionClientDownloadResult downloadTheArtifact (IArtifactInfo artifact,
- String distributionId) throws ASDCDownloadException {
-
- LOGGER.debug ("Trying to download the artifact : " + artifact.getArtifactURL ()
- + UUID_PARAM
- + artifact.getArtifactUUID ()
- + ")");
- IDistributionClientDownloadResult downloadResult;
-
-
- try {
- downloadResult = distributionClient.download (artifact);
- if (null == downloadResult) {
- LOGGER.info (MessageEnum.ASDC_ARTIFACT_NULL, artifact.getArtifactUUID (), "", "");
- return downloadResult;
- }
- } catch (RuntimeException e) {
- LOGGER.debug ("Not able to download the artifact due to an exception: " + artifact.getArtifactURL ());
- this.sendASDCNotification (NotificationType.DOWNLOAD,
- artifact.getArtifactURL (),
- asdcConfig.getConsumerID (),
- distributionId,
- DistributionStatusEnum.DOWNLOAD_ERROR,
- e.getMessage (),
- System.currentTimeMillis ());
-
- throw new ASDCDownloadException ("Exception caught when downloading the artifact", e);
- }
-
- if (DistributionActionResultEnum.SUCCESS.equals(downloadResult.getDistributionActionResult ())) {
-
- LOGGER.info (MessageEnum.ASDC_ARTIFACT_DOWNLOAD_SUC,
- artifact.getArtifactURL (),
- artifact.getArtifactUUID (),
- String.valueOf (downloadResult.getArtifactPayload ().length), "", "");
-
- } else {
-
- LOGGER.error (MessageEnum.ASDC_ARTIFACT_DOWNLOAD_FAIL,
- artifact.getArtifactName (),
- artifact.getArtifactURL (),
- artifact.getArtifactUUID (),
- downloadResult.getDistributionMessageResult (), "", "", MsoLogger.ErrorCode.DataError, "ASDC artifact download fail");
-
- this.sendASDCNotification (NotificationType.DOWNLOAD,
- artifact.getArtifactURL (),
- asdcConfig.getConsumerID (),
- distributionId,
- DistributionStatusEnum.DOWNLOAD_ERROR,
- downloadResult.getDistributionMessageResult (),
- System.currentTimeMillis ());
-
- throw new ASDCDownloadException ("Artifact " + artifact.getArtifactName ()
- + " could not be downloaded from ASDC URL "
- + artifact.getArtifactURL ()
- + UUID_PARAM
- + artifact.getArtifactUUID ()
- + ")"
- + System.lineSeparator ()
- + "Error message is "
- + downloadResult.getDistributionMessageResult ()
- + System.lineSeparator ());
-
- }
-
- this.sendASDCNotification (NotificationType.DOWNLOAD,
- artifact.getArtifactURL (),
- asdcConfig.getConsumerID (),
- distributionId,
- DistributionStatusEnum.DOWNLOAD_OK,
- null,
- System.currentTimeMillis ());
- return downloadResult;
-
- }
-
-
- private void sendDeployNotificationsForResource(VfResourceStructure vfResourceStructure,DistributionStatusEnum distribStatus, String errorReason) {
-
- for (IArtifactInfo artifactInfo : vfResourceStructure.getResourceInstance().getArtifacts()) {
-
- if (DistributionStatusEnum.DEPLOY_OK.equals(distribStatus)
- // This could be NULL if the artifact is a VF module artifact, this won't be present in the MAP
- && vfResourceStructure.getArtifactsMapByUUID().get(artifactInfo.getArtifactUUID()) != null
- && vfResourceStructure.getArtifactsMapByUUID().get(artifactInfo.getArtifactUUID()).getDeployedInDb() == 0) {
- this.sendASDCNotification (NotificationType.DEPLOY,
- artifactInfo.getArtifactURL (),
- asdcConfig.getConsumerID (),
- vfResourceStructure.getNotification().getDistributionID(),
- DistributionStatusEnum.DEPLOY_ERROR,
- "The artifact has not been used by the modules defined in the resource",
- System.currentTimeMillis ());
- } else {
- this.sendASDCNotification (NotificationType.DEPLOY,
- artifactInfo.getArtifactURL (),
- asdcConfig.getConsumerID (),
- vfResourceStructure.getNotification().getDistributionID(),
- distribStatus,
- errorReason,
- System.currentTimeMillis ());
- }
- }
- }
-
- private void deployResourceStructure (VfResourceStructure resourceStructure) throws ArtifactInstallerException {
-
- LOGGER.info (MessageEnum.ASDC_START_DEPLOY_ARTIFACT, resourceStructure.getResourceInstance().getResourceInstanceName(), resourceStructure.getResourceInstance().getResourceUUID(), "ASDC", "deployResourceStructure");
- try {
- String resourceType = resourceStructure.getResourceInstance().getResourceType();
- String category = resourceStructure.getResourceInstance().getCategory();
- if(resourceType.equals("VF") && !category.equalsIgnoreCase("Allotted Resource")){
- resourceStructure.createVfModuleStructures();
- }
- resourceInstaller.installTheResource (resourceStructure);
-
- } catch (ArtifactInstallerException e) {
-
- sendDeployNotificationsForResource(resourceStructure,DistributionStatusEnum.DEPLOY_ERROR,e.getMessage());
- throw e;
- }
-
- if (resourceStructure.isDeployedSuccessfully()) {
- LOGGER.info (MessageEnum.ASDC_ARTIFACT_DEPLOY_SUC,
- resourceStructure.getResourceInstance().getResourceName(),
- resourceStructure.getResourceInstance().getResourceUUID(),
- String.valueOf (resourceStructure.getVfModuleStructure().size()), "ASDC", "deployResourceStructure");
- sendDeployNotificationsForResource(resourceStructure,DistributionStatusEnum.DEPLOY_OK ,null);
- }
-
- }
-
- private enum NotificationType {
- DOWNLOAD, DEPLOY
- }
-
- private void sendASDCNotification (NotificationType notificationType,
- String artifactURL,
- String consumerID,
- String distributionID,
- DistributionStatusEnum status,
- String errorReason,
- long timestamp) {
-
- String event = "Sending " + notificationType.name ()
- + "("
- + status.name ()
- + ")"
- + " notification to ASDC for artifact:"
- + artifactURL;
-
- if (errorReason != null) {
- event=event+"("+errorReason+")";
- }
- LOGGER.info (MessageEnum.ASDC_SEND_NOTIF_ASDC, notificationType.name (), status.name (), artifactURL, "ASDC", "sendASDCNotification");
- LOGGER.debug (event);
-
- long subStarttime = System.currentTimeMillis ();
- String action = "";
- try {
- IDistributionStatusMessage message = new DistributionStatusMessage (artifactURL,
- consumerID,
- distributionID,
- status,
- timestamp);
-
- switch (notificationType) {
- case DOWNLOAD:
- if (errorReason != null) {
- this.distributionClient.sendDownloadStatus (message, errorReason);
- } else {
- this.distributionClient.sendDownloadStatus (message);
- }
- action = "sendDownloadStatus";
- break;
- case DEPLOY:
- if (errorReason != null) {
- this.distributionClient.sendDeploymentStatus (message, errorReason);
- } else {
- this.distributionClient.sendDeploymentStatus (message);
- }
- action = "sendDeploymentdStatus";
- break;
- default:
- break;
- }
- } catch (RuntimeException e) {
- // TODO: May be a list containing the unsent notification should be
- // kept
- LOGGER.warn (MessageEnum.ASDC_SEND_NOTIF_ASDC_EXEC, "ASDC", "sendASDCNotification", MsoLogger.ErrorCode.SchemaError, "RuntimeException - sendASDCNotification", e);
- }
- LOGGER.recordMetricEvent (subStarttime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully sent notification to ASDC", "ASDC", action, null);
- }
-
- public void treatNotification (INotificationData iNotif) {
-
- int noOfArtifacts = 0;
- for (IResourceInstance resource : iNotif.getResources ()) {
- noOfArtifacts += resource.getArtifacts ().size ();
- }
- LOGGER.info (MessageEnum.ASDC_RECEIVE_CALLBACK_NOTIF,
- String.valueOf (noOfArtifacts),
- iNotif.getServiceUUID (), "ASDC", "treatNotification");
-
- try {
- LOGGER.debug(ASDCNotificationLogging.dumpASDCNotification(iNotif));
- LOGGER.info(MessageEnum.ASDC_RECEIVE_SERVICE_NOTIF, iNotif.getServiceUUID(), "ASDC", "treatNotification");
- this.changeControllerStatus(ASDCControllerStatus.BUSY);
- // Process only the Resource artifacts in MSO
- for (IResourceInstance resource : iNotif.getResources()) {
-
- // We process only VNF(VF) and Network(VL) resources on MSO Side
- // We process only VNF resource on MSO Side
- if ("VF".equals(resource.getResourceType()) || "VL".equals(resource.getResourceType())) {
- this.processResourceNotification(iNotif,resource);
- }
- }
-
-
-
- } catch (RuntimeException e) {
- LOGGER.error (MessageEnum.ASDC_GENERAL_EXCEPTION_ARG,
- "Unexpected exception caught during the notification processing", "ASDC", "treatNotification", MsoLogger.ErrorCode.SchemaError, "RuntimeException in treatNotification",
- e);
- } finally {
- this.changeControllerStatus (ASDCControllerStatus.IDLE);
- }
- }
-
-
- private void processResourceNotification (INotificationData iNotif,IResourceInstance resource) {
- // For each artifact, create a structure describing the VFModule in a ordered flat level
- VfResourceStructure resourceStructure = new VfResourceStructure(iNotif,resource);
-
- try {
-
- if (!this.checkResourceAlreadyDeployed(resourceStructure)) {
- for (IArtifactInfo artifact : resource.getArtifacts()) {
-
- IDistributionClientDownloadResult resultArtifact = this.downloadTheArtifact(artifact,
- iNotif.getDistributionID());
-
- if (resultArtifact != null) {
- if (ASDCConfiguration.VF_MODULES_METADATA.equals(artifact.getArtifactType())) {
- LOGGER.debug("VF_MODULE_ARTIFACT: "+new String(resultArtifact.getArtifactPayload(),"UTF-8"));
- LOGGER.debug(ASDCNotificationLogging.dumpVfModuleMetaDataList(resourceStructure.decodeVfModuleArtifact(resultArtifact.getArtifactPayload())));
- }
- resourceStructure.addArtifactToStructure(distributionClient,artifact, resultArtifact);
-
- }
-
- }
-
- this.deployResourceStructure(resourceStructure);
-
- }
- } catch (ArtifactInstallerException | ASDCDownloadException | UnsupportedEncodingException e) {
- LOGGER.error(MessageEnum.ASDC_GENERAL_EXCEPTION_ARG,
- "Exception caught during Installation of artifact", "ASDC", "processResourceNotification", MsoLogger.ErrorCode.BusinessProcesssError, "Exception in processResourceNotification", e);
- }
- }
-
- private static final String UNKNOWN="Unknown";
-
- /**
- * @return the address of the ASDC we are connected to.
- */
- public String getAddress () {
- if (asdcConfig != null) {
- return asdcConfig.getAsdcAddress ();
- }
- return UNKNOWN;
- }
-
- /**
- * @return the environment name of the ASDC we are connected to.
- */
- public String getEnvironment () {
- if (asdcConfig != null) {
- return asdcConfig.getEnvironmentName ();
- }
- return UNKNOWN;
- }
-
-}
+/*-\r
+ * ============LICENSE_START=======================================================\r
+ * OPENECOMP - MSO\r
+ * ================================================================================\r
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
+ * ================================================================================\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ * ============LICENSE_END=========================================================\r
+ */\r
+\r
+package org.openecomp.mso.asdc.client;\r
+\r
+\r
+import java.io.IOException;\r
+import java.io.UnsupportedEncodingException;\r
+import org.openecomp.sdc.api.IDistributionClient;\r
+import org.openecomp.sdc.api.consumer.IDistributionStatusMessage;\r
+import org.openecomp.sdc.api.consumer.INotificationCallback;\r
+import org.openecomp.sdc.api.notification.IArtifactInfo;\r
+import org.openecomp.sdc.api.notification.INotificationData;\r
+import org.openecomp.sdc.api.notification.IResourceInstance;\r
+import org.openecomp.sdc.api.results.IDistributionClientDownloadResult;\r
+import org.openecomp.sdc.api.results.IDistributionClientResult;\r
+import org.openecomp.sdc.impl.DistributionClientFactory;\r
+import org.openecomp.sdc.utils.DistributionActionResultEnum;\r
+import org.openecomp.sdc.utils.DistributionStatusEnum;\r
+import org.openecomp.mso.asdc.client.exceptions.ASDCControllerException;\r
+import org.openecomp.mso.asdc.client.exceptions.ASDCDownloadException;\r
+import org.openecomp.mso.asdc.client.exceptions.ASDCParametersException;\r
+import org.openecomp.mso.asdc.client.exceptions.ArtifactInstallerException;\r
+import org.openecomp.mso.asdc.installer.IVfResourceInstaller;\r
+import org.openecomp.mso.asdc.installer.VfResourceStructure;\r
+import org.openecomp.mso.asdc.installer.heat.VfResourceInstaller;\r
+import org.openecomp.mso.asdc.util.ASDCNotificationLogging;\r
+import org.openecomp.mso.logger.MessageEnum;\r
+import org.openecomp.mso.logger.MsoAlarmLogger;\r
+import org.openecomp.mso.logger.MsoLogger;\r
+import org.openecomp.mso.utils.UUIDChecker;\r
+\r
+public class ASDCController {\r
+\r
+ protected static final MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.ASDC);\r
+\r
+ protected static MsoAlarmLogger alarmLogger = new MsoAlarmLogger ();\r
+\r
+ protected boolean isAsdcClientAutoManaged = false;\r
+\r
+ protected String controllerName;\r
+\r
+ /**\r
+ * Inner class for Notification callback\r
+ *\r
+ *\r
+ */\r
+ private final class ASDCNotificationCallBack implements INotificationCallback {\r
+\r
+ private ASDCController asdcController;\r
+\r
+ ASDCNotificationCallBack (ASDCController controller) {\r
+ asdcController = controller;\r
+ }\r
+\r
+ /**\r
+ * This method can be called multiple times at the same moment.\r
+ * The controller must be thread safe !\r
+ */\r
+ @Override\r
+ public void activateCallback (INotificationData iNotif) {\r
+ long startTime = System.currentTimeMillis ();\r
+ UUIDChecker.generateUUID (LOGGER);\r
+ MsoLogger.setServiceName ("NotificationHandler");\r
+ MsoLogger.setLogContext (iNotif.getDistributionID (), iNotif.getServiceUUID ());\r
+ String event = "Receive a callback notification in ASDC, nb of resources: " + iNotif.getResources ().size ();\r
+ LOGGER.debug(event);\r
+ asdcController.treatNotification (iNotif);\r
+ LOGGER.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Completed the treatment of the notification");\r
+ }\r
+ }\r
+\r
+ // ***** Controller STATUS code\r
+\r
+ protected int nbOfNotificationsOngoing = 0;\r
+\r
+ public int getNbOfNotificationsOngoing () {\r
+ return nbOfNotificationsOngoing;\r
+ }\r
+\r
+ private ASDCControllerStatus controllerStatus = ASDCControllerStatus.STOPPED;\r
+\r
+ protected synchronized final void changeControllerStatus (ASDCControllerStatus newControllerStatus) {\r
+ switch (newControllerStatus) {\r
+\r
+ case BUSY:\r
+ ++this.nbOfNotificationsOngoing;\r
+ this.controllerStatus = newControllerStatus;\r
+ break;\r
+\r
+ case IDLE:\r
+ if (this.nbOfNotificationsOngoing > 1) {\r
+ --this.nbOfNotificationsOngoing;\r
+ } else {\r
+ this.nbOfNotificationsOngoing = 0;\r
+ this.controllerStatus = newControllerStatus;\r
+ }\r
+\r
+ break;\r
+ default:\r
+ this.controllerStatus = newControllerStatus;\r
+ break;\r
+\r
+ }\r
+ }\r
+\r
+ public synchronized final ASDCControllerStatus getControllerStatus () {\r
+ return this.controllerStatus;\r
+ }\r
+\r
+ // ***** END of Controller STATUS code\r
+\r
+ protected ASDCConfiguration asdcConfig;\r
+ private IDistributionClient distributionClient;\r
+ private IVfResourceInstaller resourceInstaller;\r
+\r
+ public ASDCController (String controllerConfigName) {\r
+ isAsdcClientAutoManaged = true;\r
+ this.controllerName = controllerConfigName;\r
+ this.resourceInstaller = new VfResourceInstaller();\r
+ }\r
+\r
+ public ASDCController (String controllerConfigName, IDistributionClient asdcClient, IVfResourceInstaller resourceinstaller) {\r
+\r
+ distributionClient = asdcClient;\r
+ this.resourceInstaller = resourceinstaller;\r
+ this.controllerName = controllerConfigName;\r
+ }\r
+\r
+ public ASDCController (String controllerConfigName,IDistributionClient asdcClient) {\r
+ distributionClient = asdcClient;\r
+ this.controllerName = controllerConfigName;\r
+ this.resourceInstaller = new VfResourceInstaller();\r
+ }\r
+\r
+ /**\r
+ * This method refresh the ASDC Controller config and restart the client.\r
+ *\r
+ * @return true if config has been reloaded, false otherwise\r
+ * @throws ASDCControllerException If case of issue with the init or close called during the config reload\r
+ * @throws ASDCParametersException If there is an issue with the parameters\r
+ * @throws IOException In case of the key file could not be loaded properly\r
+ */\r
+ public boolean updateConfigIfNeeded () throws ASDCParametersException, ASDCControllerException, IOException {\r
+ LOGGER.debug ("Checking whether ASDC config must be reloaded");\r
+\r
+ try {\r
+ if (this.asdcConfig != null && this.asdcConfig.hasASDCConfigChanged ()) {\r
+ LOGGER.debug ("ASDC Config must be reloaded");\r
+ this.closeASDC ();\r
+ this.asdcConfig.refreshASDCConfig ();\r
+ this.initASDC ();\r
+ return true;\r
+ } else {\r
+ LOGGER.debug ("ASDC Config must NOT be reloaded");\r
+ return false;\r
+ }\r
+ } catch (ASDCParametersException ep) {\r
+ // Try to close it at least to make it consistent with the file specified\r
+ // We cannot let it run with a different config file, even if it's bad.\r
+ // This call could potentially throw a ASDCController exception if the controller is currently BUSY.\r
+ this.closeASDC ();\r
+\r
+ throw ep;\r
+ }\r
+ }\r
+\r
+ /**\r
+ * This method initializes the ASDC Controller and the ASDC Client.\r
+ *\r
+ * @throws ASDCControllerException It throws an exception if the ASDC Client cannot be instantiated or if an init\r
+ * attempt is done when already initialized\r
+ * @throws ASDCParametersException If there is an issue with the parameters provided\r
+ * @throws IOException In case of issues when trying to load the key file\r
+ */\r
+ public void initASDC () throws ASDCControllerException, ASDCParametersException, IOException {\r
+ String event = "Initialize the ASDC Controller";\r
+ MsoLogger.setServiceName ("InitASDC");\r
+ LOGGER.debug (event);\r
+ if (this.getControllerStatus () != ASDCControllerStatus.STOPPED) {\r
+ String endEvent = "The controller is already initialized, call the closeASDC method first";\r
+ throw new ASDCControllerException (endEvent);\r
+ }\r
+\r
+ if (asdcConfig == null) {\r
+ asdcConfig = new ASDCConfiguration (this.controllerName);\r
+\r
+ }\r
+ // attempt to refresh during init as MsoProperties is may be pointing to an old file\r
+ // Be careful this is static in MsoProperties\r
+ asdcConfig.refreshASDCConfig ();\r
+\r
+ if (this.distributionClient == null) {\r
+ distributionClient = DistributionClientFactory.createDistributionClient ();\r
+ }\r
+ long initStartTime = System.currentTimeMillis ();\r
+ IDistributionClientResult result = this.distributionClient.init (asdcConfig,\r
+ new ASDCNotificationCallBack (this));\r
+ if (!result.getDistributionActionResult ().equals (DistributionActionResultEnum.SUCCESS)) {\r
+ String endEvent = "ASDC distribution client init failed with reason:"\r
+ + result.getDistributionMessageResult ();\r
+ LOGGER.recordMetricEvent (initStartTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.UnknownError, "Initialization of the ASDC Controller failed with reason:" + result.getDistributionMessageResult (), "ASDC", "init", null);\r
+ LOGGER.debug (endEvent);\r
+ asdcConfig = null;\r
+\r
+ this.changeControllerStatus (ASDCControllerStatus.STOPPED);\r
+ throw new ASDCControllerException ("Initialization of the ASDC Controller failed with reason: "\r
+ + result.getDistributionMessageResult ());\r
+ }\r
+ LOGGER.recordMetricEvent (initStartTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully initialize ASDC Controller", "ASDC", "init", null);\r
+\r
+ long clientstartStartTime = System.currentTimeMillis ();\r
+ result = this.distributionClient.start ();\r
+ if (!result.getDistributionActionResult ().equals (DistributionActionResultEnum.SUCCESS)) {\r
+ String endEvent = "ASDC distribution client start failed with reason:"\r
+ + result.getDistributionMessageResult ();\r
+ LOGGER.recordMetricEvent (clientstartStartTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.UnknownError, endEvent, "ASDC", "start", null);\r
+ LOGGER.debug (endEvent);\r
+ asdcConfig = null;\r
+ this.changeControllerStatus (ASDCControllerStatus.STOPPED);\r
+ throw new ASDCControllerException ("Startup of the ASDC Controller failed with reason: "\r
+ + result.getDistributionMessageResult ());\r
+ }\r
+ LOGGER.recordMetricEvent (clientstartStartTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully start ASDC distribution client", "ASDC", "start", null);\r
+\r
+\r
+ this.changeControllerStatus (ASDCControllerStatus.IDLE);\r
+ LOGGER.info (MessageEnum.ASDC_INIT_ASDC_CLIENT_SUC, "ASDC", "changeControllerStatus");\r
+ }\r
+\r
+ /**\r
+ * This method closes the ASDC Controller and the ASDC Client.\r
+ *\r
+ * @throws ASDCControllerException It throws an exception if the ASDC Client cannot be closed because\r
+ * it's currently BUSY in processing notifications.\r
+ */\r
+ public void closeASDC () throws ASDCControllerException {\r
+\r
+ MsoLogger.setServiceName ("CloseController");\r
+ if (this.getControllerStatus () == ASDCControllerStatus.BUSY) {\r
+ throw new ASDCControllerException ("Cannot close the ASDC controller as it's currently in BUSY state");\r
+ }\r
+ if (this.distributionClient != null) {\r
+ this.distributionClient.stop ();\r
+ // If auto managed we can set it to Null, ASDCController controls it.\r
+ // In the other case the client of this class has specified it, so we can't reset it\r
+ if (isAsdcClientAutoManaged) {\r
+ // Next init will initialize it with a new ASDC Client\r
+ this.distributionClient = null;\r
+ }\r
+\r
+ }\r
+ this.changeControllerStatus (ASDCControllerStatus.STOPPED);\r
+ }\r
+\r
+ private boolean checkResourceAlreadyDeployed (VfResourceStructure resource) throws ArtifactInstallerException {\r
+\r
+ if (this.resourceInstaller.isResourceAlreadyDeployed (resource)) {\r
+ LOGGER.info (MessageEnum.ASDC_ARTIFACT_ALREADY_EXIST,\r
+ resource.getResourceInstance().getResourceInstanceName(),\r
+ resource.getResourceInstance().getResourceUUID(),\r
+ resource.getResourceInstance().getResourceName(), "", "");\r
+\r
+ this.sendDeployNotificationsForResource(resource,DistributionStatusEnum.ALREADY_DOWNLOADED,null);\r
+ this.sendDeployNotificationsForResource(resource,DistributionStatusEnum.ALREADY_DEPLOYED,null);\r
+\r
+ return true;\r
+ } else {\r
+ return false;\r
+ }\r
+\r
+ }\r
+\r
+ private final static String UUID_PARAM = "(UUID:";\r
+\r
+ private IDistributionClientDownloadResult downloadTheArtifact (IArtifactInfo artifact,\r
+ String distributionId) throws ASDCDownloadException {\r
+\r
+ LOGGER.debug ("Trying to download the artifact : " + artifact.getArtifactURL ()\r
+ + UUID_PARAM\r
+ + artifact.getArtifactUUID ()\r
+ + ")");\r
+ IDistributionClientDownloadResult downloadResult;\r
+\r
+\r
+ try {\r
+ downloadResult = distributionClient.download (artifact);\r
+ if (null == downloadResult) {\r
+ LOGGER.info (MessageEnum.ASDC_ARTIFACT_NULL, artifact.getArtifactUUID (), "", "");\r
+ return downloadResult;\r
+ }\r
+ } catch (RuntimeException e) {\r
+ LOGGER.debug ("Not able to download the artifact due to an exception: " + artifact.getArtifactURL ());\r
+ this.sendASDCNotification (NotificationType.DOWNLOAD,\r
+ artifact.getArtifactURL (),\r
+ asdcConfig.getConsumerID (),\r
+ distributionId,\r
+ DistributionStatusEnum.DOWNLOAD_ERROR,\r
+ e.getMessage (),\r
+ System.currentTimeMillis ());\r
+\r
+ throw new ASDCDownloadException ("Exception caught when downloading the artifact", e);\r
+ }\r
+\r
+ if (DistributionActionResultEnum.SUCCESS.equals(downloadResult.getDistributionActionResult ())) {\r
+\r
+ LOGGER.info (MessageEnum.ASDC_ARTIFACT_DOWNLOAD_SUC,\r
+ artifact.getArtifactURL (),\r
+ artifact.getArtifactUUID (),\r
+ String.valueOf (downloadResult.getArtifactPayload ().length), "", "");\r
+\r
+ } else {\r
+\r
+ LOGGER.error (MessageEnum.ASDC_ARTIFACT_DOWNLOAD_FAIL,\r
+ artifact.getArtifactName (),\r
+ artifact.getArtifactURL (),\r
+ artifact.getArtifactUUID (),\r
+ downloadResult.getDistributionMessageResult (), "", "", MsoLogger.ErrorCode.DataError, "ASDC artifact download fail");\r
+\r
+ this.sendASDCNotification (NotificationType.DOWNLOAD,\r
+ artifact.getArtifactURL (),\r
+ asdcConfig.getConsumerID (),\r
+ distributionId,\r
+ DistributionStatusEnum.DOWNLOAD_ERROR,\r
+ downloadResult.getDistributionMessageResult (),\r
+ System.currentTimeMillis ());\r
+\r
+ throw new ASDCDownloadException ("Artifact " + artifact.getArtifactName ()\r
+ + " could not be downloaded from ASDC URL "\r
+ + artifact.getArtifactURL ()\r
+ + UUID_PARAM\r
+ + artifact.getArtifactUUID ()\r
+ + ")"\r
+ + System.lineSeparator ()\r
+ + "Error message is "\r
+ + downloadResult.getDistributionMessageResult ()\r
+ + System.lineSeparator ());\r
+\r
+ }\r
+\r
+ this.sendASDCNotification (NotificationType.DOWNLOAD,\r
+ artifact.getArtifactURL (),\r
+ asdcConfig.getConsumerID (),\r
+ distributionId,\r
+ DistributionStatusEnum.DOWNLOAD_OK,\r
+ null,\r
+ System.currentTimeMillis ());\r
+ return downloadResult;\r
+\r
+ }\r
+\r
+\r
+ private void sendDeployNotificationsForResource(VfResourceStructure vfResourceStructure,DistributionStatusEnum distribStatus, String errorReason) {\r
+\r
+ for (IArtifactInfo artifactInfo : vfResourceStructure.getResourceInstance().getArtifacts()) {\r
+\r
+ if (DistributionStatusEnum.DEPLOY_OK.equals(distribStatus)\r
+ // This could be NULL if the artifact is a VF module artifact, this won't be present in the MAP\r
+ && vfResourceStructure.getArtifactsMapByUUID().get(artifactInfo.getArtifactUUID()) != null\r
+ && vfResourceStructure.getArtifactsMapByUUID().get(artifactInfo.getArtifactUUID()).getDeployedInDb() == 0) {\r
+ this.sendASDCNotification (NotificationType.DEPLOY,\r
+ artifactInfo.getArtifactURL (),\r
+ asdcConfig.getConsumerID (),\r
+ vfResourceStructure.getNotification().getDistributionID(),\r
+ DistributionStatusEnum.DEPLOY_ERROR,\r
+ "The artifact has not been used by the modules defined in the resource",\r
+ System.currentTimeMillis ());\r
+ } else {\r
+ this.sendASDCNotification (NotificationType.DEPLOY,\r
+ artifactInfo.getArtifactURL (),\r
+ asdcConfig.getConsumerID (),\r
+ vfResourceStructure.getNotification().getDistributionID(),\r
+ distribStatus,\r
+ errorReason,\r
+ System.currentTimeMillis ());\r
+ }\r
+ }\r
+ }\r
+\r
+ private void deployResourceStructure (VfResourceStructure resourceStructure) throws ArtifactInstallerException {\r
+\r
+ LOGGER.info (MessageEnum.ASDC_START_DEPLOY_ARTIFACT, resourceStructure.getResourceInstance().getResourceInstanceName(), resourceStructure.getResourceInstance().getResourceUUID(), "ASDC", "deployResourceStructure");\r
+ try {\r
+ String resourceType = resourceStructure.getResourceInstance().getResourceType();\r
+ String category = resourceStructure.getResourceInstance().getCategory();\r
+ if(resourceType.equals("VF") && !category.equalsIgnoreCase("Allotted Resource")){\r
+ resourceStructure.createVfModuleStructures();\r
+ }\r
+ resourceInstaller.installTheResource (resourceStructure);\r
+\r
+ } catch (ArtifactInstallerException e) {\r
+\r
+ sendDeployNotificationsForResource(resourceStructure,DistributionStatusEnum.DEPLOY_ERROR,e.getMessage());\r
+ throw e;\r
+ }\r
+\r
+ if (resourceStructure.isDeployedSuccessfully()) {\r
+ LOGGER.info (MessageEnum.ASDC_ARTIFACT_DEPLOY_SUC,\r
+ resourceStructure.getResourceInstance().getResourceName(),\r
+ resourceStructure.getResourceInstance().getResourceUUID(),\r
+ String.valueOf (resourceStructure.getVfModuleStructure().size()), "ASDC", "deployResourceStructure");\r
+ sendDeployNotificationsForResource(resourceStructure,DistributionStatusEnum.DEPLOY_OK ,null);\r
+ }\r
+\r
+ }\r
+\r
+ private enum NotificationType {\r
+ DOWNLOAD, DEPLOY\r
+ }\r
+\r
+ private void sendASDCNotification (NotificationType notificationType,\r
+ String artifactURL,\r
+ String consumerID,\r
+ String distributionID,\r
+ DistributionStatusEnum status,\r
+ String errorReason,\r
+ long timestamp) {\r
+\r
+ String event = "Sending " + notificationType.name ()\r
+ + "("\r
+ + status.name ()\r
+ + ")"\r
+ + " notification to ASDC for artifact:"\r
+ + artifactURL;\r
+\r
+ if (errorReason != null) {\r
+ event=event+"("+errorReason+")";\r
+ }\r
+ LOGGER.info (MessageEnum.ASDC_SEND_NOTIF_ASDC, notificationType.name (), status.name (), artifactURL, "ASDC", "sendASDCNotification");\r
+ LOGGER.debug (event);\r
+\r
+ long subStarttime = System.currentTimeMillis ();\r
+ String action = "";\r
+ try {\r
+ IDistributionStatusMessage message = new DistributionStatusMessage (artifactURL,\r
+ consumerID,\r
+ distributionID,\r
+ status,\r
+ timestamp);\r
+\r
+ switch (notificationType) {\r
+ case DOWNLOAD:\r
+ if (errorReason != null) {\r
+ this.distributionClient.sendDownloadStatus (message, errorReason);\r
+ } else {\r
+ this.distributionClient.sendDownloadStatus (message);\r
+ }\r
+ action = "sendDownloadStatus";\r
+ break;\r
+ case DEPLOY:\r
+ if (errorReason != null) {\r
+ this.distributionClient.sendDeploymentStatus (message, errorReason);\r
+ } else {\r
+ this.distributionClient.sendDeploymentStatus (message);\r
+ }\r
+ action = "sendDeploymentdStatus";\r
+ break;\r
+ default:\r
+ break;\r
+ }\r
+ } catch (RuntimeException e) {\r
+ // TODO: May be a list containing the unsent notification should be\r
+ // kept\r
+ LOGGER.warn (MessageEnum.ASDC_SEND_NOTIF_ASDC_EXEC, "ASDC", "sendASDCNotification", MsoLogger.ErrorCode.SchemaError, "RuntimeException - sendASDCNotification", e);\r
+ }\r
+ LOGGER.recordMetricEvent (subStarttime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully sent notification to ASDC", "ASDC", action, null);\r
+ }\r
+\r
+ public void treatNotification (INotificationData iNotif) {\r
+\r
+ int noOfArtifacts = 0;\r
+ for (IResourceInstance resource : iNotif.getResources ()) {\r
+ noOfArtifacts += resource.getArtifacts ().size ();\r
+ }\r
+ LOGGER.info (MessageEnum.ASDC_RECEIVE_CALLBACK_NOTIF,\r
+ String.valueOf (noOfArtifacts),\r
+ iNotif.getServiceUUID (), "ASDC", "treatNotification");\r
+\r
+ try {\r
+ LOGGER.debug(ASDCNotificationLogging.dumpASDCNotification(iNotif));\r
+ LOGGER.info(MessageEnum.ASDC_RECEIVE_SERVICE_NOTIF, iNotif.getServiceUUID(), "ASDC", "treatNotification");\r
+ this.changeControllerStatus(ASDCControllerStatus.BUSY);\r
+ // Process only the Resource artifacts in MSO\r
+ for (IResourceInstance resource : iNotif.getResources()) {\r
+\r
+ // We process only VNF(VF) and Network(VL) resources on MSO Side\r
+ // We process only VNF resource on MSO Side\r
+ if ("VF".equals(resource.getResourceType()) || "VL".equals(resource.getResourceType())) {\r
+ this.processResourceNotification(iNotif,resource);\r
+ }\r
+ }\r
+\r
+\r
+\r
+ } catch (RuntimeException e) {\r
+ LOGGER.error (MessageEnum.ASDC_GENERAL_EXCEPTION_ARG,\r
+ "Unexpected exception caught during the notification processing", "ASDC", "treatNotification", MsoLogger.ErrorCode.SchemaError, "RuntimeException in treatNotification",\r
+ e);\r
+ } finally {\r
+ this.changeControllerStatus (ASDCControllerStatus.IDLE);\r
+ }\r
+ }\r
+\r
+\r
+ private void processResourceNotification (INotificationData iNotif,IResourceInstance resource) {\r
+ // For each artifact, create a structure describing the VFModule in a ordered flat level\r
+ VfResourceStructure resourceStructure = new VfResourceStructure(iNotif,resource);\r
+\r
+ try {\r
+\r
+ if (!this.checkResourceAlreadyDeployed(resourceStructure)) {\r
+ for (IArtifactInfo artifact : resource.getArtifacts()) {\r
+\r
+ IDistributionClientDownloadResult resultArtifact = this.downloadTheArtifact(artifact,\r
+ iNotif.getDistributionID());\r
+\r
+ if (resultArtifact != null) {\r
+ if (ASDCConfiguration.VF_MODULES_METADATA.equals(artifact.getArtifactType())) {\r
+ LOGGER.debug("VF_MODULE_ARTIFACT: "+new String(resultArtifact.getArtifactPayload(),"UTF-8"));\r
+ LOGGER.debug(ASDCNotificationLogging.dumpVfModuleMetaDataList(resourceStructure.decodeVfModuleArtifact(resultArtifact.getArtifactPayload())));\r
+ }\r
+ resourceStructure.addArtifactToStructure(distributionClient,artifact, resultArtifact);\r
+\r
+ }\r
+\r
+ }\r
+\r
+ this.deployResourceStructure(resourceStructure);\r
+\r
+ }\r
+ } catch (ArtifactInstallerException | ASDCDownloadException | UnsupportedEncodingException e) {\r
+ LOGGER.error(MessageEnum.ASDC_GENERAL_EXCEPTION_ARG,\r
+ "Exception caught during Installation of artifact", "ASDC", "processResourceNotification", MsoLogger.ErrorCode.BusinessProcesssError, "Exception in processResourceNotification", e);\r
+ }\r
+ }\r
+\r
+ private static final String UNKNOWN="Unknown";\r
+\r
+ /**\r
+ * @return the address of the ASDC we are connected to.\r
+ */\r
+ public String getAddress () {\r
+ if (asdcConfig != null) {\r
+ return asdcConfig.getAsdcAddress ();\r
+ }\r
+ return UNKNOWN;\r
+ }\r
+\r
+ /**\r
+ * @return the environment name of the ASDC we are connected to.\r
+ */\r
+ public String getEnvironment () {\r
+ if (asdcConfig != null) {\r
+ return asdcConfig.getEnvironmentName ();\r
+ }\r
+ return UNKNOWN;\r
+ }\r
+\r
+}\r
Code Review / so.git / blobdiff