asdc-controller/src/main/java/org/onap/so/asdc/installer/bpmn/WorkflowResource.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Modifications Copyright (c) 2019 Samsung
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.so.asdc.installer.bpmn;
  24
  25 import java.util.ArrayList;
  26 import java.util.List;
  27 import java.util.Map;
  28 import java.util.regex.Matcher;
  29 import java.util.regex.Pattern;
  30 import org.apache.http.HttpResponse;
  31 import org.onap.sdc.api.notification.IArtifactInfo;
  32 import org.onap.so.asdc.installer.VfResourceStructure;
  33 import org.onap.so.asdc.installer.WorkflowArtifact;
  34 import org.onap.so.db.catalog.beans.ActivitySpec;
  35 import org.onap.so.db.catalog.beans.VnfResourceWorkflow;
  36 import org.onap.so.db.catalog.beans.Workflow;
  37 import org.onap.so.db.catalog.beans.WorkflowActivitySpecSequence;
  38 import org.onap.so.db.catalog.data.repository.ActivitySpecRepository;
  39 import org.onap.so.db.catalog.data.repository.WorkflowRepository;
  40 import org.onap.so.logger.ErrorCode;
  41 import org.onap.so.logger.MessageEnum;
  42 import org.slf4j.Logger;
  43 import org.slf4j.LoggerFactory;
  44 import org.springframework.beans.factory.annotation.Autowired;
  45 import org.springframework.stereotype.Component;
  46
  47 @Component
  48 public class WorkflowResource {
  49     protected static final Logger logger = LoggerFactory.getLogger(WorkflowResource.class);
  50
  51     private static final String pattern = ".*\\\"activity:(.*)\\\" .*";
  52     private static final String TARGET_RESOURCE_VNF = "vnf";
  53     private static final String SOURCE_SDC = "sdc";
  54     private static final String BPMN_SUFFIX = ".bpmn";
  55
  56     @Autowired
  57     protected WorkflowRepository workflowRepo;
  58
  59     @Autowired
  60     protected ActivitySpecRepository activityRepo;
  61
  62     @Autowired
  63     private BpmnInstaller bpmnInstaller;
  64
  65     public void processWorkflows(VfResourceStructure vfResourceStructure) throws Exception {
  66         Map<String, WorkflowArtifact> artifactsMapByUUID = vfResourceStructure.getWorkflowArtifactsMapByUUID();
  67         String vfResourceModelUuid = vfResourceStructure.getResourceInstance().getResourceUUID();
  68         for (String uuid : artifactsMapByUUID.keySet()) {
  69             WorkflowArtifact artifactToInstall = artifactsMapByUUID.get(uuid);
  70             if (isLatestVersionAvailable(artifactsMapByUUID, artifactToInstall)) {
  71                 logger.debug("Installing the BPMN: " + artifactToInstall.getArtifactInfo().getArtifactName());
  72                 deployWorkflowResourceToCamunda(artifactToInstall);
  73                 installWorkflowResource(artifactToInstall, vfResourceModelUuid);
  74             } else {
  75                 logger.debug("Skipping installing - not the latest version: "
  76                         + artifactToInstall.getArtifactInfo().getArtifactName());
  77             }
  78         }
  79     }
  80
  81     protected void deployWorkflowResourceToCamunda(WorkflowArtifact artifact) throws Exception {
  82         String bpmnName = artifact.getArtifactInfo().getArtifactName();
  83         String version = artifact.getArtifactInfo().getArtifactVersion();
  84         logger.debug("BPMN Name: " + bpmnName);
  85         try {
  86             HttpResponse response = bpmnInstaller.sendDeploymentRequest(bpmnName, version);
  87             logger.debug("Response status line: {}", response.getStatusLine());
  88             logger.debug("Response entity: {}", response.getEntity().toString());
  89             if (response.getStatusLine().getStatusCode() != 200) {
  90                 logger.debug("Failed deploying BPMN {}", bpmnName);
  91                 logger.error("{} {} {} {} {} {}", MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL.toString(), bpmnName,
  92                         bpmnName, Integer.toString(response.getStatusLine().getStatusCode()),
  93                         ErrorCode.DataError.getValue(), "ASDC BPMN deploy failed");
  94                 throw (new Exception("Error from Camunda on deploying the BPMN: " + bpmnName));
  95             } else {
  96                 logger.debug("Successfully deployed to Camunda: {}", bpmnName);
  97             }
  98         } catch (Exception e) {
  99             logger.debug("Exception :", e);
 100             logger.error("{} {} {} {} {}", MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL.toString(), bpmnName,
 101                     e.getMessage(), ErrorCode.DataError.getValue(), "ASDC BPMN deploy failed");
 102             throw e;
 103         }
 104     }
 105
 106     protected void installWorkflowResource(WorkflowArtifact artifact, String vfResourceModelUuid) throws Exception {
 107         IArtifactInfo artifactInfo = artifact.getArtifactInfo();
 108
 109         Workflow workflow = new Workflow();
 110
 111         workflow.setArtifactChecksum(artifactInfo.getArtifactChecksum());
 112         workflow.setArtifactName(artifactInfo.getArtifactName());
 113         workflow.setArtifactUUID(artifactInfo.getArtifactUUID());
 114         workflow.setBody(artifact.getResult());
 115         workflow.setDescription(artifactInfo.getArtifactDescription());
 116         workflow.setName(getWorkflowNameFromArtifactName(artifactInfo.getArtifactName()));
 117         workflow.setResourceTarget(TARGET_RESOURCE_VNF);
 118         workflow.setSource(SOURCE_SDC);
 119         workflow.setTimeoutMinutes(artifactInfo.getArtifactTimeout());
 120         workflow.setOperationName(getWorkflowNameFromArtifactName(artifactInfo.getArtifactName()));
 121         workflow.setVersion(getWorkflowVersionFromArtifactName(artifactInfo.getArtifactName()));
 122
 123         VnfResourceWorkflow vnfResourceWorkflow = new VnfResourceWorkflow();
 124         vnfResourceWorkflow.setVnfResourceModelUUID(vfResourceModelUuid);
 125         List<VnfResourceWorkflow> vnfResourceWorkflows = new ArrayList<VnfResourceWorkflow>();
 126         vnfResourceWorkflows.add(vnfResourceWorkflow);
 127
 128         workflow.setVnfResourceWorkflow(vnfResourceWorkflows);
 129
 130         List<String> activityNames = getActivityNameList(artifact.getResult());
 131         List<WorkflowActivitySpecSequence> wfss = getWorkflowActivitySpecSequence(activityNames);
 132         workflow.setWorkflowActivitySpecSequence(wfss);
 133
 134         workflowRepo.save(workflow);
 135
 136     }
 137
 138     protected boolean isLatestVersionAvailable(Map<String, WorkflowArtifact> artifactsMapByUUID,
 139             WorkflowArtifact artifact) {
 140         String workflowName = getWorkflowNameFromArtifactName(artifact.getArtifactInfo().getArtifactName());
 141         Double workflowVersion = getWorkflowVersionFromArtifactName(artifact.getArtifactInfo().getArtifactName());
 142         if (workflowVersion == null) {
 143             workflowVersion = 0.0;
 144         }
 145         for (WorkflowArtifact artifactInMap : artifactsMapByUUID.values()) {
 146             Double versionInMap = getWorkflowVersionFromArtifactName(artifactInMap.getArtifactInfo().getArtifactName());
 147             if (versionInMap == null) {
 148                 versionInMap = 0.0;
 149             }
 150             if (workflowName.equals(getWorkflowNameFromArtifactName(artifactInMap.getArtifactInfo().getArtifactName()))
 151                     && Double.compare(workflowVersion, versionInMap) < 0) {
 152                 return false;
 153             }
 154         }
 155         return true;
 156     }
 157
 158     protected List<String> getActivityNameList(String bpmnContent) {
 159         List<String> activityNameList = new ArrayList<String>();
 160
 161         Pattern p = Pattern.compile(pattern);
 162         Matcher m = p.matcher(bpmnContent);
 163         while (m.find()) {
 164             activityNameList.add(m.group(1));
 165         }
 166         return activityNameList;
 167     }
 168
 169     protected List<WorkflowActivitySpecSequence> getWorkflowActivitySpecSequence(List<String> activityNames)
 170             throws Exception {
 171         if (activityNames == null || activityNames.size() == 0) {
 172             return null;
 173         }
 174         List<WorkflowActivitySpecSequence> workflowActivitySpecs = new ArrayList<WorkflowActivitySpecSequence>();
 175         for (String activityName : activityNames) {
 176             ActivitySpec activitySpec = activityRepo.findByName(activityName);
 177             if (activitySpec != null) {
 178                 WorkflowActivitySpecSequence workflowActivitySpec = new WorkflowActivitySpecSequence();
 179                 workflowActivitySpec.setActivitySpec(activitySpec);
 180                 workflowActivitySpecs.add(workflowActivitySpec);
 181             }
 182         }
 183         return workflowActivitySpecs;
 184     }
 185
 186     public String getWorkflowNameFromArtifactName(String artifactName) {
 187         if (artifactName == null) {
 188             return null;
 189         } else {
 190             if (artifactName.contains(BPMN_SUFFIX)) {
 191                 return artifactName.substring(0, artifactName.lastIndexOf(BPMN_SUFFIX)).split("-")[0];
 192             } else {
 193                 return artifactName.split("-")[0];
 194             }
 195         }
 196     }
 197
 198     public Double getWorkflowVersionFromArtifactName(String artifactName) {
 199         if (artifactName == null) {
 200             return null;
 201         } else {
 202             String[] workflowNameParts = null;
 203             if (artifactName.contains(BPMN_SUFFIX)) {
 204                 workflowNameParts = artifactName.substring(0, artifactName.lastIndexOf(BPMN_SUFFIX)).split("-");
 205             } else {
 206                 workflowNameParts = artifactName.split("-");
 207             }
 208             if (workflowNameParts.length < 2) {
 209                 return null;
 210             } else {
 211                 return Double.valueOf(workflowNameParts[1].replaceAll("_", "."));
 212             }
 213         }
 214     }
 215 }