Runtime BPMN Deployment Capability

Added license header to BpmnInstaller.java
ASDC Controller integration with BPMN Installer
Correct a test file name in a JUnit.
BPMN deployment mechanism for WorkflowDesigner

Change-Id: I670406dd09b8789c86ab0b85ef122b35ea057698
Issue-ID: SO-826
Signed-off-by: Elena Kuleshov <EK1439@att.com>

3 files changed, 197 insertions, 0 deletions

diff --git a/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCConfiguration.java b/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCConfiguration.java
index 85e3e9e747..8276826456 100644
--- a/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCConfiguration.java
+++ b/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCConfiguration.java
@@ -70,6 +70,7 @@ public class ASDCConfiguration implements IConfiguration {
     public static final String HEAT_VOL="HEAT_VOL";
     public static final String OTHER="OTHER";
     public static final String TOSCA_CSAR="TOSCA_CSAR";
+    public static final String WORKFLOWS="Workflows";
     public static final String VF_MODULES_METADATA="VF_MODULES_METADATA";
     private static MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.ASDC,ASDCConfiguration.class);
     
diff --git a/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCController.java b/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCController.java
index ee329ced3c..7ead6cbb7f 100644
--- a/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCController.java
+++ b/asdc-controller/src/main/java/org/onap/so/asdc/client/ASDCController.java
@@ -48,6 +48,7 @@ import org.onap.so.asdc.installer.IVfResourceInstaller;
 import org.onap.so.asdc.installer.ToscaResourceStructure;
 import org.onap.so.asdc.installer.VfModuleStructure;
 import org.onap.so.asdc.installer.VfResourceStructure;
+import org.onap.so.asdc.installer.bpmn.BpmnInstaller;
 import org.onap.so.asdc.installer.heat.ToscaResourceInstaller;
 import org.onap.so.asdc.tenantIsolation.DistributionStatus;
 import org.onap.so.asdc.tenantIsolation.WatchdogDistribution;
@@ -79,6 +80,9 @@ public class ASDCController {
     private ToscaResourceInstaller toscaInstaller;
     
     @Autowired
+    private BpmnInstaller bpmnInstaller;
+    
+    @Autowired
     private WatchdogDistributionStatusRepository wdsRepo;
     
     @Autowired
@@ -684,6 +688,13 @@ public class ASDCController {
     		
    			this.processCsarServiceArtifacts(iNotif, toscaResourceStructure);
    			
+   			if (toscaResourceStructure.getServiceVersion() == null) {
+   				LOGGER.debug("Deploy the workflow");
+   				IArtifactInfo iArtifact = toscaResourceStructure.getToscaArtifact();
+   				String csarFilePath = System.getProperty("mso.config.path") + "/ASDC" + "/" + iArtifact.getArtifactName();   				
+   				bpmnInstaller.installBpmn(csarFilePath);
+   			} 			
+
    			// Install a service with no resources, only the service itself
    			if (iNotif.getResources() == null || iNotif.getResources().size() < 1) {
    				
@@ -772,6 +783,26 @@ public class ASDCController {
     							"Exception caught during processCsarServiceArtifacts", "ASDC", "processCsarServiceArtifacts", MsoLogger.ErrorCode.BusinessProcesssError, "Exception in processCsarServiceArtifacts", e);
     				}
     			}
+    			else if(artifact.getArtifactType().equals(ASDCConfiguration.WORKFLOWS)){
+     				
+    				try{   					
+    					
+    					IDistributionClientDownloadResult resultArtifact = this.downloadTheArtifact(artifact,iNotif.getDistributionID());
+    					
+    					writeArtifactToFile(artifact, resultArtifact);
+    					
+    					toscaResourceStructure.setToscaArtifact(artifact);
+    					
+    					LOGGER.debug(ASDCNotificationLogging.dumpASDCNotification(iNotif));
+    					
+
+    				} catch(Exception e){
+    					System.out.println("Whats the error " + e.getMessage());
+    					LOGGER.error(MessageEnum.ASDC_GENERAL_EXCEPTION_ARG,
+    							"Exception caught during processCsarServiceArtifacts", "ASDC", "processCsarServiceArtifacts", MsoLogger.ErrorCode.BusinessProcesssError, "Exception in processCsarServiceArtifacts", e);
+    				}
+    			}
+
     				
     		}
     }
diff --git a/asdc-controller/src/main/java/org/onap/so/asdc/installer/bpmn/BpmnInstaller.java b/asdc-controller/src/main/java/org/onap/so/asdc/installer/bpmn/BpmnInstaller.java
new file mode 100644
index 0000000000..f131b73175
--- /dev/null
+++ b/asdc-controller/src/main/java/org/onap/so/asdc/installer/bpmn/BpmnInstaller.java
@@ -0,0 +1,165 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * 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.onap.so.asdc.installer.bpmn;
+
+import java.io.*;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.zip.*;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.ContentType;
+import org.apache.http.impl.client.HttpClientBuilder;
+
+import org.onap.so.logger.MessageEnum;
+import org.onap.so.logger.MsoLogger;
+import org.apache.http.entity.mime.MultipartEntityBuilder;
+import org.apache.http.entity.mime.content.ByteArrayBody;
+import org.apache.http.entity.mime.content.StringBody;
+import org.apache.http.entity.mime.FormBodyPartBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.env.Environment;
+import org.springframework.stereotype.Component;
+
+@Component
+public class BpmnInstaller {
+	protected static final MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.ASDC,BpmnInstaller.class);
+	private static final String BPMN_SUFFIX = ".bpmn";
+	private static final String CAMUNDA_URL = "mso.camundaURL";
+	private static final String CREATE_DEPLOYMENT_PATH = "/sobpmnengine/deployment/create";
+	
+	@Autowired
+	private Environment env;	
+	
+	public void installBpmn(String csarFilePath) {
+		LOGGER.info("Deploying BPMN files from " + csarFilePath);		
+		try {			
+			ZipInputStream csarFile = new ZipInputStream(new FileInputStream(csarFilePath));
+			ZipEntry entry = csarFile.getNextEntry();		
+	 
+			while (entry != null) {				
+				String name = entry.getName();
+				if (name.endsWith(BPMN_SUFFIX)) {
+					LOGGER.debug("Attempting to deploy BPMN file: " + name);
+					try {
+						Path p = Paths.get(name);
+						String fileName = p.getFileName().toString();
+						extractBpmnFileFromCsar(csarFile, fileName);
+						HttpResponse response = sendDeploymentRequest(fileName);
+						LOGGER.debug("Response status line: " + response.getStatusLine());
+						LOGGER.debug("Response entity: " + response.getEntity().toString());
+						if (response.getStatusLine().getStatusCode() != 200) {
+							LOGGER.debug("Failed deploying BPMN " + name);
+			                LOGGER.error(MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL,
+			        				name,
+			        				fileName,
+			        				"",
+			        				Integer.toString(response.getStatusLine().getStatusCode()), "", "", MsoLogger.ErrorCode.DataError, "ASDC BPMN deploy failed"); 	
+						}						
+						else {
+							LOGGER.debug("Successfully deployed to Camunda: " + name);
+						}
+					}
+					catch (Exception e) {
+						LOGGER.debug("Exception :",e);
+		                LOGGER.error(MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL,
+		        				name,
+		        				"",
+		        				"",
+		        				e.getMessage(), "", "", MsoLogger.ErrorCode.DataError, "ASDC BPMN deploy failed"); 					
+					}							
+				}
+				entry = csarFile.getNextEntry();
+	        }
+			csarFile.close();
+		} catch (IOException ex) {
+			LOGGER.debug("Exception :",ex);
+            LOGGER.error(MessageEnum.ASDC_ARTIFACT_NOT_DEPLOYED_DETAIL,
+    				csarFilePath,
+    				"",
+    				"",
+    				ex.getMessage(), "", "", MsoLogger.ErrorCode.DataError, "ASDC reading CSAR with workflows failed"); 		
+		}
+		return;
+	}	
+	
+	protected HttpResponse sendDeploymentRequest(String bpmnFileName) throws Exception {					
+		HttpClient client = HttpClientBuilder.create().build();	
+		String deploymentUri = this.env.getProperty(CAMUNDA_URL) + CREATE_DEPLOYMENT_PATH;
+		HttpPost post = new HttpPost(deploymentUri);
+		RequestConfig requestConfig =
+				RequestConfig.custom().setSocketTimeout(1000000).setConnectTimeout(1000).setConnectionRequestTimeout(1000).build();
+		post.setConfig(requestConfig);        
+		HttpEntity requestEntity = buildMimeMultipart(bpmnFileName);        
+		post.setEntity(requestEntity);
+		return client.execute(post);
+	}
+	
+	protected HttpEntity buildMimeMultipart(String bpmnFileName) throws Exception {
+		FileInputStream bpmnFileStream = new FileInputStream (System.getProperty("mso.config.path") + "/ASDC" + "/" + bpmnFileName);
+
+		byte[] bytesToSend = IOUtils.toByteArray(bpmnFileStream);
+		HttpEntity requestEntity = MultipartEntityBuilder.create()                
+				.addPart(FormBodyPartBuilder.create()
+						.setName("deployment-name")
+						.setBody(new StringBody("MSO Sample 1", ContentType.TEXT_PLAIN))
+						.setField("Content-Disposition", String.format("form-data; name=\"%s\"", "deployment-name"))
+						.build())
+				.addPart(FormBodyPartBuilder.create() 
+						.setName("enable-duplicate-filtering")
+						.setBody(new StringBody("false", ContentType.TEXT_PLAIN))
+						.setField("Content-Disposition", String.format("form-data; name=\"%s\"", "enable-duplicate-filtering"))
+						.build())
+				.addPart(FormBodyPartBuilder.create()
+						.setName("deplpy-changed-only")
+						.setBody(new StringBody("false", ContentType.TEXT_PLAIN))
+						.setField("Content-Disposition", String.format("form-data; name=\"%s\"", "deploy-changed-only"))
+						.build())
+				.addPart(FormBodyPartBuilder.create()
+						.setName("deployment-source")  
+						.setBody(new StringBody("local", ContentType.TEXT_PLAIN))
+						.setField("Content-Disposition", String.format("form-data; name=\"%s\"", "deployment-source"))
+						.build())
+				.addPart(FormBodyPartBuilder.create()
+						.setName(bpmnFileName)
+						.setBody(new ByteArrayBody(bytesToSend, ContentType.create("octet"), bpmnFileName))
+						.setField("Content-Disposition", String.format("form-data; name=\"%s\"; filename=\"%s\"; size=%d", bpmnFileName, bpmnFileName, bytesToSend.length))
+						.build())
+				.build();
+		 return requestEntity;
+	}
+	
+	protected void extractBpmnFileFromCsar(ZipInputStream zipIn, String fileName) throws IOException {
+		String filePath = System.getProperty("mso.config.path") + "/ASDC" + "/" + fileName;
+		BufferedOutputStream outputStream = new BufferedOutputStream(new FileOutputStream(filePath));
+		byte[] bytesIn = new byte[4096];
+		int read = 0;
+		while ((read = zipIn.read(bytesIn)) != -1) {
+			outputStream.write(bytesIn, 0, read);
+		}
+		outputStream.close();
+	}
+}