2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018 Huawei Technologies Co., Ltd. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.onap.so.bpmn.infrastructure.scripts
23 import org.apache.commons.lang3.*
24 import org.camunda.bpm.engine.delegate.BpmnError
25 import org.camunda.bpm.engine.delegate.DelegateExecution
26 import org.json.JSONObject
28 import org.onap.so.bpmn.common.recipe.ResourceInput
29 import org.onap.so.bpmn.common.resource.ResourceRequestBuilder
30 import org.onap.so.bpmn.common.scripts.AaiUtil
31 import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
32 import org.onap.so.bpmn.common.scripts.ExceptionUtil
33 import org.onap.so.bpmn.common.scripts.MsoUtils
34 import org.onap.so.bpmn.core.json.JsonUtils
35 import org.onap.so.logger.MsoLogger
36 import org.onap.so.rest.APIResponse
38 import static org.apache.commons.lang3.StringUtils.*
41 * This groovy class supports the <class>CreateSDNCCNetworkResource.bpmn</class> process.
42 * flow for SDNC Network Resource Create
44 public class CreateSDNCNetworkResource extends AbstractServiceTaskProcessor {
46 private static final MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.BPEL, CreateSDNCNetworkResource.class);
47 String Prefix="CRESDNCRES_"
49 ExceptionUtil exceptionUtil = new ExceptionUtil()
51 JsonUtils jsonUtil = new JsonUtils()
53 MsoUtils msoUtils = new MsoUtils()
55 public void preProcessRequest(DelegateExecution execution){
57 msoLogger.info(" ***** Started preProcessRequest *****")
60 //get bpmn inputs from resource request.
61 String requestId = execution.getVariable("mso-request-id")
62 String requestAction = execution.getVariable("requestAction")
63 msoLogger.info("The requestAction is: " + requestAction)
64 String recipeParamsFromRequest = execution.getVariable("recipeParams")
65 msoLogger.info("The recipeParams is: " + recipeParamsFromRequest)
66 String resourceInput = execution.getVariable("resourceInput")
67 msoLogger.info("The resourceInput is: " + resourceInput)
68 //Get ResourceInput Object
69 ResourceInput resourceInputObj = ResourceRequestBuilder.getJsonObject(resourceInput, ResourceInput.class)
70 execution.setVariable(Prefix + "resourceInput", resourceInputObj)
72 //Deal with recipeParams
73 String recipeParamsFromWf = execution.getVariable("recipeParamXsd")
74 String resourceName = resourceInputObj.getResourceInstanceName()
75 //For sdnc requestAction default is "createNetworkInstance"
76 String operationType = "Network"
77 if(!StringUtils.isBlank(recipeParamsFromRequest)){
78 //the operationType from worflow(first node) is second priority.
79 operationType = jsonUtil.getJsonValue(recipeParamsFromRequest, "operationType")
81 if(!StringUtils.isBlank(recipeParamsFromWf)){
82 //the operationType from worflow(first node) is highest priority.
83 operationType = jsonUtil.getJsonValue(recipeParamsFromWf, "operationType")
87 //For sdnc, generate svc_action and request_action
88 String sdnc_svcAction = "create"
89 switch (resourceInputObj.getResourceInstanceName()) {
91 case ~/[\w\s\W]*overlay[\w\s\W]*/ :
92 //This will be resolved in R3.
93 sdnc_svcAction ="activate"
94 operationType = "NCINetwork"
97 case ~/[\w\s\W]*underlay[\w\s\W]*/ :
98 //This will be resolved in R3.
99 operationType ="Network"
102 case ~/[\w\s\W]*SOTNConnectivity[\w\s\W]*/ :
103 operationType = "SOTNConnectivity"
104 execution.setVariable("isActivateRequired", "true")
107 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/ :
108 operationType = "SOTNAttachment"
109 execution.setVariable("isActivateRequired", "true")
112 case ~/[\w\s\W]*SiteVF[\w\s\W]*/ :
113 operationType = "Site"
114 execution.setVariable("isActivateRequired", "true")
117 case ~/[\w\s\W]*deviceVF[\w\s\W]*/ :
118 operationType = "SDWANDevice"
119 execution.setVariable("isActivateRequired", "true")
122 case ~/[\w\s\W]*SiteWANVF[\w\s\W]*/ :
123 operationType = "SDWANPort"
124 execution.setVariable("isActivateRequired", "true")
127 case ~/[\w\s\W]*SDWANConnectivity[\w\s\W]*/ :
128 operationType = "SDWANConnectivity"
129 execution.setVariable("isActivateRequired", "true")
132 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
133 operationType = "SDWANAttachment"
134 execution.setVariable("isActivateRequired", "true")
137 case ~/[\w\s\W]*wanconnection[\w\s\W]*/ :
138 execution.setVariable("isActivateRequired", "true")
145 String sdnc_requestAction = StringUtils.capitalize(sdnc_svcAction) + operationType +"Instance"
146 execution.setVariable(Prefix + "svcAction", sdnc_svcAction)
147 execution.setVariable(Prefix + "requestAction", sdnc_requestAction)
148 execution.setVariable(Prefix + "serviceInstanceId", resourceInputObj.getServiceInstanceId())
149 execution.setVariable("mso-request-id", requestId)
150 execution.setVariable("mso-service-instance-id", resourceInputObj.getServiceInstanceId())
151 } catch (BpmnError e) {
153 } catch (Exception ex){
154 msg = "Exception in preProcessRequest " + ex.getMessage()
156 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
160 String customizeResourceParam(String networkInputParametersJson) {
161 List<Map<String, Object>> paramList = new ArrayList();
162 JSONObject jsonObject = new JSONObject(networkInputParametersJson);
163 Iterator iterator = jsonObject.keys();
164 while (iterator.hasNext()) {
165 String key = iterator.next();
166 HashMap<String, String> hashMap = new HashMap();
167 hashMap.put("name", key);
168 hashMap.put("value", jsonObject.get(key))
169 paramList.add(hashMap)
171 Map<String, List<Map<String, Object>>> paramMap = new HashMap();
172 paramMap.put("param", paramList);
174 return new JSONObject(paramMap).toString();
178 * This method updates the resource input by collecting required info from AAI
181 public void updateResourceInput(DelegateExecution execution) {
182 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
183 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
186 case ~/[\w\s\W]*SOTNConnectivity[\w\s\W]*/:
188 def resourceInput = resourceInputObj.getResourceParameters()
189 String incomingRequest = resourceInputObj.getRequestsInputs()
190 String serviceParameters = JsonUtils.getJsonValue(incomingRequest, "service.parameters")
191 String requestInputs = JsonUtils.getJsonValue(serviceParameters, "requestInputs")
192 JSONObject inputParameters = new JSONObject(requestInputs)
193 if(inputParameters.has("local-access-provider-id")) {
194 String uResourceInput = jsonUtil.addJsonValue(resourceInput, "requestInputs.access-provider-id", inputParameters.get("local-access-provider-id"))
195 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-client-id", inputParameters.get("local-access-client-id"))
196 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-topology-id", inputParameters.get("local-access-topology-id"))
197 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-ltp-id", inputParameters.get("local-access-ltp-id"))
198 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-node-id", inputParameters.get("local-access-node-id"))
199 resourceInputObj.setResourceParameters(uResourceInput)
200 execution.setVariable(Prefix + "resourceInput", resourceInputObj)
205 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
206 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/ :
207 // fill attachment TP in networkInputParamJson
208 String customer = resourceInputObj.getGlobalSubscriberId()
209 String serviceType = resourceInputObj.getServiceType()
211 def vpnName = StringUtils.containsIgnoreCase(modelName, "sotnvpnattachment") ? "sotnvpnattachmentvf_sotncondition_sotnVpnName" : "sdwanvpnattachmentvf_sdwancondition_sdwanVpnName"
212 String parentServiceName = jsonUtil.getJsonValueForKey(resourceInputObj.getRequestsInputs(), vpnName)
214 AaiUtil aaiUtil = new AaiUtil(this)
215 String aai_endpoint = execution.getVariable("URN_aai_endpoint")
216 String customerUri = aaiUtil.getBusinessCustomerUri(execution) + "/" + customer
217 String aai_service_query_url = aai_endpoint + customerUri + "/service-subscriptions/service-subscription/" + serviceType + "/service-instances?service-instance-name=" + parentServiceName
219 APIResponse aaiResponse = aaiUtil.executeAAIGetCall(execution, aai_service_query_url)
220 def parentServiceInstanceId = getParentServiceInstnaceId(aaiResponse)
221 execution.setVariable("parentServiceInstanceId", parentServiceInstanceId)
229 private String getParentServiceInstnaceId(APIResponse aaiResponse) {
230 String response = aaiResponse.getResponseBodyAsString()
231 def xmlResp = new XmlParser().parseText(response)
232 return "${xmlResp?."service-instance"[0]?."service-instance-id"[0]?.text()}"
236 * Pre Process the BPMN Flow Request
238 * generate the nsOperationKey
239 * generate the nsParameters
241 public void prepareSDNCRequest (DelegateExecution execution) {
242 msoLogger.info(" ***** Started prepareSDNCRequest *****")
246 String sdnc_svcAction = execution.getVariable(Prefix + "svcAction")
247 String sdnc_requestAction = execution.getVariable(Prefix + "requestAction")
248 String sdncCallback = execution.getVariable("URN_mso_workflow_sdncadapter_callback")
249 String createNetworkInput = execution.getVariable(Prefix + "networkRequest")
251 String parentServiceInstanceId = execution.getVariable("parentServiceInstanceId")
252 String hdrRequestId = execution.getVariable("mso-request-id")
253 String serviceInstanceId = execution.getVariable(Prefix + "serviceInstanceId")
254 String source = execution.getVariable("source")
255 String sdnc_service_id = execution.getVariable(Prefix + "sdncServiceId")
256 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
257 String serviceType = resourceInputObj.getServiceType()
258 String serviceModelInvariantUuid = resourceInputObj.getServiceModelInfo().getModelInvariantUuid()
259 String serviceModelUuid = resourceInputObj.getServiceModelInfo().getModelUuid()
260 String serviceModelVersion = resourceInputObj.getServiceModelInfo().getModelVersion()
261 String serviceModelName = resourceInputObj.getServiceModelInfo().getModelName()
262 String globalCustomerId = resourceInputObj.getGlobalSubscriberId()
263 String modelInvariantUuid = resourceInputObj.getResourceModelInfo().getModelInvariantUuid();
264 String modelCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
265 String modelUuid = resourceInputObj.getResourceModelInfo().getModelUuid()
266 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
267 String modelVersion = resourceInputObj.getResourceModelInfo().getModelVersion()
268 String resourceInputPrameters = resourceInputObj.getResourceParameters()
269 String networkInputParametersJson = jsonUtil.getJsonValue(resourceInputPrameters, "requestInputs")
270 //here convert json string to xml string
271 String netowrkInputParameters = XML.toString(new JSONObject(customizeResourceParam(networkInputParametersJson)))
272 // 1. prepare assign topology via SDNC Adapter SUBFLOW call
273 String sdncTopologyCreateRequest = ""
276 case ~/[\w\s\W]*deviceVF[\w\s\W]*/ :
277 case ~/[\w\s\W]*SiteWANVF[\w\s\W]*/ :
278 case ~/[\w\s\W]*SiteVF[\w\s\W]*/:
279 sdncTopologyCreateRequest = """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.onap/so/workflow/schema/v1"
280 xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1"
281 xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1">
282 <sdncadapter:RequestHeader>
283 <sdncadapter:RequestId>${msoUtils.xmlEscape(hdrRequestId)}</sdncadapter:RequestId>
284 <sdncadapter:SvcInstanceId>${msoUtils.xmlEscape(serviceInstanceId)}</sdncadapter:SvcInstanceId>
285 <sdncadapter:SvcAction>${msoUtils.xmlEscape(sdnc_svcAction)}</sdncadapter:SvcAction>
286 <sdncadapter:SvcOperation>vnf-topology-operation</sdncadapter:SvcOperation>
287 <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
288 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
289 </sdncadapter:RequestHeader>
290 <sdncadapterworkflow:SDNCRequestData>
291 <request-information>
292 <request-id>${msoUtils.xmlEscape(hdrRequestId)}</request-id>
293 <request-action>${msoUtils.xmlEscape(sdnc_requestAction)}</request-action>
294 <source>${msoUtils.xmlEscape(source)}</source>
295 <notification-url></notification-url>
296 <order-number></order-number>
297 <order-version></order-version>
298 </request-information>
299 <service-information>
300 <service-id>${msoUtils.xmlEscape(serviceInstanceId)}</service-id>
301 <subscription-service-type>${msoUtils.xmlEscape(serviceType)}</subscription-service-type>
302 <onap-model-information>
303 <model-invariant-uuid>${msoUtils.xmlEscape(serviceModelInvariantUuid)}</model-invariant-uuid>
304 <model-uuid>${msoUtils.xmlEscape(serviceModelUuid)}</model-uuid>
305 <model-version>${msoUtils.xmlEscape(serviceModelVersion)}</model-version>
306 <model-name>${msoUtils.xmlEscape(serviceModelName)}</model-name>
307 </onap-model-information>
308 <service-instance-id>${msoUtils.xmlEscape(serviceInstanceId)}</service-instance-id>
309 <global-customer-id>${msoUtils.xmlEscape(globalCustomerId)}</global-customer-id>
310 <subscriber-name>${msoUtils.xmlEscape(globalCustomerId)}</subscriber-name>
311 </service-information>
314 <vnf-type></vnf-type>
315 <onap-model-information>
316 <model-invariant-uuid>${msoUtils.xmlEscape(modelInvariantUuid)}</model-invariant-uuid>
317 <model-customization-uuid>${msoUtils.xmlEscape(modelCustomizationUuid)}</model-customization-uuid>
318 <model-uuid>${msoUtils.xmlEscape(modelUuid)}</model-uuid>
319 <model-version>${msoUtils.xmlEscape(modelVersion)}</model-version>
320 <model-name>${msoUtils.xmlEscape(modelName)}</model-name>
321 </onap-model-information>
324 <vnf-input-parameters>
325 $netowrkInputParameters
326 </vnf-input-parameters>
327 <request-version></request-version>
328 <vnf-name></vnf-name>
332 </sdncadapterworkflow:SDNCRequestData>
333 </aetgt:SDNCAdapterWorkflowRequest>""".trim()
336 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
337 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/ :
338 sdncTopologyCreateRequest = """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.onap/so/workflow/schema/v1"
339 xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1"
340 xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1">
341 <sdncadapter:RequestHeader>
342 <sdncadapter:RequestId>${msoUtils.xmlEscape(hdrRequestId)}</sdncadapter:RequestId>
343 <sdncadapter:SvcInstanceId>${msoUtils.xmlEscape(serviceInstanceId)}</sdncadapter:SvcInstanceId>
344 <sdncadapter:SvcAction>${msoUtils.xmlEscape(sdnc_svcAction)}</sdncadapter:SvcAction>
345 <sdncadapter:SvcOperation>connection-attachment-topology-operation</sdncadapter:SvcOperation>
346 <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
347 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
348 </sdncadapter:RequestHeader>
349 <sdncadapterworkflow:SDNCRequestData>
350 <request-information>
351 <request-id>${msoUtils.xmlEscape(hdrRequestId)}</request-id>
352 <request-action>${msoUtils.xmlEscape(sdnc_requestAction)}</request-action>
353 <source>${msoUtils.xmlEscape(source)}</source>
354 <notification-url></notification-url>
355 <order-number></order-number>
356 <order-version></order-version>
357 </request-information>
358 <service-information>
359 <service-id>${msoUtils.xmlEscape(serviceInstanceId)}</service-id>
360 <subscription-service-type>${msoUtils.xmlEscape(serviceType)}</subscription-service-type>
361 <onap-model-information>
362 <model-invariant-uuid>${msoUtils.xmlEscape(serviceModelInvariantUuid)}</model-invariant-uuid>
363 <model-uuid>${msoUtils.xmlEscape(serviceModelUuid)}</model-uuid>
364 <model-version>${msoUtils.xmlEscape(serviceModelVersion)}</model-version>
365 <model-name>${msoUtils.xmlEscape(serviceModelName)}</model-name>
366 </onap-model-information>
367 <service-instance-id>${msoUtils.xmlEscape(serviceInstanceId)}</service-instance-id>
368 <global-customer-id>${msoUtils.xmlEscape(globalCustomerId)}</global-customer-id>
369 <subscriber-name>${msoUtils.xmlEscape(globalCustomerId)}</subscriber-name>
370 </service-information>
371 <allotted-resource-information>
372 <!-- TODO: to be filled as per the request input -->
373 <allotted-resource-id></allotted-resource-id>
374 <allotted-resource-type></allotted-resource-type>
375 <parent-service-instance-id>$parentServiceInstanceId</parent-service-instance-id>
376 <onap-model-information>
377 <model-invariant-uuid>${msoUtils.xmlEscape(modelInvariantUuid)}</model-invariant-uuid>
378 <model-customization-uuid>${msoUtils.xmlEscape(modelCustomizationUuid)}</model-customization-uuid>
379 <model-uuid>${msoUtils.xmlEscape(modelUuid)}</model-uuid>
380 <model-version>${msoUtils.xmlEscape(modelVersion)}</model-version>
381 <model-name>${msoUtils.xmlEscape(modelName)}</model-name>
382 </onap-model-information>
383 </allotted-resource-information>
384 <connection-attachment-request-input>
385 $netowrkInputParameters
386 </connection-attachment-request-input>
387 </sdncadapterworkflow:SDNCRequestData>
388 </aetgt:SDNCAdapterWorkflowRequest>""".trim()
391 // for SDWANConnectivity and SOTNConnectivity:
393 sdncTopologyCreateRequest = """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.onap/so/workflow/schema/v1"
394 xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1"
395 xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1">
396 <sdncadapter:RequestHeader>
397 <sdncadapter:RequestId>${hdrRequestId}</sdncadapter:RequestId>
398 <sdncadapter:SvcInstanceId>${msoUtils.xmlEscape(serviceInstanceId)}</sdncadapter:SvcInstanceId>
399 <sdncadapter:SvcAction>${msoUtils.xmlEscape(sdnc_svcAction)}</sdncadapter:SvcAction>
400 <sdncadapter:SvcOperation>network-topology-operation</sdncadapter:SvcOperation>
401 <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
402 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
403 </sdncadapter:RequestHeader>
404 <sdncadapterworkflow:SDNCRequestData>
405 <request-information>
406 <request-id>${msoUtils.xmlEscape(hdrRequestId)}</request-id>
407 <request-action>${msoUtils.xmlEscape(sdnc_requestAction)}</request-action>
408 <source>${msoUtils.xmlEscape(source)}</source>
409 <notification-url></notification-url>
410 <order-number></order-number>
411 <order-version></order-version>
412 </request-information>
413 <service-information>
414 <service-id>${msoUtils.xmlEscape(serviceInstanceId)}</service-id>
415 <subscription-service-type>${msoUtils.xmlEscape(serviceType)}</subscription-service-type>
416 <onap-model-information>
417 <model-invariant-uuid>${msoUtils.xmlEscape(serviceModelInvariantUuid)}</model-invariant-uuid>
418 <model-uuid>${msoUtils.xmlEscape(serviceModelUuid)}</model-uuid>
419 <model-version>${msoUtils.xmlEscape(serviceModelVersion)}</model-version>
420 <model-name>${msoUtils.xmlEscape(serviceModelName)}</model-name>
421 </onap-model-information>
422 <service-instance-id>${msoUtils.xmlEscape(serviceInstanceId)}</service-instance-id>
423 <global-customer-id>${msoUtils.xmlEscape(globalCustomerId)}</global-customer-id>
424 </service-information>
425 <network-information>
426 <onap-model-information>
427 <model-invariant-uuid>${msoUtils.xmlEscape(modelInvariantUuid)}</model-invariant-uuid>
428 <model-customization-uuid>${msoUtils.xmlEscape(modelCustomizationUuid)}</model-customization-uuid>
429 <model-uuid>${msoUtils.xmlEscape(modelUuid)}</model-uuid>
430 <model-version>${msoUtils.xmlEscape(modelVersion)}</model-version>
431 <model-name>${msoUtils.xmlEscape(modelName)}</model-name>
432 </onap-model-information>
433 </network-information>
434 <network-request-input>
435 <network-input-parameters>$netowrkInputParameters</network-input-parameters>
436 </network-request-input>
437 </sdncadapterworkflow:SDNCRequestData>
438 </aetgt:SDNCAdapterWorkflowRequest>""".trim()
441 String sndcTopologyCreateRequesAsString = utils.formatXml(sdncTopologyCreateRequest)
442 utils.logAudit(sndcTopologyCreateRequesAsString)
443 execution.setVariable("sdncAdapterWorkflowRequest", sndcTopologyCreateRequesAsString)
444 msoLogger.debug("sdncAdapterWorkflowRequest - " + "\n" + sndcTopologyCreateRequesAsString)
446 } catch (Exception ex) {
447 String exceptionMessage = " Bpmn error encountered in CreateSDNCCNetworkResource flow. prepareSDNCRequest() - " + ex.getMessage()
448 msoLogger.debug(exceptionMessage)
449 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)
452 msoLogger.info(" ***** Exit prepareSDNCRequest *****")
455 private void setProgressUpdateVariables(DelegateExecution execution, String body) {
456 def dbAdapterEndpoint = execution.getVariable("URN_mso_adapters_openecomp_db_endpoint")
457 execution.setVariable("CVFMI_dbAdapterEndpoint", dbAdapterEndpoint)
458 execution.setVariable("CVFMI_updateResOperStatusRequest", body)
461 public void prepareUpdateBeforeCreateSDNCResource(DelegateExecution execution) {
462 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
463 String operType = resourceInputObj.getOperationType()
464 String resourceCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
465 String ServiceInstanceId = resourceInputObj.getServiceInstanceId()
466 String operationId = resourceInputObj.getOperationId()
467 String progress = "20"
468 String status = "processing"
469 String statusDescription = "SDCN resource creation invoked"
471 execution.getVariable("operationId")
474 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
475 xmlns:ns="http://org.openecomp.mso/requestsdb">
478 <ns:updateResourceOperationStatus>
479 <operType>${msoUtils.xmlEscape(operType)}</operType>
480 <operationId>${msoUtils.xmlEscape(operationId)}</operationId>
481 <progress>${msoUtils.xmlEscape(progress)}</progress>
482 <resourceTemplateUUID>${msoUtils.xmlEscape(resourceCustomizationUuid)}</resourceTemplateUUID>
483 <serviceId>${msoUtils.xmlEscape(ServiceInstanceId)}</serviceId>
484 <status>${msoUtils.xmlEscape(status)}</status>
485 <statusDescription>${msoUtils.xmlEscape(statusDescription)}</statusDescription>
486 </ns:updateResourceOperationStatus>
488 </soapenv:Envelope>""";
490 setProgressUpdateVariables(execution, body)
494 public void prepareUpdateAfterCreateSDNCResource(execution) {
495 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
496 String operType = resourceInputObj.getOperationType()
497 String resourceCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
498 String ServiceInstanceId = resourceInputObj.getServiceInstanceId()
499 String operationId = resourceInputObj.getOperationId()
500 String progress = "100"
501 String status = "finished"
502 String statusDescription = "SDCN resource creation and activation completed"
504 execution.getVariable("operationId")
507 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
508 xmlns:ns="http://org.openecomp.mso/requestsdb">
511 <ns:updateResourceOperationStatus>
512 <operType>${msoUtils.xmlEscape(operType)}</operType>
513 <operationId>${msoUtils.xmlEscape(operationId)}</operationId>
514 <progress>${msoUtils.xmlEscape(progress)}</progress>
515 <resourceTemplateUUID>${msoUtils.xmlEscape(resourceCustomizationUuid)}</resourceTemplateUUID>
516 <serviceId>${msoUtils.xmlEscape(ServiceInstanceId)}</serviceId>
517 <status>${msoUtils.xmlEscape(status)}</status>
518 <statusDescription>${msoUtils.xmlEscape(statusDescription)}</statusDescription>
519 </ns:updateResourceOperationStatus>
521 </soapenv:Envelope>""";
523 setProgressUpdateVariables(execution, body)
526 public void afterCreateSDNCCall(DelegateExecution execution){
527 msoLogger.info(" ***** Started prepareSDNCRequest *****")
528 String responseCode = execution.getVariable(Prefix + "sdncCreateReturnCode")
529 String responseObj = execution.getVariable(Prefix + "SuccessIndicator")
531 def isActivateRequried = execution.getVariable("isActivateRequired")
532 if (StringUtils.equalsIgnoreCase(isActivateRequried, "true")) {
533 def instnaceId = getInstnaceId(execution)
534 execution.setVariable("networkInstanceId", instnaceId)
537 msoLogger.info("response from sdnc, response code :" + responseCode + " response object :" + responseObj)
538 msoLogger.info(" ***** Exit prepareSDNCRequest *****")
541 private def getInstnaceId(DelegateExecution execution) {
542 def responce = new XmlSlurper().parseText(execution.getVariable("CRENWKI_createSDNCResponse"))
543 def data = responce.toString()
544 data = data.substring(data.indexOf("<"))
546 def resp = new XmlSlurper().parseText(data)
547 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
548 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
552 case ~/[\w\s\W]*SOTNConnectivity[\w\s\W]*/ :
553 case ~/[\w\s\W]*SDWANConnectivity[\w\s\W]*/ :
554 val = resp."network-response-information"."instance-id"
557 case ~/[\w\s\W]*deviceVF[\w\s\W]*/ :
558 case ~/[\w\s\W]*SiteWANVF[\w\s\W]*/ :
559 case ~/[\w\s\W]*Site[\w\s\W]*/:
560 val = resp."vnf-response-information"."instance-id"
563 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
564 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/:
565 val = resp."connection-attachment-response-information"."instance-id"
569 return val.toString()
572 public void sendSyncResponse (DelegateExecution execution) {
573 msoLogger.debug(" *** sendSyncResponse *** ")
576 String operationStatus = "finished"
577 // RESTResponse for main flow
578 String resourceOperationResp = """{"operationStatus":"${operationStatus}"}""".trim()
579 msoLogger.debug(" sendSyncResponse to APIH:" + "\n" + resourceOperationResp)
580 sendWorkflowResponse(execution, 202, resourceOperationResp)
581 execution.setVariable("sentSyncResponse", true)
583 } catch (Exception ex) {
584 String msg = "Exception in sendSyncResponse:" + ex.getMessage()
586 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
588 msoLogger.debug(" ***** Exit sendSyncResponse *****")