Fix issues in AN NSSMF - Allocate workflow

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

diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy
index 1d8de35..da95847 100644 (file)
--- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy
@@ -55,7 +55,7 @@ import org.onap.aai.domain.yang.ServiceInstance
 import org.onap.aai.domain.yang.SliceProfile
 import org.onap.aai.domain.yang.SliceProfiles
 import org.onap.aai.domain.yang.Relationship
-
+import com.google.gson.Gson
 
 class AnNssmfUtils {
 
@@ -193,7 +193,7 @@ public void createSliceProfilesInAai(DelegateExecution execution) {
        ANNF_sliceProfileInstance.setServiceType(serviceType)
        String serviceStatus = "deactivated"
        ANNF_sliceProfileInstance.setOrchestrationStatus(serviceStatus)
-       String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("ranNfSliceProfile"), "pLMNIdList")
+       String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("ranNfSliceProfile"), "plmnIdList")
        ANNF_sliceProfileInstance.setServiceInstanceLocationId(serviceInstanceLocationid)
        String serviceRole = "slice-profile-instance"
        ANNF_sliceProfileInstance.setServiceRole(serviceRole)
@@ -213,7 +213,7 @@ public void createSliceProfilesInAai(DelegateExecution execution) {
        serviceType = jsonUtil.getJsonValue(execution.getVariable("tnFhSliceProfile"), "sST")
        TNFH_sliceProfileInstance.setServiceType(serviceType)
        TNFH_sliceProfileInstance.setOrchestrationStatus(serviceStatus)
-       serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnFhSliceProfile"), "pLMNIdList")
+       serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnFhSliceProfile"), "plmnIdList")
        TNFH_sliceProfileInstance.setServiceInstanceLocationId(serviceInstanceLocationid)
        TNFH_sliceProfileInstance.setServiceRole(serviceRole)
        TNFH_sliceProfileInstance.setEnvironmentContext(snssai)
@@ -230,7 +230,7 @@ public void createSliceProfilesInAai(DelegateExecution execution) {
        serviceType = jsonUtil.getJsonValue(execution.getVariable("tnMhSliceProfile"), "sST")
        TNMH_sliceProfileInstance.setServiceType(serviceType)
        TNMH_sliceProfileInstance.setOrchestrationStatus(serviceStatus)
-       serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnMhSliceProfile"), "pLMNIdList")
+       serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnMhSliceProfile"), "plmnIdList")
        TNMH_sliceProfileInstance.setServiceInstanceLocationId(serviceInstanceLocationid)
        TNMH_sliceProfileInstance.setServiceRole(serviceRole)
        TNMH_sliceProfileInstance.setEnvironmentContext(snssai)
@@ -268,7 +268,7 @@ private SliceProfile createSliceProfile(String domainType, DelegateExecution exe
        Map<String,Object> profile
        switch(domainType) {
                case "AN-NF":
-                       profile = objectMapper.readValue(execution.getVariable("ranNfSliceProfile"), Map.class)//pending fields - maxBandwidth, sST, pLMNIdList, cSReliabilityMeanTime, 
+                       profile = objectMapper.readValue(execution.getVariable("ranNfSliceProfile"), Map.class)//pending fields - maxBandwidth, sST, plmnIdList, cSReliabilityMeanTime, 
                                                                                                                                                                                                        //msgSizeByte, maxNumberofPDUSessions,overallUserDensity,transferIntervalTarget
                        result.setJitter(profile.get("jitter"))
                        result.setLatency(profile.get("latency"))
@@ -286,14 +286,14 @@ private SliceProfile createSliceProfile(String domainType, DelegateExecution exe
                        result.setProfileId(execution.getVariable("ANNF_sliceProfileId"))
                        break
                case "TN-FH":
-                       profile = objectMapper.readValue(execution.getVariable("tnFhSliceProfile"), Map.class) //pending fields - maxBandwidth, sST, pLMNIdList
+                       profile = objectMapper.readValue(execution.getVariable("tnFhSliceProfile"), Map.class) //pending fields - maxBandwidth, sST, plmnIdList
                        result.setJitter(profile.get("jitter"))
                        result.setLatency(profile.get("latency"))
                        result.setResourceSharingLevel(profile.get("resourceSharingLevel"))
                        result.setProfileId(execution.getVariable("TNFH_sliceProfileId"))
                        break
                case "TN-MH":
-                       profile = objectMapper.readValue(execution.getVariable("tnMhSliceProfile"), Map.class)//pending fields - maxBandwidth, sST, pLMNIdList
+                       profile = objectMapper.readValue(execution.getVariable("tnMhSliceProfile"), Map.class)//pending fields - maxBandwidth, sST, plmnIdList
                        result.setJitter(profile.get("jitter"))
                        result.setLatency(profile.get("latency"))
                        result.setResourceSharingLevel(profile.get("resourceSharingLevel"))
@@ -342,16 +342,17 @@ private SliceProfile createSliceProfile(String domainType, DelegateExecution exe
        
        public String buildCreateNSSMFRequest(DelegateExecution execution, String domainType, String action) {
                JsonObject esrInfo = new JsonObject()
-           esrInfo.addProperty("networkType", "tn")
-           esrInfo.addProperty("vendor", "ONAP_internal")
+               esrInfo.addProperty("networkType", "tn")
+               esrInfo.addProperty("vendor", "ONAP_internal")
                JsonObject response = new JsonObject()
                JsonObject allocateTnNssi = new JsonObject()
                JsonObject serviceInfo = new JsonObject()
                JsonArray transportSliceNetworksList  = new JsonArray()
                JsonArray connectionLinksList = new JsonArray()
                JsonObject connectionLinks = new JsonObject()
+               Gson jsonConverter = new Gson()
                if(action.equals("allocate")){
-                       Map<String, String> endpoints
+                       JsonObject endpoints = new JsonObject()
                        if(domainType.equals("TN_FH")) {
                                serviceInfo.addProperty("serviceInvariantUuid", execution.getVariable("TNFH_modelInvariantUuid"))
                                serviceInfo.addProperty("serviceUuid", execution.getVariable("TNFH_modelUuid"))
@@ -359,12 +360,10 @@ private SliceProfile createSliceProfile(String domainType, DelegateExecution exe
                                allocateTnNssi.addProperty("nssiName", execution.getVariable("TNFH_modelName"))
                                Map<String,Object> sliceProfile = objectMapper.readValue(execution.getVariable("tnFhSliceProfile"), Map.class)
                                sliceProfile.put("sliceProfileId", execution.getVariable("TNFH_sliceProfileInstanceId"))
-                               String sliceProfileString = objectMapper.writeValueAsString(sliceProfile)
-                               allocateTnNssi.addProperty("sliceProfile", sliceProfileString)
-                               endpoints.put("transportEndpointA", execution.getVariable("tranportEp_ID_RU"))
-                               endpoints.put("transportEndpointB", execution.getVariable("tranportEp_ID_DUIN"))
-                               String endpointsString = objectMapper.writeValueAsString(endpoints)
-                               connectionLinksList.add(endpointsString)
+                               allocateTnNssi.add("sliceProfile", jsonConverter.toJsonTree(sliceProfile))
+                               endpoints.addProperty("transportEndpointA", execution.getVariable("tranportEp_ID_RU"))
+                               endpoints.addProperty("transportEndpointB", execution.getVariable("tranportEp_ID_DUIN"))
+                               connectionLinksList.add(endpoints)
                        }else if(domainType.equals("TN_MH")) {
                                serviceInfo.addProperty("serviceInvariantUuid", execution.getVariable("TNMH_modelInvariantUuid"))
                                serviceInfo.addProperty("serviceUuid", execution.getVariable("TNMH_modelUuid"))
@@ -372,41 +371,32 @@ private SliceProfile createSliceProfile(String domainType, DelegateExecution exe
                                allocateTnNssi.addProperty("nssiName", execution.getVariable("TNMH_modelName"))
                                Map<String,Object> sliceProfile = objectMapper.readValue(execution.getVariable("tnMhSliceProfile"), Map.class)
                                sliceProfile.put("sliceProfileId", execution.getVariable("TNMH_sliceProfileInstanceId"))
-                               String sliceProfileString = objectMapper.writeValueAsString(sliceProfile)
-                               allocateTnNssi.addProperty("sliceProfile", sliceProfileString)
-                               endpoints.put("transportEndpointA", execution.getVariable("tranportEp_ID_DUEG"))
-                               endpoints.put("transportEndpointB", execution.getVariable("tranportEp_ID_CUIN"))
-                               String endpointsString = objectMapper.writeValueAsString(endpoints)
-                               connectionLinksList.add(endpointsString)
+                               allocateTnNssi.add("sliceProfile", jsonConverter.toJsonTree(sliceProfile))
+                                endpoints.addProperty("transportEndpointA", execution.getVariable("tranportEp_ID_DUEG"))
+                               endpoints.addProperty("transportEndpointB", execution.getVariable("tranportEp_ID_CUIN"))
+                               connectionLinksList.add(endpoints)
                        }
                        
                        //Connection links
                        connectionLinks.add("connectionLinks", connectionLinksList)
                        transportSliceNetworksList.add(connectionLinks)
                        allocateTnNssi.add("transportSliceNetworks", transportSliceNetworksList)
-                       allocateTnNssi.addProperty("nssiId", null)
-                       serviceInfo.addProperty("nssiId", null)
                }else if(action.equals("modify-allocate")) {
                        if(domainType.equals("TN_FH")) {
-                               serviceInfo.addProperty("serviceInvariantUuid", null)
-                               serviceInfo.addProperty("serviceUuid", null)
-                               allocateTnNssi.addProperty("nsstId", null)
                                allocateTnNssi.addProperty("nssiName", execution.getVariable("TNFH_nssiName"))
                                allocateTnNssi.addProperty("sliceProfileId", execution.getVariable("TNFH_sliceProfileInstanceId"))
                                allocateTnNssi.addProperty("nssiId", execution.getVariable("TNFH_NSSI"))
                                serviceInfo.addProperty("nssiId", execution.getVariable("TNFH_NSSI"))
                        }else if(domainType.equals("TN_MH")) {
-                               serviceInfo.addProperty("serviceInvariantUuid", null)
-                               serviceInfo.addProperty("serviceUuid", null)
-                               allocateTnNssi.addProperty("nsstId", null)
                                allocateTnNssi.addProperty("nssiName", execution.getVariable("TNMH_nssiName"))
                                allocateTnNssi.addProperty("sliceProfileId", execution.getVariable("TNMH_sliceProfileInstanceId"))
                                allocateTnNssi.addProperty("nssiId", execution.getVariable("TNMH_NSSI"))
                                serviceInfo.addProperty("nssiId", execution.getVariable("TNMH_NSSI"))
                        }
                }
+               JsonParser parser = new JsonParser()
                String nsiInfo = jsonUtil.getJsonValue(execution.getVariable("sliceParams"), "nsiInfo")
-               allocateTnNssi.addProperty("nsiInfo", nsiInfo)
+               allocateTnNssi.add("nsiInfo",(JsonObject) parser.parse(nsiInfo))
                allocateTnNssi.addProperty("scriptName", "TN1")
                serviceInfo.addProperty("nsiId", execution.getVariable("nsiId"))
                serviceInfo.addProperty("globalSubscriberId", execution.getVariable("globalSubscriberId"))

diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy
index e1719aa..33724bd 100644 (file)
--- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy
@@ -34,6 +34,7 @@ import org.slf4j.LoggerFactory
 import java.util.List
 import static org.apache.commons.lang3.StringUtils.isBlank
 import com.google.gson.JsonObject
+import com.google.gson.Gson
 import com.fasterxml.jackson.databind.ObjectMapper
 import com.google.gson.JsonArray
 import com.google.gson.JsonParser
@@ -98,8 +99,8 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
                                execution.setVariable("sliceProfile", sliceProfile)
                        }
                        String sliceProfileId = jsonUtil.getJsonValue(sliceProfile, "sliceProfileId")
-                       def snssaiList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "sNSSAI"))
-                       def plmnIdList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "pLMNIdList"))
+                       def snssaiList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "snssaiList"))
+                       def plmnIdList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "plmnIdList"))
                        def coverageAreaTAList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "coverageAreaTAList"))
 
                        if (isBlank(sliceProfileId) || (snssaiList.empty) || (plmnIdList.empty)
@@ -577,7 +578,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
        def createSdnrRequest = { DelegateExecution execution ->
                logger.debug(Prefix+"createSdnrRequest method start")
                String callbackUrl = UrnPropertiesReader.getVariable("mso.workflow.message.endpoint") + "/AsyncSdnrResponse/"+execution.getVariable("msoRequestId")
-               String sdnrRequest = buildSdnrAllocateRequest(execution, "allocate", "InstantiateRANSlice", callbackUrl)
+               String sdnrRequest = buildSdnrAllocateRequest(execution, "allocate", "instantiateRANSlice", callbackUrl)
                execution.setVariable("createNSSI_sdnrRequest", sdnrRequest)
                execution.setVariable("createNSSI_timeout", "PT10M")
                execution.setVariable("createNSSI_correlator", execution.getVariable("msoRequestId"))
@@ -697,12 +698,12 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
        }
        
        def createFhAllocateNssiJobQuery = { DelegateExecution execution ->
-               logger.debug(Prefix+"createModifyNssiQueryJobStatus method start")
+               logger.debug(Prefix+"createFhAllocateNssiJobQuery method start")
                createTnAllocateNssiJobQuery(execution, "TN_FH")                
        }
        
        def createMhAllocateNssiJobQuery = { DelegateExecution execution ->
-               logger.debug(Prefix+"createModifyNssiQueryJobStatus method start")
+               logger.debug(Prefix+"createMhAllocateNssiJobQuery method start")
                createTnAllocateNssiJobQuery(execution, "TN_MH")
        }
        
@@ -712,7 +713,6 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
            esrInfo.addProperty("vendor", "ONAP_internal")
                execution.setVariable("esrInfo", esrInfo.toString())
                JsonObject serviceInfo = new JsonObject()
-               serviceInfo.addProperty("nssiId", null)
                serviceInfo.addProperty("nsiId", execution.getVariable("nsiId"))
                String sST = jsonUtil.getJsonValue(execution.getVariable("sliceProfile"), "sST")
                serviceInfo.addProperty("sST", sST)
@@ -736,14 +736,14 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
                logger.debug(Prefix+"processJobStatusRsp method start")
                String jobResponse = execution.getVariable("TNFH_jobResponse")
                logger.debug("Job status response "+jobResponse)
-               String status = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.status")
-               String nssi = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.nssi")
+               String status = jsonUtil.getJsonValue(jobResponse, "status")
+               String nssi = jsonUtil.getJsonValue(jobResponse, "nssiId")
                if(status.equalsIgnoreCase("finished")) {
                        execution.setVariable("TNFH_NSSI", nssi)
                        logger.debug("Job successfully completed ... proceeding with flow for nssi : "+nssi)
                }
                else {
-                       String statusDescription = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.statusDescription")
+                       String statusDescription = jsonUtil.getJsonValue(jobResponse, "statusDescription")
                        logger.error("received failed status from job status query for nssi : "+nssi+" with status description : "+ statusDescription)
                        exceptionUtil.buildAndThrowWorkflowException(execution, 7000,"received failed status from job status query for nssi : "+nssi+" with status description : "+ statusDescription)
                }
@@ -753,14 +753,14 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
                logger.debug(Prefix+"processJobStatusRsp method start")
                String jobResponse = execution.getVariable("TNMH_jobResponse")
                logger.debug("Job status response "+jobResponse)
-               String status = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.status")
-               String nssi = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.nssi")
+               String status = jsonUtil.getJsonValue(jobResponse, "status")
+               String nssi = jsonUtil.getJsonValue(jobResponse, "nssiId")
                if(status.equalsIgnoreCase("finished")) {
                        execution.setVariable("TNMH_NSSI", nssi)
                        logger.debug("Job successfully completed ... proceeding with flow for nssi : "+nssi)
                }
                else {
-                       String statusDescription = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.statusDescription")
+                       String statusDescription = jsonUtil.getJsonValue(jobResponse, "statusDescription")
                        logger.error("received failed status from job status query for nssi : "+nssi+" with status description : "+ statusDescription)
                        exceptionUtil.buildAndThrowWorkflowException(execution, 7000,"received failed status from job status query for nssi : "+nssi+" with status description : "+ statusDescription)
                }
@@ -770,13 +770,13 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
                logger.debug(Prefix+"processJobStatusRsp method start")
                String jobResponse = execution.getVariable("jobResponse")
                logger.debug("Job status response "+jobResponse)
-               String status = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.status")
-               String nssi = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.nssi")
+               String status = jsonUtil.getJsonValue(jobResponse, "status")
+               String nssi = jsonUtil.getJsonValue(jobResponse, "nssiId")
                if(status.equalsIgnoreCase("finished")) {
                        logger.debug("Job successfully completed ... proceeding with flow for nssi : "+nssi)
                }
                else {
-                       String statusDescription = jsonUtil.getJsonValue(jobResponse, "responseDescriptor.statusDescription")
+                       String statusDescription = jsonUtil.getJsonValue(jobResponse, "statusDescription")
                        logger.error("received failed status from job status query for nssi : "+nssi+" with status description : "+ statusDescription)
                        exceptionUtil.buildAndThrowWorkflowException(execution, 7000,"received failed status from job status query for nssi : "+nssi+" with status description : "+ statusDescription)
                }
@@ -899,29 +899,30 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor {
                sliceProfile.put("maxNumberofConns", sliceProfile.get("maxNumberofPDUSessions"))
                sliceProfile.put("uLThptPerSlice", sliceProfile.get("expDataRateUL"))
                sliceProfile.put("dLThptPerSlice", sliceProfile.get("expDataRateDL"))
-               String sliceProfileString = objectMapper.writeValueAsString(sliceProfile)
+
                JsonObject response = new JsonObject()
                JsonObject body = new JsonObject()
                JsonObject input = new JsonObject()
                JsonObject commonHeader = new JsonObject()
                JsonObject payload = new JsonObject()
                JsonObject payloadInput = new JsonObject()
-               commonHeader.addProperty("TimeStamp",new Date(System.currentTimeMillis()).format("yyyy-MM-dd'T'HH:mm:ss.sss", TimeZone.getDefault()))
-               commonHeader.addProperty("APIver", "1.0")
-               commonHeader.addProperty("RequestID", requestId)
-               commonHeader.addProperty("SubRequestID", "1")
-               commonHeader.add("RequestTrack", new JsonObject())
-               commonHeader.add("Flags", new JsonObject())
-               payloadInput.addProperty("sliceProfile", sliceProfileString)
+               commonHeader.addProperty("TimeStamp",new Date(System.currentTimeMillis()).format("yyyy-MM-dd'T'HH:mm:ss.sss'Z'", TimeZone.getDefault()))
+               commonHeader.addProperty("api-ver", "1.0")
+               commonHeader.addProperty("request-id", requestId)
+               commonHeader.addProperty("sub-request-id", "1")
+               commonHeader.add("request-track", new JsonObject())
+               commonHeader.add("flags", new JsonObject())
+               Gson jsonConverter = new Gson() 
+               payloadInput.add("sliceProfile", jsonConverter.toJsonTree(sliceProfile))
                payloadInput.addProperty("RANNSSIId", execution.getVariable("RANServiceInstanceId"))
                payloadInput.addProperty("NSIID", execution.getVariable("nsiId"))
                payloadInput.addProperty("RANNFNSSIId", execution.getVariable("RANNFServiceInstanceId"))
                payloadInput.addProperty("callbackURL", callbackUrl)
                payloadInput.add("additionalproperties", new JsonObject())
                payload.add("input", payloadInput)
-               input.add("CommonHeader", commonHeader)
-               input.addProperty("Action", action)
-               input.addProperty("Payload", payload.toString())
+               input.add("common-header", commonHeader)
+               input.addProperty("action", action)
+               input.addProperty("payload", payload.toString())
                body.add("input", input)
                response.add("body", body)
                response.addProperty("version", "1.0")

diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateAccessNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateAccessNSSI.bpmn
index 9c12200..9b44901 100644 (file)
--- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateAccessNSSI.bpmn
+++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateAccessNSSI.bpmn
@@ -193,7 +193,7 @@ nss.prepareDecomposeService(execution)</bpmn:script>
         <camunda:in source="esrInfo" target="esrInfo" />
         <camunda:in source="serviceInfo" target="serviceInfo" />
         <camunda:in source="TNFH_jobId" target="jobId" />
-        <camunda:out source="jobResponse" target="TNFH_jobResponse" />
+        <camunda:out source="responseDescriptor" target="TNFH_jobResponse" />
         <camunda:in source="responseId" target="responseId" />
         <camunda:in source="job_timeout" target="timeout" />
       </bpmn:extensionElements>
@@ -206,7 +206,7 @@ nss.prepareDecomposeService(execution)</bpmn:script>
         <camunda:in source="esrInfo" target="esrInfo" />
         <camunda:in source="serviceInfo" target="serviceInfo" />
         <camunda:in source="TNMH_jobId" target="jobId" />
-        <camunda:out source="jobResponse" target="TNMH_jobResponse" />
+        <camunda:out source="responseDescriptor" target="TNMH_jobResponse" />
         <camunda:in source="responseId" target="responseId" />
         <camunda:in source="job_timeout" target="timeout" />
       </bpmn:extensionElements>
@@ -318,7 +318,7 @@ nss.prepareModifyAccessNssiInputs(execution)</bpmn:script>
         <camunda:in source="esrInfo" target="esrInfo" />
         <camunda:in source="serviceInfo" target="serviceInfo" />
         <camunda:in source="modifyRanNssiJobId" target="jobId" />
-        <camunda:out source="jobResponse" target="jobResponse" />
+        <camunda:out source="responseDescriptor" target="jobResponse" />
         <camunda:in source="responseId" target="responseId" />
         <camunda:in source="job_timeout" target="timeout" />
       </bpmn:extensionElements>
@@ -435,7 +435,7 @@ nss.updateAaiWithRANInstances(execution)</bpmn:script>
     <bpmn:sequenceFlow id="Flow_1exjm0h" sourceRef="Activity_0pa8al6" targetRef="Event_15zn4zi" />
     <bpmn:sequenceFlow id="Flow_0bd6dhi" sourceRef="Activity_0zn4e4n" targetRef="Activity_0vf28ld" />
     <bpmn:sequenceFlow id="Flow_0kcvava" sourceRef="Activity_0vf28ld" targetRef="Event_0u9308h" />
-    <bpmn:scriptTask id="Activity_0vf28ld" name="update AAI relationships">
+    <bpmn:scriptTask id="Activity_0vf28ld" name="update AAI relationships" scriptFormat="groovy">
       <bpmn:incoming>Flow_0bd6dhi</bpmn:incoming>
       <bpmn:outgoing>Flow_0kcvava</bpmn:outgoing>
       <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.*