Implement Workflows to handle NSSMF Common functionalities

Issue-ID: SO-3190
Signed-off-by: Priyadharshini <priyadharshini.b96@wipro.com>
Change-Id: I38ce91415fc5ced083e017ed4306873d17d5fa24

8 files changed, 1061 insertions, 0 deletions

diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateSliceSubnet.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateSliceSubnet.groovy
new file mode 100644
index 0000000000..c7fe7e36a6
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateSliceSubnet.groovy
@@ -0,0 +1,181 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ # Copyright (c) 2020, Wipro Limited.
+ #
+ # 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.bpmn.infrastructure.scripts
+
+import org.camunda.bpm.engine.delegate.BpmnError
+import org.camunda.bpm.engine.delegate.DelegateExecution
+import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
+import org.onap.so.bpmn.common.scripts.ExceptionUtil
+import org.onap.so.bpmn.common.scripts.RequestDBUtil
+import org.onap.so.bpmn.core.json.JsonUtils
+import org.onap.so.db.request.beans.ResourceOperationStatus
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import static org.apache.commons.lang3.StringUtils.isBlank
+
+class ActivateSliceSubnet extends AbstractServiceTaskProcessor {
+	String Prefix="ActSS"
+	ExceptionUtil exceptionUtil = new ExceptionUtil()
+	JsonUtils jsonUtil = new JsonUtils()
+	RequestDBUtil requestDBUtil = new RequestDBUtil()
+	
+	private static final Logger logger = LoggerFactory.getLogger(ActivateSliceSubnet.class)
+	
+	 @Override
+	void preProcessRequest(DelegateExecution execution) {
+		logger.debug(Prefix + "preProcessRequest Start")
+		execution.setVariable("prefix", Prefix)
+		execution.setVariable("startTime", System.currentTimeMillis())
+		def msg
+		try {
+			// get request input
+			String subnetInstanceReq = execution.getVariable("bpmnRequest")
+			logger.debug(subnetInstanceReq)
+
+			String requestId = execution.getVariable("mso-request-id")
+			execution.setVariable("msoRequestId", requestId)
+			logger.debug("Input Request:" + subnetInstanceReq + " reqId:" + requestId)
+
+			//subscriberInfo
+			String globalSubscriberId = jsonUtil.getJsonValue(subnetInstanceReq, "globalSubscriberId")
+			if (isBlank(globalSubscriberId)) {
+				msg = "Input globalSubscriberId' is null"
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("globalSubscriberId", globalSubscriberId)
+			}
+			
+			//NSSI ID
+			String serviceInstanceID = jsonUtil.getJsonValue(subnetInstanceReq, "serviceInstanceID")
+			if (isBlank(serviceInstanceID)) {
+				msg = "Input serviceInstanceID is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("serviceInstanceID", serviceInstanceID)
+			}
+			
+			String nsiId = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties.nsiId")
+			if (isBlank(nsiId)) {
+				msg = "Input nsiId is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("nsiId", nsiId)
+			}
+			String networkType = jsonUtil.getJsonValue(subnetInstanceReq, "networkType")
+			if (isBlank(networkType)) {
+				msg = "Input networkType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("networkType", networkType.toUpperCase())
+			}
+			
+			//requestParameters, subscriptionServiceType is 5G
+			String subscriptionServiceType = jsonUtil.getJsonValue(subnetInstanceReq, "subscriptionServiceType")
+			if (isBlank(subscriptionServiceType)) {
+				msg = "Input subscriptionServiceType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("subscriptionServiceType", subscriptionServiceType)
+			}
+			
+			//operationType = deactivateInstance/activateInstance
+			String operationType = execution.getVariable("requestAction")
+			if (isBlank(operationType)) {
+				msg = "Input operationType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("operationType", operationType)
+			}
+			
+			String jobId = UUID.randomUUID().toString()
+			execution.setVariable("jobId", jobId)
+			
+			String sliceParams = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties")
+			execution.setVariable("sliceParams", sliceParams)
+
+		} catch(BpmnError e) {
+			throw e
+		} catch(Exception ex) {
+			msg = "Exception in ActivateSliceSubnet.preProcessRequest " + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "preProcessRequest Exit")
+	}
+
+
+	/**
+	 * create operation status in request db
+	 *
+	 * Init the Operation Status
+	 */
+	def prepareInitOperationStatus = { DelegateExecution execution ->
+		logger.debug(Prefix + "prepareInitOperationStatus Start")
+
+		String serviceId = execution.getVariable("serviceInstanceID")
+		String jobId = execution.getVariable("jobId")
+		String nsiId = execution.getVariable("nsiId")
+		String operationType = execution.getVariable("operationType")
+		logger.debug("Generated new job for Service Instance serviceId:" + serviceId + " jobId:" + jobId)
+
+		ResourceOperationStatus initStatus = new ResourceOperationStatus()
+		initStatus.setServiceId(serviceId)
+		initStatus.setOperationId(jobId)
+		initStatus.setResourceTemplateUUID(nsiId)
+		initStatus.setOperType(operationType)
+		requestDBUtil.prepareInitResourceOperationStatus(execution, initStatus)
+
+		logger.debug(Prefix + "prepareInitOperationStatus Exit")
+	}
+
+
+	
+	/**
+	 * return sync response
+	 */
+	def sendSyncResponse = { DelegateExecution execution ->
+		logger.debug(Prefix + "sendSyncResponse Start")
+		try {
+			String jobId = execution.getVariable("jobId")
+			String activateSyncResponse = """{"jobId": "${jobId}","status": "processing"}"""
+												.trim().replaceAll(" ", "")
+
+			logger.debug("sendSyncResponse to APIH:" + "\n" + activateSyncResponse)
+			sendWorkflowResponse(execution, 202, activateSyncResponse)
+
+			execution.setVariable("sentSyncResponse", true)
+		} catch (Exception ex) {
+			String msg = "Exception in sendSyncResponse:" + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "sendSyncResponse Exit")
+	}
+	
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AllocateSliceSubnet.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AllocateSliceSubnet.groovy
new file mode 100644
index 0000000000..5a7722d679
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AllocateSliceSubnet.groovy
@@ -0,0 +1,190 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ # Copyright (c) 2020, Wipro Limited.
+ #
+ # 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.bpmn.infrastructure.scripts
+
+import org.camunda.bpm.engine.delegate.BpmnError
+import org.camunda.bpm.engine.delegate.DelegateExecution
+import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
+import org.onap.so.bpmn.common.scripts.ExceptionUtil
+import org.onap.so.bpmn.common.scripts.RequestDBUtil
+import org.onap.so.bpmn.core.json.JsonUtils
+import org.onap.so.db.request.beans.ResourceOperationStatus
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import static org.apache.commons.lang3.StringUtils.isBlank
+
+class AllocateSliceSubnet extends AbstractServiceTaskProcessor {
+
+	String Prefix="ASS_"
+	ExceptionUtil exceptionUtil = new ExceptionUtil()
+	RequestDBUtil requestDBUtil = new RequestDBUtil()
+	JsonUtils jsonUtil = new JsonUtils()
+	private static final Logger logger = LoggerFactory.getLogger(AllocateSliceSubnet.class)
+
+	@Override
+	void preProcessRequest(DelegateExecution execution) {
+		logger.debug(Prefix + "preProcessRequest Start")
+		execution.setVariable("prefix", Prefix)
+		execution.setVariable("startTime", System.currentTimeMillis())
+		def msg
+		try {
+			// get request input
+			String subnetInstanceReq = execution.getVariable("bpmnRequest")
+			logger.debug(subnetInstanceReq)
+
+			String requestId = execution.getVariable("mso-request-id")
+			execution.setVariable("msoRequestId", requestId)
+			logger.debug("Input Request:" + subnetInstanceReq + " reqId:" + requestId)
+
+			//modelInfo
+			String modelInvariantUuid = jsonUtil.getJsonValue(subnetInstanceReq, "modelInvariantUuid")
+			if (isBlank(modelInvariantUuid)) {
+				msg = "Input modelInvariantUuid is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("modelInvariantUuid", modelInvariantUuid)
+			}
+
+			logger.debug("modelInvariantUuid: " + modelInvariantUuid)
+
+			String modelUuid = jsonUtil.getJsonValue(subnetInstanceReq, "modelUuid")
+			if (isBlank(modelUuid)) {
+				msg = "Input modelUuid is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("modelUuid", modelUuid)
+			}
+
+			logger.debug("modelUuid: " + modelUuid)
+
+
+			//subscriberInfo
+			String globalSubscriberId = jsonUtil.getJsonValue(subnetInstanceReq, "globalSubscriberId")
+			if (isBlank(globalSubscriberId)) {
+				msg = "Input globalSubscriberId' is null"
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("globalSubscriberId", globalSubscriberId)
+			}
+			String dummyServiceId = new UUID(0,0).toString();
+			execution.setVariable("dummyServiceId", dummyServiceId)
+			logger.debug("dummyServiceId: " + dummyServiceId)
+			String servicename = jsonUtil.getJsonValue(subnetInstanceReq, "name")
+			execution.setVariable("servicename", servicename)
+
+			String nsiId = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties.nsiInfo.nsiId")
+			if (isBlank(nsiId)) {
+				msg = "Input nsiId is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("nsiId", nsiId)
+			}
+
+			String networkType = jsonUtil.getJsonValue(subnetInstanceReq, "networkType")
+			if (isBlank(networkType)) {
+				msg = "Input networkType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("networkType", networkType.toUpperCase())
+			}
+
+			//requestParameters, subscriptionServiceType is 5G
+			String subscriptionServiceType = jsonUtil.getJsonValue(subnetInstanceReq, "subscriptionServiceType")
+			if (isBlank(subscriptionServiceType)) {
+				msg = "Input subscriptionServiceType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("subscriptionServiceType", subscriptionServiceType)
+			}
+
+			String jobId = UUID.randomUUID().toString()
+			execution.setVariable("jobId", jobId)
+
+			String sliceParams = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties")
+			execution.setVariable("sliceParams", sliceParams)
+
+		} catch(BpmnError e) {
+			throw e
+		} catch(Exception ex) {
+			msg = "Exception in AllocateSliceSubnet.preProcessRequest " + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "preProcessRequest Exit")
+	}
+
+
+	/**
+	 * create operation status in request db
+	 *
+	 * Init the Operation Status
+	 */
+	def prepareInitOperationStatus = { DelegateExecution execution ->
+		logger.debug(Prefix + "prepareInitOperationStatus Start")
+
+		String serviceId = execution.getVariable("dummyServiceId")
+		String jobId = execution.getVariable("jobId")
+		String nsiId = execution.getVariable("nsiId")
+		logger.debug("Generated new job for Service Instance serviceId:" + serviceId + " jobId:" + jobId)
+
+		ResourceOperationStatus initStatus = new ResourceOperationStatus()
+		initStatus.setServiceId(serviceId)
+		initStatus.setOperationId(jobId)
+		initStatus.setResourceTemplateUUID(nsiId)
+		initStatus.setOperType("Allocate")
+		requestDBUtil.prepareInitResourceOperationStatus(execution, initStatus)
+
+		logger.debug(Prefix + "prepareInitOperationStatus Exit")
+	}
+
+
+	/**
+	 * return sync response
+	 */
+	def sendSyncResponse = { DelegateExecution execution ->
+		logger.debug(Prefix + "sendSyncResponse Start")
+		try {
+			String jobId = execution.getVariable("jobId")
+			String allocateSyncResponse = """{"jobId": "${jobId}","status": "processing"}"""
+												.trim().replaceAll(" ", "").trim().replaceAll(" ", "")
+
+			logger.debug("sendSyncResponse to APIH:" + "\n" + allocateSyncResponse)
+			sendWorkflowResponse(execution, 202, allocateSyncResponse)
+
+			execution.setVariable("sentSyncResponse", true)
+		} catch (Exception ex) {
+			String msg = "Exception in sendSyncResponse:" + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "sendSyncResponse Exit")
+	}
+	
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy
new file mode 100644
index 0000000000..964baa7a9d
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy
@@ -0,0 +1,170 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ # Copyright (c) 2020, Wipro Limited.
+ #
+ # 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.bpmn.infrastructure.scripts
+
+import org.camunda.bpm.engine.delegate.BpmnError
+import org.camunda.bpm.engine.delegate.DelegateExecution
+import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
+import org.onap.so.bpmn.common.scripts.ExceptionUtil
+import org.onap.so.bpmn.common.scripts.RequestDBUtil
+import org.onap.so.bpmn.core.json.JsonUtils
+import org.onap.so.db.request.beans.ResourceOperationStatus
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import static org.apache.commons.lang3.StringUtils.isBlank
+
+class DeAllocateSliceSubnet extends AbstractServiceTaskProcessor {
+	String Prefix="DeASS_"
+	ExceptionUtil exceptionUtil = new ExceptionUtil()
+	JsonUtils jsonUtil = new JsonUtils()
+	RequestDBUtil requestDBUtil = new RequestDBUtil()
+	
+	private static final Logger logger = LoggerFactory.getLogger(DeAllocateSliceSubnet.class)
+	
+	 @Override
+    void preProcessRequest(DelegateExecution execution) {
+        logger.debug(Prefix + "preProcessRequest Start")
+        execution.setVariable("prefix", Prefix)
+        execution.setVariable("startTime", System.currentTimeMillis())
+        def msg
+        try {
+            // get request input
+            String subnetInstanceReq = execution.getVariable("bpmnRequest")
+            logger.debug(subnetInstanceReq)
+
+            String requestId = execution.getVariable("mso-request-id")
+            execution.setVariable("msoRequestId", requestId)
+            logger.debug("Input Request:" + subnetInstanceReq + " reqId:" + requestId)
+
+            //subscriberInfo
+            String globalSubscriberId = jsonUtil.getJsonValue(subnetInstanceReq, "globalSubscriberId")
+            if (isBlank(globalSubscriberId)) {
+                msg = "Input globalSubscriberId' is null"
+                exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+            } else {
+                execution.setVariable("globalSubscriberId", globalSubscriberId)
+            }
+			
+			//NSSI ID
+            String serviceInstanceID = jsonUtil.getJsonValue(subnetInstanceReq, "serviceInstanceID")
+            if (isBlank(serviceInstanceID)) {
+                msg = "Input serviceInstanceID is null"
+                logger.debug(msg)
+                exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+            } else
+            {
+                execution.setVariable("serviceInstanceID", serviceInstanceID)
+            }
+			
+			String nsiId = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties.nsiId")
+			if (isBlank(nsiId)) {
+				msg = "Input nsiId is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("nsiId", nsiId)
+			}
+
+			String networkType = jsonUtil.getJsonValue(subnetInstanceReq, "networkType")
+			if (isBlank(networkType)) {
+				msg = "Input networkType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("networkType", networkType.toUpperCase())
+			}
+			
+            //requestParameters, subscriptionServiceType is 5G
+            String subscriptionServiceType = jsonUtil.getJsonValue(subnetInstanceReq, "subscriptionServiceType")
+            if (isBlank(subscriptionServiceType)) {
+                msg = "Input subscriptionServiceType is null"
+                logger.debug(msg)
+                exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+            } else {
+                execution.setVariable("subscriptionServiceType", subscriptionServiceType)
+            }
+            
+            String jobId = UUID.randomUUID().toString()
+            execution.setVariable("jobId", jobId)
+			
+			String sliceParams = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties")
+			execution.setVariable("sliceParams", sliceParams)
+
+        } catch(BpmnError e) {
+            throw e
+        } catch(Exception ex) {
+            msg = "Exception in DeAllocateSliceSubnet.preProcessRequest " + ex.getMessage()
+            logger.debug(msg)
+            exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+        }
+        logger.debug(Prefix + "preProcessRequest Exit")
+    }
+
+
+    /**
+     * create operation status in request db
+     *
+     * Init the Operation Status
+     */
+    def prepareInitOperationStatus = { DelegateExecution execution ->
+        logger.debug(Prefix + "prepareInitOperationStatus Start")
+
+        String serviceId = execution.getVariable("serviceInstanceID")
+        String jobId = execution.getVariable("jobId")
+		String nsiId = execution.getVariable("nsiId")
+        logger.debug("Generated new job for Service Instance serviceId:" + serviceId + " jobId:" + jobId)
+
+        ResourceOperationStatus initStatus = new ResourceOperationStatus()
+        initStatus.setServiceId(serviceId)
+        initStatus.setOperationId(jobId)
+		initStatus.setResourceTemplateUUID(nsiId)
+        initStatus.setOperType("Deallocate")
+        requestDBUtil.prepareInitResourceOperationStatus(execution, initStatus)
+
+        logger.debug(Prefix + "prepareInitOperationStatus Exit")
+    }
+
+
+	
+	/**
+	 * return sync response
+	 */
+	def sendSyncResponse = { DelegateExecution execution ->
+		logger.debug(Prefix + "sendSyncResponse Start")
+		try {
+			String jobId = execution.getVariable("jobId")
+			String deAllocateSyncResponse = """{"jobId": "${jobId}","status": "processing"}""".trim().replaceAll(" ", "")
+
+			logger.debug("sendSyncResponse to APIH:" + "\n" + deAllocateSyncResponse)
+			sendWorkflowResponse(execution, 202, deAllocateSyncResponse)
+
+			execution.setVariable("sentSyncResponse", true)
+		} catch (Exception ex) {
+			String msg = "Exception in sendSyncResponse:" + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "sendSyncResponse Exit")
+	}
+
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ModifySliceSubnet.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ModifySliceSubnet.groovy
new file mode 100644
index 0000000000..47489b7b84
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ModifySliceSubnet.groovy
@@ -0,0 +1,173 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ # Copyright (c) 2020, Wipro Limited.
+ #
+ # 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.bpmn.infrastructure.scripts
+
+import org.camunda.bpm.engine.delegate.BpmnError
+import org.camunda.bpm.engine.delegate.DelegateExecution
+import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
+import org.onap.so.bpmn.common.scripts.ExceptionUtil
+import org.onap.so.bpmn.common.scripts.RequestDBUtil
+import org.onap.so.bpmn.core.json.JsonUtils
+import org.onap.so.db.request.beans.ResourceOperationStatus
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import static org.apache.commons.lang3.StringUtils.isBlank
+
+class ModifySliceSubnet extends AbstractServiceTaskProcessor {
+	String Prefix="MSS_"
+	ExceptionUtil exceptionUtil = new ExceptionUtil()
+	JsonUtils jsonUtil = new JsonUtils()
+	RequestDBUtil requestDBUtil = new RequestDBUtil()
+	
+	private static final Logger logger = LoggerFactory.getLogger(ModifySliceSubnet.class)
+
+	@Override
+	void preProcessRequest(DelegateExecution execution) {
+		logger.debug(Prefix + "preProcessRequest Start")
+		execution.setVariable("prefix", Prefix)
+		execution.setVariable("startTime", System.currentTimeMillis())
+		def msg
+		try {
+			// get request input
+			String subnetInstanceReq = execution.getVariable("bpmnRequest")
+			logger.debug(subnetInstanceReq)
+
+			String requestId = execution.getVariable("mso-request-id")
+			execution.setVariable("msoRequestId", requestId)
+			logger.debug("Input Request:" + subnetInstanceReq + " reqId:" + requestId)
+
+			//subscriberInfo
+			String globalSubscriberId = jsonUtil.getJsonValue(subnetInstanceReq, "globalSubscriberId")
+			if (isBlank(globalSubscriberId)) {
+				msg = "Input globalSubscriberId' is null"
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("globalSubscriberId", globalSubscriberId)
+			}
+
+			//NSSI Info
+			String serviceInstanceID = jsonUtil.getJsonValue(subnetInstanceReq, "serviceInstanceID")
+			if (isBlank(serviceInstanceID)) {
+				msg = "Input serviceInstanceID is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("serviceInstanceID", serviceInstanceID)
+			}
+
+			String servicename = jsonUtil.getJsonValue(subnetInstanceReq, "name")
+			execution.setVariable("servicename", servicename)
+
+			String nsiId = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties.nsiInfo.nsiId")
+			if (isBlank(nsiId)) {
+				msg = "Input nsiId is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("nsiId", nsiId)
+			}
+
+			String networkType = jsonUtil.getJsonValue(subnetInstanceReq, "networkType")
+			if (isBlank(networkType)) {
+				msg = "Input networkType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else
+			{
+				execution.setVariable("networkType", networkType.toUpperCase())
+			}
+
+			//requestParameters, subscriptionServiceType is 5G
+			String subscriptionServiceType = jsonUtil.getJsonValue(subnetInstanceReq, "subscriptionServiceType")
+			if (isBlank(subscriptionServiceType)) {
+				msg = "Input subscriptionServiceType is null"
+				logger.debug(msg)
+				exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
+			} else {
+				execution.setVariable("subscriptionServiceType", subscriptionServiceType)
+			}
+
+			String jobId = UUID.randomUUID().toString()
+			execution.setVariable("jobId", jobId)
+
+			String sliceParams = jsonUtil.getJsonValue(subnetInstanceReq, "additionalProperties")
+			execution.setVariable("sliceParams", sliceParams)
+
+		} catch(BpmnError e) {
+			throw e
+		} catch(Exception ex) {
+			msg = "Exception in ModifySliceSubnet.preProcessRequest " + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "preProcessRequest Exit")
+	}
+
+
+	/**
+	 * create operation status in request db
+	 *
+	 * Init the Operation Status
+	 */
+	def prepareInitOperationStatus = { DelegateExecution execution ->
+		logger.debug(Prefix + "prepareInitOperationStatus Start")
+
+		String serviceId = execution.getVariable("serviceInstanceID")
+		String jobId = execution.getVariable("jobId")
+		String nsiId = execution.getVariable("nsiId")
+		logger.debug("Generated new job for Service Instance serviceId:" + serviceId + "jobId:" + jobId)
+
+		ResourceOperationStatus initStatus = new ResourceOperationStatus()
+		initStatus.setServiceId(serviceId)
+		initStatus.setOperationId(jobId)
+		initStatus.setResourceTemplateUUID(nsiId)
+		initStatus.setOperType("Modify")
+		requestDBUtil.prepareInitResourceOperationStatus(execution, initStatus)
+
+		logger.debug(Prefix + "prepareInitOperationStatus Exit")
+	}
+
+
+
+	/**
+	 * return sync response
+	 */
+	def sendSyncResponse = { DelegateExecution execution ->
+		logger.debug(Prefix + "sendSyncResponse Start")
+		try {
+			String jobId = execution.getVariable("jobId")
+			String modifySyncResponse = """{"jobId": "${jobId}","status": "processing"}"""
+												.trim().replaceAll(" ", "")
+			logger.debug("sendSyncResponse to APIH:" + "\n" + modifySyncResponse)
+			sendWorkflowResponse(execution, 202, modifySyncResponse)
+
+			execution.setVariable("sentSyncResponse", true)
+		} catch (Exception ex) {
+			String msg = "Exception in sendSyncResponse:" + ex.getMessage()
+			logger.debug(msg)
+			exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
+		}
+		logger.debug(Prefix + "sendSyncResponse Exit")
+	}
+
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateSliceSubnetTest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateSliceSubnetTest.groovy
new file mode 100644
index 0000000000..adb83e7714
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/ActivateSliceSubnetTest.groovy
@@ -0,0 +1,68 @@
+package org.onap.so.bpmn.infrastructure.scripts
+
+import static org.junit.Assert.*
+
+import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
+import org.junit.Before
+import org.junit.Test
+import org.mockito.ArgumentCaptor
+import org.mockito.Captor
+
+class ActivateSliceSubnetTest {
+	@Before
+	void init() throws IOException {
+		super.init("ActivateSliceSubnet")
+	}
+
+	@Captor
+	static ArgumentCaptor<ExecutionEntity> captor = ArgumentCaptor.forClass(ExecutionEntity.class)
+
+	@Test
+	public void testPreProcessRequest() {
+		when(mockExecution.getVariable("bpmnRequest")).thenReturn("""
+        {
+				"serviceInstanceID": "NSSI-C-001-HDBNJ-NSSMF-01-A-ZX ",
+				"networkType": "an/cn/tn",
+				"globalSubscriberId": "5GCustomer",
+				"subscriptionServiceType": "5G",
+				"additionalProperties": {
+				"nsiInfo": {
+					"nsiId": "NSI-M-001-HDBNJ-NSMF-01-A-ZX",
+					"nsiName": "eMBB-001"
+				},
+				}
+}
+""".replaceAll("\\s+", ""))
+		when(mockExecution.getVariable("mso-request-id")).thenReturn("edb08d97-e0f9-4c71-840a-72080d7be42e")
+		when(mockExecution.getVariable("requestAction")).thenReturn("activateInstance")
+		ActivateSliceSubnet sliceSubnet = new ActivateSliceSubnet()
+		sliceSubnet.preProcessRequest(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(captor.capture() as String, captor.capture())
+		List<ExecutionEntity> values = captor.getAllValues()
+		assertNotNull(values)
+	}
+	
+	@Test
+	void testPrepareInitOperationStatus() {
+		when(mockExecution.getVariable("serviceInstanceId")).thenReturn("54321")
+		when(mockExecution.getVariable("jobId")).thenReturn("54321")
+		when(mockExecution.getVariable("nsiId")).thenReturn("11111")
+		ActivateSliceSubnet sliceSubnet = new ActivateSliceSubnet()
+		sliceSubnet.prepareInitOperationStatus(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("initResourceOperationStatus"), captor.capture())
+		String res = captor.getValue()
+		assertNotNull(res)
+	}
+
+
+	@Test
+	void testSendSyncResponse() {
+		when(mockExecution.getVariable("jobId")).thenReturn("123456")
+		ActivateSliceSubnet sliceSubnet = new ActivateSliceSubnet()
+		sliceSubnet.sendSyncResponse(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("sentSyncResponse"), captor.capture())
+		def updateVolumeGroupRequest = captor.getValue()
+		assertEquals(updateVolumeGroupRequest, true)
+	}
+
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/AllocateSliceSubnetTest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/AllocateSliceSubnetTest.groovy
new file mode 100644
index 0000000000..a9b4e095e7
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/AllocateSliceSubnetTest.groovy
@@ -0,0 +1,135 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ # Copyright (c) 2020, Wipro Limited.
+ #
+ # 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.bpmn.infrastructure.scripts
+
+import static org.junit.Assert.*
+import static org.mockito.Mockito.times
+import static org.mockito.Mockito.when
+
+import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
+import org.junit.Before
+import org.junit.Test
+import org.mockito.ArgumentCaptor
+import org.mockito.Captor
+import org.mockito.Mockito
+import org.onap.so.bpmn.common.scripts.MsoGroovyTest
+
+
+class AllocateSliceSubnetTest extends MsoGroovyTest {
+	
+	@Before
+	void init() throws IOException {
+		super.init("AllocateSliceSubnet")
+	}
+
+	@Captor
+	static ArgumentCaptor<ExecutionEntity> captor = ArgumentCaptor.forClass(ExecutionEntity.class)
+
+	@Test
+	public void testPreProcessRequest() {
+		when(mockExecution.getVariable("serviceInstanceID")).thenReturn("12345")
+		when(mockExecution.getVariable("bpmnRequest")).thenReturn("""
+        {
+				"name": "eMBB-001",
+				"modelInvariantUuid": "NSST-C-001-HDBNJ-NSSMF-01-A-ZX",
+				"modelUuid": "NSST-C-001-HDBNJ-NSSMF-01-A-ZX-UUID",
+				"globalSubscriberId": "5GCustomer",
+				"subscriptionServiceType": "5G",
+				"networkType": "an/cn/tn",
+				"additionalProperties": {
+					"sliceProfile": {
+					"snssaiList": [
+						"001-100001"
+					],
+					"sliceProfileId": "ab9af40f13f721b5f13539d87484098",
+					"plmnIdList": [
+						"460-00",
+						"460-01"
+					],
+					"perfReq": {
+					"perfReqEmbbList ": [
+						{
+							"activityFactor": 50
+						}
+					]
+					},
+				"maxNumberofUEs": 200,
+				"coverageAreaTAList": [
+						"1",
+						"2",
+						"3",
+						"4"
+					],
+				"latency": 2,
+				"resourceSharingLevel": "non-shared"
+					},
+				"endPoints": [
+					{
+						"nodeId": "",
+						"additionalInfo": {
+							"xxx": "xxx"
+						}
+					}
+					],
+				"nsiInfo": {
+					"nsiId": "NSI-M-001-HDBNJ-NSMF-01-A-ZX",
+					"nsiName": "eMBB-001"
+				},
+				"scriptName": "AN1"
+				}
+}
+""".replaceAll("\\s+", ""))
+		when(mockExecution.getVariable("mso-request-id")).thenReturn("edb08d97-e0f9-4c71-840a-72080d7be42e")
+		AllocateSliceSubnet sliceSubnet = new AllocateSliceSubnet()
+		sliceSubnet.preProcessRequest(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(captor.capture() as String, captor.capture())
+		List<ExecutionEntity> values = captor.getAllValues()
+		assertNotNull(values)
+	}
+	
+	@Test
+	void testPrepareInitOperationStatus() {
+
+		when(mockExecution.getVariable("dummyServiceId")).thenReturn("12345")
+		when(mockExecution.getVariable("jobId")).thenReturn("54321")
+
+		when(mockExecution.getVariable("nsiId")).thenReturn("11111")
+
+		AllocateSliceSubnet sliceSubnet = new AllocateSliceSubnet()
+
+		sliceSubnet.prepareInitOperationStatus(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("initResourceOperationStatus"), captor.capture())
+		String res = captor.getValue()
+		assertNotNull(res)
+	}
+
+
+	@Test
+	void testSendSyncResponse() {
+		when(mockExecution.getVariable("jobId")).thenReturn("123456")
+		AllocateSliceSubnet sliceSubnet = new AllocateSliceSubnet()
+		sliceSubnet.sendSyncResponse(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("sentSyncResponse"), captor.capture())
+		def updateVolumeGroupRequest = captor.getValue()
+		assertEquals(updateVolumeGroupRequest, true)
+	}
+
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnetTest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnetTest.groovy
new file mode 100644
index 0000000000..a254a90576
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnetTest.groovy
@@ -0,0 +1,72 @@
+package org.onap.so.bpmn.infrastructure.scripts
+
+import static org.junit.Assert.*
+
+import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
+import org.junit.Before
+import org.junit.Test
+import org.mockito.ArgumentCaptor
+import org.mockito.Captor
+
+class DeAllocateSliceSubnetTest {
+	
+	@Before
+	void init() throws IOException {
+		super.init("DeAllocateSliceSubnet")
+	}
+
+	@Captor
+	static ArgumentCaptor<ExecutionEntity> captor = ArgumentCaptor.forClass(ExecutionEntity.class)
+
+	@Test
+	public void testPreProcessRequest() {
+		when(mockExecution.getVariable("bpmnRequest")).thenReturn("""
+        {
+				"serviceInstanceID": "NSSI-C-001-HDBNJ-NSSMF-01-A-ZX ",
+				"networkType": "an/cn/tn",
+				"globalSubscriberId": "5GCustomer",
+				"subscriptionServiceType": "5G",
+				"additionalProperties": {
+				"snssaiList": [
+				"001-100001"
+				],
+				"scriptName": "AN1",
+				"nsiInfo": {
+					"nsiId": "NSI-M-001-HDBNJ-NSMF-01-A-ZX",
+					"nsiName": "eMBB-001"
+				},
+				}
+}
+""".replaceAll("\\s+", ""))
+		when(mockExecution.getVariable("mso-request-id")).thenReturn("edb08d97-e0f9-4c71-840a-72080d7be42e")
+		DeAllocateSliceSubnet sliceSubnet = new DeAllocateSliceSubnet()
+		sliceSubnet.preProcessRequest(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(captor.capture() as String, captor.capture())
+		List<ExecutionEntity> values = captor.getAllValues()
+		assertNotNull(values)
+	}
+	
+	@Test
+	void testPrepareInitOperationStatus() {
+		when(mockExecution.getVariable("serviceInstanceId")).thenReturn("54321")
+		when(mockExecution.getVariable("jobId")).thenReturn("54321")
+		when(mockExecution.getVariable("nsiId")).thenReturn("11111")
+		DeAllocateSliceSubnet sliceSubnet = new DeAllocateSliceSubnet()
+		sliceSubnet.prepareInitOperationStatus(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("initResourceOperationStatus"), captor.capture())
+		String res = captor.getValue()
+		assertNotNull(res)
+	}
+
+
+	@Test
+	void testSendSyncResponse() {
+		when(mockExecution.getVariable("jobId")).thenReturn("123456")
+		DeAllocateSliceSubnet sliceSubnet = new DeAllocateSliceSubnet()
+		sliceSubnet.sendSyncResponse(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("sentSyncResponse"), captor.capture())
+		def updateVolumeGroupRequest = captor.getValue()
+		assertEquals(updateVolumeGroupRequest, true)
+	}
+
+}
diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/ModifySliceSubnetTest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/ModifySliceSubnetTest.groovy
new file mode 100644
index 0000000000..b7515a487c
--- /dev/null
+++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/ModifySliceSubnetTest.groovy
@@ -0,0 +1,72 @@
+package org.onap.so.bpmn.infrastructure.scripts
+
+import static org.junit.Assert.*
+
+import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
+import org.junit.Before
+import org.junit.Test
+import org.mockito.ArgumentCaptor
+import org.mockito.Captor
+
+class ModifySliceSubnetTest {
+	@Before
+	void init() throws IOException {
+		super.init("ModifySliceSubnet")
+	}
+
+	@Captor
+	static ArgumentCaptor<ExecutionEntity> captor = ArgumentCaptor.forClass(ExecutionEntity.class)
+
+	@Test
+	public void testPreProcessRequest() {
+		when(mockExecution.getVariable("bpmnRequest")).thenReturn("""
+        {
+				"serviceInstanceID": "NSSI-C-001-HDBNJ-NSSMF-01-A-ZX ",
+				"networkType": "an/cn/tn",
+				"globalSubscriberId": "5GCustomer",
+				"subscriptionServiceType": "5G",
+				"additionalProperties": {
+				"nsiInfo": {
+					"nsiId": "NSI-M-001-HDBNJ-NSMF-01-A-ZX",
+					"nsiName": "eMBB-001"
+				},
+				}
+}
+""".replaceAll("\\s+", ""))
+		when(mockExecution.getVariable("mso-request-id")).thenReturn("edb08d97-e0f9-4c71-840a-72080d7be42e")
+		ModifySliceSubnet sliceSubnet = new ModifySliceSubnet()
+		sliceSubnet.preProcessRequest(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(captor.capture() as String, captor.capture())
+		List<ExecutionEntity> values = captor.getAllValues()
+		assertNotNull(values)
+	}
+	
+	@Test
+	void testPrepareInitOperationStatus() {
+		when(mockExecution.getVariable("serviceInstanceId")).thenReturn("54321")
+		when(mockExecution.getVariable("jobId")).thenReturn("54321")
+		when(mockExecution.getVariable("nsiId")).thenReturn("11111")
+		ModifySliceSubnet sliceSubnet = new ModifySliceSubnet()
+		sliceSubnet.prepareInitOperationStatus(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("initResourceOperationStatus"), captor.capture())
+		String res = captor.getValue()
+		assertNotNull(res)
+	}
+
+
+	@Test
+	void testSendSyncResponse() {
+		when(mockExecution.getVariable("jobId")).thenReturn("123456")
+		ModifySliceSubnet sliceSubnet = new ModifySliceSubnet()
+		sliceSubnet.sendSyncResponse(mockExecution)
+		Mockito.verify(mockExecution, times(1)).setVariable(eq("sentSyncResponse"), captor.capture())
+		def updateVolumeGroupRequest = captor.getValue()
+		assertEquals(updateVolumeGroupRequest, true)
+	}
+
+	@Test
+	public void test() {
+		fail("Not yet implemented")
+	}
+
+}