2 * ============LICENSE_START=======================================================
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
13 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
23 package org.onap.so.asdc.installer.bpmn;
25 import java.util.ArrayList;
26 import java.util.List;
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.VnfResource;
36 import org.onap.so.db.catalog.beans.VnfResourceWorkflow;
37 import org.onap.so.db.catalog.beans.Workflow;
38 import org.onap.so.db.catalog.beans.WorkflowActivitySpecSequence;
39 import org.onap.so.db.catalog.data.repository.ActivitySpecRepository;
40 import org.onap.so.db.catalog.data.repository.VnfResourceRepository;
41 import org.onap.so.db.catalog.data.repository.WorkflowRepository;
42 import org.onap.so.logger.ErrorCode;
43 import org.onap.so.logger.MessageEnum;
44 import org.slf4j.Logger;
45 import org.slf4j.LoggerFactory;
46 import org.springframework.beans.factory.annotation.Autowired;
47 import org.springframework.http.HttpStatus;
48 import org.springframework.stereotype.Component;
51 public class WorkflowResource {
52 protected static final Logger logger = LoggerFactory.getLogger(WorkflowResource.class);
54 private static final String pattern = ".*\\\"activity:(.*)\\\" .*";
55 private static final String TARGET_RESOURCE_VNF = "vnf";
56 private static final String SOURCE_SDC = "sdc";
57 private static final String BPMN_SUFFIX = ".bpmn";
60 protected WorkflowRepository workflowRepo;
63 protected ActivitySpecRepository activityRepo;
66 protected VnfResourceRepository vnfResourceRepo;
69 private BpmnInstaller bpmnInstaller;
71 public void processWorkflows(VfResourceStructure vfResourceStructure) throws Exception {
72 Map<String, WorkflowArtifact> artifactsMapByUUID = vfResourceStructure.getWorkflowArtifactsMapByUUID();
73 if (artifactsMapByUUID != null && !artifactsMapByUUID.isEmpty()) {
74 String vfResourceModelUuid = vfResourceStructure.getResourceInstance().getResourceUUID();
75 VnfResource vnfResource = vnfResourceRepo.findResourceByModelUUID(vfResourceModelUuid);
76 if (vnfResource == null) {
77 logger.debug("Failed deploying BPMN for vfResourceModelUUID {}", vfResourceModelUuid);
78 logger.error("{} {} {} {} {} {}", MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL.toString(),
79 vfResourceModelUuid, vfResourceModelUuid, HttpStatus.NOT_FOUND, ErrorCode.DataError.getValue(),
80 "ASDC BPMN deploy failed");
81 throw (new Exception("VF Resource not present in Catalog DB: " + vfResourceModelUuid));
83 for (String uuid : artifactsMapByUUID.keySet()) {
84 WorkflowArtifact artifactToInstall = artifactsMapByUUID.get(uuid);
85 if (isLatestVersionAvailable(artifactsMapByUUID, artifactToInstall)) {
86 logger.debug("Installing the BPMN: " + artifactToInstall.getArtifactInfo().getArtifactName());
87 deployWorkflowResourceToCamunda(artifactToInstall);
88 installWorkflowResource(artifactToInstall, vfResourceModelUuid);
90 logger.debug("Skipping installing - not the latest version: "
91 + artifactToInstall.getArtifactInfo().getArtifactName());
97 protected void deployWorkflowResourceToCamunda(WorkflowArtifact artifact) throws Exception {
98 String bpmnName = artifact.getArtifactInfo().getArtifactName();
99 String version = artifact.getArtifactInfo().getArtifactVersion();
100 logger.debug("BPMN Name: " + bpmnName);
102 HttpResponse response = bpmnInstaller.sendDeploymentRequest(bpmnName, version);
103 logger.debug("Response status line: {}", response.getStatusLine());
104 logger.debug("Response entity: {}", response.getEntity().toString());
105 if (response.getStatusLine().getStatusCode() != 200) {
106 logger.debug("Failed deploying BPMN {}", bpmnName);
107 logger.error("{} {} {} {} {} {}", MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL.toString(), bpmnName,
108 bpmnName, Integer.toString(response.getStatusLine().getStatusCode()),
109 ErrorCode.DataError.getValue(), "ASDC BPMN deploy failed");
110 throw (new Exception("Error from Camunda on deploying the BPMN: " + bpmnName));
112 logger.debug("Successfully deployed to Camunda: {}", bpmnName);
114 } catch (Exception e) {
115 logger.debug("Exception :", e);
116 logger.error("{} {} {} {} {}", MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL.toString(), bpmnName,
117 e.getMessage(), ErrorCode.DataError.getValue(), "ASDC BPMN deploy failed");
122 protected void installWorkflowResource(WorkflowArtifact artifact, String vfResourceModelUuid) throws Exception {
123 IArtifactInfo artifactInfo = artifact.getArtifactInfo();
125 Workflow workflow = new Workflow();
127 workflow.setArtifactChecksum(artifactInfo.getArtifactChecksum());
128 workflow.setArtifactName(artifactInfo.getArtifactName());
129 workflow.setArtifactUUID(artifactInfo.getArtifactUUID());
130 workflow.setBody(artifact.getResult());
131 workflow.setDescription(artifactInfo.getArtifactDescription());
132 workflow.setName(getWorkflowNameFromArtifactName(artifactInfo.getArtifactName()));
133 workflow.setResourceTarget(TARGET_RESOURCE_VNF);
134 workflow.setSource(SOURCE_SDC);
135 workflow.setTimeoutMinutes(artifactInfo.getArtifactTimeout());
136 workflow.setOperationName(getWorkflowNameFromArtifactName(artifactInfo.getArtifactName()));
137 workflow.setVersion(getWorkflowVersionFromArtifactName(artifactInfo.getArtifactName()));
139 VnfResourceWorkflow vnfResourceWorkflow = new VnfResourceWorkflow();
140 vnfResourceWorkflow.setVnfResourceModelUUID(vfResourceModelUuid);
141 vnfResourceWorkflow.setWorkflow(workflow);
142 List<VnfResourceWorkflow> vnfResourceWorkflows = new ArrayList<VnfResourceWorkflow>();
143 vnfResourceWorkflows.add(vnfResourceWorkflow);
145 workflow.setVnfResourceWorkflow(vnfResourceWorkflows);
147 List<String> activityNames = getActivityNameList(artifact.getResult());
148 List<WorkflowActivitySpecSequence> wfss = getWorkflowActivitySpecSequence(activityNames, workflow);
149 workflow.setWorkflowActivitySpecSequence(wfss);
151 workflowRepo.save(workflow);
155 protected boolean isLatestVersionAvailable(Map<String, WorkflowArtifact> artifactsMapByUUID,
156 WorkflowArtifact artifact) {
157 String workflowName = getWorkflowNameFromArtifactName(artifact.getArtifactInfo().getArtifactName());
158 Double workflowVersion = getWorkflowVersionFromArtifactName(artifact.getArtifactInfo().getArtifactName());
159 if (workflowVersion == null) {
160 workflowVersion = 0.0;
162 for (WorkflowArtifact artifactInMap : artifactsMapByUUID.values()) {
163 Double versionInMap = getWorkflowVersionFromArtifactName(artifactInMap.getArtifactInfo().getArtifactName());
164 if (versionInMap == null) {
167 if (workflowName.equals(getWorkflowNameFromArtifactName(artifactInMap.getArtifactInfo().getArtifactName()))
168 && Double.compare(workflowVersion, versionInMap) < 0) {
175 protected List<String> getActivityNameList(String bpmnContent) {
176 List<String> activityNameList = new ArrayList<String>();
178 Pattern p = Pattern.compile(pattern);
179 Matcher m = p.matcher(bpmnContent);
181 activityNameList.add(m.group(1));
183 return activityNameList;
186 protected List<WorkflowActivitySpecSequence> getWorkflowActivitySpecSequence(List<String> activityNames,
187 Workflow workflow) throws Exception {
188 if (activityNames == null || activityNames.size() == 0) {
191 List<WorkflowActivitySpecSequence> workflowActivitySpecs = new ArrayList<WorkflowActivitySpecSequence>();
193 for (String activityName : activityNames) {
194 ActivitySpec activitySpec = activityRepo.findByName(activityName);
195 if (activitySpec != null) {
196 WorkflowActivitySpecSequence workflowActivitySpec = new WorkflowActivitySpecSequence();
197 workflowActivitySpec.setActivitySpec(activitySpec);
198 workflowActivitySpec.setWorkflow(workflow);
199 workflowActivitySpec.setSeqNo(seqNo);
201 workflowActivitySpecs.add(workflowActivitySpec);
204 return workflowActivitySpecs;
207 public String getWorkflowNameFromArtifactName(String artifactName) {
208 if (artifactName == null) {
211 if (artifactName.contains(BPMN_SUFFIX)) {
212 return artifactName.substring(0, artifactName.lastIndexOf(BPMN_SUFFIX)).split("-")[0];
214 return artifactName.split("-")[0];
219 public Double getWorkflowVersionFromArtifactName(String artifactName) {
220 if (artifactName == null) {
223 String[] workflowNameParts = null;
224 if (artifactName.contains(BPMN_SUFFIX)) {
225 workflowNameParts = artifactName.substring(0, artifactName.lastIndexOf(BPMN_SUFFIX)).split("-");
227 workflowNameParts = artifactName.split("-");
229 if (workflowNameParts.length < 2) {
232 return Double.valueOf(workflowNameParts[1].replaceAll("_", "."));