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.core.json.JsonUtils
34 import org.onap.so.logger.MsoLogger
35 import org.onap.so.rest.APIResponse
37 import static org.apache.commons.lang3.StringUtils.*
40 * This groovy class supports the <class>CreateSDNCCNetworkResource.bpmn</class> process.
41 * flow for SDNC Network Resource Create
43 public class CreateSDNCNetworkResource extends AbstractServiceTaskProcessor {
45 private static final MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.BPEL, CreateSDNCNetworkResource.class);
46 String Prefix="CRESDNCRES_"
48 ExceptionUtil exceptionUtil = new ExceptionUtil()
50 JsonUtils jsonUtil = new JsonUtils()
52 public void preProcessRequest(DelegateExecution execution){
54 msoLogger.info(" ***** Started preProcessRequest *****")
57 //get bpmn inputs from resource request.
58 String requestId = execution.getVariable("mso-request-id")
59 String requestAction = execution.getVariable("requestAction")
60 msoLogger.info("The requestAction is: " + requestAction)
61 String recipeParamsFromRequest = execution.getVariable("recipeParams")
62 msoLogger.info("The recipeParams is: " + recipeParamsFromRequest)
63 String resourceInput = execution.getVariable("resourceInput")
64 msoLogger.info("The resourceInput is: " + resourceInput)
65 //Get ResourceInput Object
66 ResourceInput resourceInputObj = ResourceRequestBuilder.getJsonObject(resourceInput, ResourceInput.class)
67 execution.setVariable(Prefix + "resourceInput", resourceInputObj)
69 //Deal with recipeParams
70 String recipeParamsFromWf = execution.getVariable("recipeParamXsd")
71 String resourceName = resourceInputObj.getResourceInstanceName()
72 //For sdnc requestAction default is "createNetworkInstance"
73 String operationType = "Network"
74 if(!StringUtils.isBlank(recipeParamsFromRequest)){
75 //the operationType from worflow(first node) is second priority.
76 operationType = jsonUtil.getJsonValue(recipeParamsFromRequest, "operationType")
78 if(!StringUtils.isBlank(recipeParamsFromWf)){
79 //the operationType from worflow(first node) is highest priority.
80 operationType = jsonUtil.getJsonValue(recipeParamsFromWf, "operationType")
84 //For sdnc, generate svc_action and request_action
85 String sdnc_svcAction = "create"
86 switch (resourceInputObj.getResourceInstanceName()) {
88 case ~/[\w\s\W]*overlay[\w\s\W]*/ :
89 //This will be resolved in R3.
90 sdnc_svcAction ="activate"
91 operationType = "NCINetwork"
94 case ~/[\w\s\W]*underlay[\w\s\W]*/ :
95 //This will be resolved in R3.
96 operationType ="Network"
99 case ~/[\w\s\W]*SOTNConnectivity[\w\s\W]*/ :
100 operationType = "SOTNConnectivity"
101 execution.setVariable("isActivateRequired", "true")
104 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/ :
105 operationType = "SOTNAttachment"
106 execution.setVariable("isActivateRequired", "true")
109 case ~/[\w\s\W]*SiteVF[\w\s\W]*/ :
110 operationType = "Site"
111 execution.setVariable("isActivateRequired", "true")
114 case ~/[\w\s\W]*deviceVF[\w\s\W]*/ :
115 operationType = "SDWANDevice"
116 execution.setVariable("isActivateRequired", "true")
119 case ~/[\w\s\W]*SiteWANVF[\w\s\W]*/ :
120 operationType = "SDWANPort"
121 execution.setVariable("isActivateRequired", "true")
124 case ~/[\w\s\W]*SDWANConnectivity[\w\s\W]*/ :
125 operationType = "SDWANConnectivity"
126 execution.setVariable("isActivateRequired", "true")
129 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
130 operationType = "SDWANAttachment"
131 execution.setVariable("isActivateRequired", "true")
134 case ~/[\w\s\W]*wanconnection[\w\s\W]*/ :
135 execution.setVariable("isActivateRequired", "true")
142 String sdnc_requestAction = StringUtils.capitalize(sdnc_svcAction) + operationType +"Instance"
143 execution.setVariable(Prefix + "svcAction", sdnc_svcAction)
144 execution.setVariable(Prefix + "requestAction", sdnc_requestAction)
145 execution.setVariable(Prefix + "serviceInstanceId", resourceInputObj.getServiceInstanceId())
146 execution.setVariable("mso-request-id", requestId)
147 execution.setVariable("mso-service-instance-id", resourceInputObj.getServiceInstanceId())
148 } catch (BpmnError e) {
150 } catch (Exception ex){
151 msg = "Exception in preProcessRequest " + ex.getMessage()
153 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
157 String customizeResourceParam(String networkInputParametersJson) {
158 List<Map<String, Object>> paramList = new ArrayList();
159 JSONObject jsonObject = new JSONObject(networkInputParametersJson);
160 Iterator iterator = jsonObject.keys();
161 while (iterator.hasNext()) {
162 String key = iterator.next();
163 HashMap<String, String> hashMap = new HashMap();
164 hashMap.put("name", key);
165 hashMap.put("value", jsonObject.get(key))
166 paramList.add(hashMap)
168 Map<String, List<Map<String, Object>>> paramMap = new HashMap();
169 paramMap.put("param", paramList);
171 return new JSONObject(paramMap).toString();
175 * This method updates the resource input by collecting required info from AAI
178 public void updateResourceInput(DelegateExecution execution) {
179 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
180 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
183 case ~/[\w\s\W]*SOTNConnectivity[\w\s\W]*/:
185 def resourceInput = resourceInputObj.getResourceParameters()
186 String incomingRequest = resourceInputObj.getRequestsInputs()
187 String serviceParameters = JsonUtils.getJsonValue(incomingRequest, "service.parameters")
188 String requestInputs = JsonUtils.getJsonValue(serviceParameters, "requestInputs")
189 JSONObject inputParameters = new JSONObject(requestInputs)
190 if(inputParameters.has("local-access-provider-id")) {
191 String uResourceInput = jsonUtil.addJsonValue(resourceInput, "requestInputs.access-provider-id", inputParameters.get("local-access-provider-id"))
192 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-client-id", inputParameters.get("local-access-client-id"))
193 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-topology-id", inputParameters.get("local-access-topology-id"))
194 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-ltp-id", inputParameters.get("local-access-ltp-id"))
195 uResourceInput = jsonUtil.addJsonValue(uResourceInput, "requestInputs.access-node-id", inputParameters.get("local-access-node-id"))
196 resourceInputObj.setResourceParameters(uResourceInput)
197 execution.setVariable(Prefix + "resourceInput", resourceInputObj)
202 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
203 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/ :
204 // fill attachment TP in networkInputParamJson
205 String customer = resourceInputObj.getGlobalSubscriberId()
206 String serviceType = resourceInputObj.getServiceType()
208 def vpnName = StringUtils.containsIgnoreCase(modelName, "sotnvpnattachment") ? "sotnvpnattachmentvf_sotncondition_sotnVpnName" : "sdwanvpnattachmentvf_sdwancondition_sdwanVpnName"
209 String parentServiceName = jsonUtil.getJsonValueForKey(resourceInputObj.getRequestsInputs(), vpnName)
211 AaiUtil aaiUtil = new AaiUtil(this)
212 String aai_endpoint = execution.getVariable("URN_aai_endpoint")
213 String customerUri = aaiUtil.getBusinessCustomerUri(execution) + "/" + customer
214 String aai_service_query_url = aai_endpoint + customerUri + "/service-subscriptions/service-subscription/" + serviceType + "/service-instances?service-instance-name=" + parentServiceName
216 APIResponse aaiResponse = aaiUtil.executeAAIGetCall(execution, aai_service_query_url)
217 def parentServiceInstanceId = getParentServiceInstnaceId(aaiResponse)
218 execution.setVariable("parentServiceInstanceId", parentServiceInstanceId)
226 private String getParentServiceInstnaceId(APIResponse aaiResponse) {
227 String response = aaiResponse.getResponseBodyAsString()
228 def xmlResp = new XmlParser().parseText(response)
229 return "${xmlResp?."service-instance"[0]?."service-instance-id"[0]?.text()}"
233 * Pre Process the BPMN Flow Request
235 * generate the nsOperationKey
236 * generate the nsParameters
238 public void prepareSDNCRequest (DelegateExecution execution) {
239 msoLogger.info(" ***** Started prepareSDNCRequest *****")
243 String sdnc_svcAction = execution.getVariable(Prefix + "svcAction")
244 String sdnc_requestAction = execution.getVariable(Prefix + "requestAction")
245 String sdncCallback = execution.getVariable("URN_mso_workflow_sdncadapter_callback")
246 String createNetworkInput = execution.getVariable(Prefix + "networkRequest")
248 String parentServiceInstanceId = execution.getVariable("parentServiceInstanceId")
249 String hdrRequestId = execution.getVariable("mso-request-id")
250 String serviceInstanceId = execution.getVariable(Prefix + "serviceInstanceId")
251 String source = execution.getVariable("source")
252 String sdnc_service_id = execution.getVariable(Prefix + "sdncServiceId")
253 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
254 String serviceType = resourceInputObj.getServiceType()
255 String serviceModelInvariantUuid = resourceInputObj.getServiceModelInfo().getModelInvariantUuid()
256 String serviceModelUuid = resourceInputObj.getServiceModelInfo().getModelUuid()
257 String serviceModelVersion = resourceInputObj.getServiceModelInfo().getModelVersion()
258 String serviceModelName = resourceInputObj.getServiceModelInfo().getModelName()
259 String globalCustomerId = resourceInputObj.getGlobalSubscriberId()
260 String modelInvariantUuid = resourceInputObj.getResourceModelInfo().getModelInvariantUuid();
261 String modelCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
262 String modelUuid = resourceInputObj.getResourceModelInfo().getModelUuid()
263 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
264 String modelVersion = resourceInputObj.getResourceModelInfo().getModelVersion()
265 String resourceInputPrameters = resourceInputObj.getResourceParameters()
266 String networkInputParametersJson = jsonUtil.getJsonValue(resourceInputPrameters, "requestInputs")
267 //here convert json string to xml string
268 String netowrkInputParameters = XML.toString(new JSONObject(customizeResourceParam(networkInputParametersJson)))
269 // 1. prepare assign topology via SDNC Adapter SUBFLOW call
270 String sdncTopologyCreateRequest = ""
273 case ~/[\w\s\W]*deviceVF[\w\s\W]*/ :
274 case ~/[\w\s\W]*SiteWANVF[\w\s\W]*/ :
275 case ~/[\w\s\W]*SiteVF[\w\s\W]*/:
276 sdncTopologyCreateRequest = """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.onap/so/workflow/schema/v1"
277 xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1"
278 xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1">
279 <sdncadapter:RequestHeader>
280 <sdncadapter:RequestId>${msoUtils.xmlEncode(hdrRequestId)}</sdncadapter:RequestId>
281 <sdncadapter:SvcInstanceId>${msoUtils.xmlEncode(serviceInstanceId)}</sdncadapter:SvcInstanceId>
282 <sdncadapter:SvcAction>${msoUtils.xmlEncode(sdnc_svcAction)}</sdncadapter:SvcAction>
283 <sdncadapter:SvcOperation>vnf-topology-operation</sdncadapter:SvcOperation>
284 <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
285 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
286 </sdncadapter:RequestHeader>
287 <sdncadapterworkflow:SDNCRequestData>
288 <request-information>
289 <request-id>${msoUtils.xmlEncode(hdrRequestId)}</request-id>
290 <request-action>${msoUtils.xmlEncode(sdnc_requestAction)}</request-action>
291 <source>${msoUtils.xmlEncode(source)}</source>
292 <notification-url></notification-url>
293 <order-number></order-number>
294 <order-version></order-version>
295 </request-information>
296 <service-information>
297 <service-id>${msoUtils.xmlEncode(serviceInstanceId)}</service-id>
298 <subscription-service-type>${msoUtils.xmlEncode(serviceType)}</subscription-service-type>
299 <onap-model-information>
300 <model-invariant-uuid>${msoUtils.xmlEncode(serviceModelInvariantUuid)}</model-invariant-uuid>
301 <model-uuid>${msoUtils.xmlEncode(serviceModelUuid)}</model-uuid>
302 <model-version>${msoUtils.xmlEncode(serviceModelVersion)}</model-version>
303 <model-name>${msoUtils.xmlEncode(serviceModelName)}</model-name>
304 </onap-model-information>
305 <service-instance-id>${msoUtils.xmlEncode(serviceInstanceId)}</service-instance-id>
306 <global-customer-id>${msoUtils.xmlEncode(globalCustomerId)}</global-customer-id>
307 <subscriber-name>${msoUtils.xmlEncode(globalCustomerId)}</subscriber-name>
308 </service-information>
311 <vnf-type></vnf-type>
312 <onap-model-information>
313 <model-invariant-uuid>${msoUtils.xmlEncode(modelInvariantUuid)}</model-invariant-uuid>
314 <model-customization-uuid>${msoUtils.xmlEncode(modelCustomizationUuid)}</model-customization-uuid>
315 <model-uuid>${msoUtils.xmlEncode(modelUuid)}</model-uuid>
316 <model-version>${msoUtils.xmlEncode(modelVersion)}</model-version>
317 <model-name>${msoUtils.xmlEncode(modelName)}</model-name>
318 </onap-model-information>
321 <vnf-input-parameters>
322 $netowrkInputParameters
323 </vnf-input-parameters>
324 <request-version></request-version>
325 <vnf-name></vnf-name>
329 </sdncadapterworkflow:SDNCRequestData>
330 </aetgt:SDNCAdapterWorkflowRequest>""".trim()
333 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
334 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/ :
335 sdncTopologyCreateRequest = """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.onap/so/workflow/schema/v1"
336 xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1"
337 xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1">
338 <sdncadapter:RequestHeader>
339 <sdncadapter:RequestId>${msoUtils.xmlEncode(hdrRequestId)}</sdncadapter:RequestId>
340 <sdncadapter:SvcInstanceId>${msoUtils.xmlEncode(serviceInstanceId)}</sdncadapter:SvcInstanceId>
341 <sdncadapter:SvcAction>${msoUtils.xmlEncode(sdnc_svcAction)}</sdncadapter:SvcAction>
342 <sdncadapter:SvcOperation>connection-attachment-topology-operation</sdncadapter:SvcOperation>
343 <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
344 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
345 </sdncadapter:RequestHeader>
346 <sdncadapterworkflow:SDNCRequestData>
347 <request-information>
348 <request-id>${msoUtils.xmlEncode(hdrRequestId)}</request-id>
349 <request-action>${msoUtils.xmlEncode(sdnc_requestAction)}</request-action>
350 <source>${msoUtils.xmlEncode(source)}</source>
351 <notification-url></notification-url>
352 <order-number></order-number>
353 <order-version></order-version>
354 </request-information>
355 <service-information>
356 <service-id>${msoUtils.xmlEncode(serviceInstanceId)}</service-id>
357 <subscription-service-type>${msoUtils.xmlEncode(serviceType)}</subscription-service-type>
358 <onap-model-information>
359 <model-invariant-uuid>${msoUtils.xmlEncode(serviceModelInvariantUuid)}</model-invariant-uuid>
360 <model-uuid>${msoUtils.xmlEncode(serviceModelUuid)}</model-uuid>
361 <model-version>${msoUtils.xmlEncode(serviceModelVersion)}</model-version>
362 <model-name>${msoUtils.xmlEncode(serviceModelName)}</model-name>
363 </onap-model-information>
364 <service-instance-id>${msoUtils.xmlEncode(serviceInstanceId)}</service-instance-id>
365 <global-customer-id>${msoUtils.xmlEncode(globalCustomerId)}</global-customer-id>
366 <subscriber-name>${msoUtils.xmlEncode(globalCustomerId)}</subscriber-name>
367 </service-information>
368 <allotted-resource-information>
369 <!-- TODO: to be filled as per the request input -->
370 <allotted-resource-id></allotted-resource-id>
371 <allotted-resource-type></allotted-resource-type>
372 <parent-service-instance-id>$parentServiceInstanceId</parent-service-instance-id>
373 <onap-model-information>
374 <model-invariant-uuid>${msoUtils.xmlEncode(modelInvariantUuid)}</model-invariant-uuid>
375 <model-customization-uuid>${msoUtils.xmlEncode(modelCustomizationUuid)}</model-customization-uuid>
376 <model-uuid>${msoUtils.xmlEncode(modelUuid)}</model-uuid>
377 <model-version>${msoUtils.xmlEncode(modelVersion)}</model-version>
378 <model-name>${msoUtils.xmlEncode(modelName)}</model-name>
379 </onap-model-information>
380 </allotted-resource-information>
381 <connection-attachment-request-input>
382 $netowrkInputParameters
383 </connection-attachment-request-input>
384 </sdncadapterworkflow:SDNCRequestData>
385 </aetgt:SDNCAdapterWorkflowRequest>""".trim()
388 // for SDWANConnectivity and SOTNConnectivity:
390 sdncTopologyCreateRequest = """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.onap/so/workflow/schema/v1"
391 xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1"
392 xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1">
393 <sdncadapter:RequestHeader>
394 <sdncadapter:RequestId>${hdrRequestId}</sdncadapter:RequestId>
395 <sdncadapter:SvcInstanceId>${msoUtils.xmlEncode(serviceInstanceId)}</sdncadapter:SvcInstanceId>
396 <sdncadapter:SvcAction>${msoUtils.xmlEncode(sdnc_svcAction)}</sdncadapter:SvcAction>
397 <sdncadapter:SvcOperation>network-topology-operation</sdncadapter:SvcOperation>
398 <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
399 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
400 </sdncadapter:RequestHeader>
401 <sdncadapterworkflow:SDNCRequestData>
402 <request-information>
403 <request-id>${msoUtils.xmlEncode(hdrRequestId)}</request-id>
404 <request-action>${msoUtils.xmlEncode(sdnc_requestAction)}</request-action>
405 <source>${msoUtils.xmlEncode(source)}</source>
406 <notification-url></notification-url>
407 <order-number></order-number>
408 <order-version></order-version>
409 </request-information>
410 <service-information>
411 <service-id>${msoUtils.xmlEncode(serviceInstanceId)}</service-id>
412 <subscription-service-type>${msoUtils.xmlEncode(serviceType)}</subscription-service-type>
413 <onap-model-information>
414 <model-invariant-uuid>${msoUtils.xmlEncode(serviceModelInvariantUuid)}</model-invariant-uuid>
415 <model-uuid>${msoUtils.xmlEncode(serviceModelUuid)}</model-uuid>
416 <model-version>${msoUtils.xmlEncode(serviceModelVersion)}</model-version>
417 <model-name>${msoUtils.xmlEncode(serviceModelName)}</model-name>
418 </onap-model-information>
419 <service-instance-id>${msoUtils.xmlEncode(serviceInstanceId)}</service-instance-id>
420 <global-customer-id>${msoUtils.xmlEncode(globalCustomerId)}</global-customer-id>
421 </service-information>
422 <network-information>
423 <onap-model-information>
424 <model-invariant-uuid>${msoUtils.xmlEncode(modelInvariantUuid)}</model-invariant-uuid>
425 <model-customization-uuid>${msoUtils.xmlEncode(modelCustomizationUuid)}</model-customization-uuid>
426 <model-uuid>${msoUtils.xmlEncode(modelUuid)}</model-uuid>
427 <model-version>${msoUtils.xmlEncode(modelVersion)}</model-version>
428 <model-name>${msoUtils.xmlEncode(modelName)}</model-name>
429 </onap-model-information>
430 </network-information>
431 <network-request-input>
432 <network-input-parameters>$netowrkInputParameters</network-input-parameters>
433 </network-request-input>
434 </sdncadapterworkflow:SDNCRequestData>
435 </aetgt:SDNCAdapterWorkflowRequest>""".trim()
438 String sndcTopologyCreateRequesAsString = utils.formatXml(sdncTopologyCreateRequest)
439 utils.logAudit(sndcTopologyCreateRequesAsString)
440 execution.setVariable("sdncAdapterWorkflowRequest", sndcTopologyCreateRequesAsString)
441 msoLogger.debug("sdncAdapterWorkflowRequest - " + "\n" + sndcTopologyCreateRequesAsString)
443 } catch (Exception ex) {
444 String exceptionMessage = " Bpmn error encountered in CreateSDNCCNetworkResource flow. prepareSDNCRequest() - " + ex.getMessage()
445 msoLogger.debug(exceptionMessage)
446 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)
449 msoLogger.info(" ***** Exit prepareSDNCRequest *****")
452 private void setProgressUpdateVariables(DelegateExecution execution, String body) {
453 def dbAdapterEndpoint = execution.getVariable("URN_mso_adapters_openecomp_db_endpoint")
454 execution.setVariable("CVFMI_dbAdapterEndpoint", dbAdapterEndpoint)
455 execution.setVariable("CVFMI_updateResOperStatusRequest", body)
458 public void prepareUpdateBeforeCreateSDNCResource(DelegateExecution execution) {
459 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
460 String operType = resourceInputObj.getOperationType()
461 String resourceCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
462 String ServiceInstanceId = resourceInputObj.getServiceInstanceId()
463 String operationId = resourceInputObj.getOperationId()
464 String progress = "20"
465 String status = "processing"
466 String statusDescription = "SDCN resource creation invoked"
468 execution.getVariable("operationId")
471 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
472 xmlns:ns="http://org.openecomp.mso/requestsdb">
475 <ns:updateResourceOperationStatus>
476 <operType>${msoUtils.xmlEncode(operType)}</operType>
477 <operationId>${msoUtils.xmlEncode(operationId)}</operationId>
478 <progress>${msoUtils.xmlEncode(progress)}</progress>
479 <resourceTemplateUUID>${msoUtils.xmlEncode(resourceCustomizationUuid)}</resourceTemplateUUID>
480 <serviceId>${msoUtils.xmlEncode(ServiceInstanceId)}</serviceId>
481 <status>${msoUtils.xmlEncode(status)}</status>
482 <statusDescription>${msoUtils.xmlEncode(statusDescription)}</statusDescription>
483 </ns:updateResourceOperationStatus>
485 </soapenv:Envelope>""";
487 setProgressUpdateVariables(execution, body)
491 public void prepareUpdateAfterCreateSDNCResource(execution) {
492 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
493 String operType = resourceInputObj.getOperationType()
494 String resourceCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
495 String ServiceInstanceId = resourceInputObj.getServiceInstanceId()
496 String operationId = resourceInputObj.getOperationId()
497 String progress = "100"
498 String status = "finished"
499 String statusDescription = "SDCN resource creation and activation completed"
501 execution.getVariable("operationId")
504 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
505 xmlns:ns="http://org.openecomp.mso/requestsdb">
508 <ns:updateResourceOperationStatus>
509 <operType>${msoUtils.xmlEncode(operType)}</operType>
510 <operationId>${msoUtils.xmlEncode(operationId)}</operationId>
511 <progress>${msoUtils.xmlEncode(progress)}</progress>
512 <resourceTemplateUUID>${msoUtils.xmlEncode(resourceCustomizationUuid)}</resourceTemplateUUID>
513 <serviceId>${msoUtils.xmlEncode(ServiceInstanceId)}</serviceId>
514 <status>${msoUtils.xmlEncode(status)}</status>
515 <statusDescription>${msoUtils.xmlEncode(statusDescription)}</statusDescription>
516 </ns:updateResourceOperationStatus>
518 </soapenv:Envelope>""";
520 setProgressUpdateVariables(execution, body)
523 public void afterCreateSDNCCall(DelegateExecution execution){
524 msoLogger.info(" ***** Started prepareSDNCRequest *****")
525 String responseCode = execution.getVariable(Prefix + "sdncCreateReturnCode")
526 String responseObj = execution.getVariable(Prefix + "SuccessIndicator")
528 def isActivateRequried = execution.getVariable("isActivateRequired")
529 if (StringUtils.equalsIgnoreCase(isActivateRequried, "true")) {
530 def instnaceId = getInstnaceId(execution)
531 execution.setVariable("networkInstanceId", instnaceId)
534 msoLogger.info("response from sdnc, response code :" + responseCode + " response object :" + responseObj)
535 msoLogger.info(" ***** Exit prepareSDNCRequest *****")
538 private def getInstnaceId(DelegateExecution execution) {
539 def responce = new XmlSlurper().parseText(execution.getVariable("CRENWKI_createSDNCResponse"))
540 def data = responce.toString()
541 data = data.substring(data.indexOf("<"))
543 def resp = new XmlSlurper().parseText(data)
544 ResourceInput resourceInputObj = execution.getVariable(Prefix + "resourceInput")
545 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
549 case ~/[\w\s\W]*SOTNConnectivity[\w\s\W]*/ :
550 case ~/[\w\s\W]*SDWANConnectivity[\w\s\W]*/ :
551 val = resp."network-response-information"."instance-id"
554 case ~/[\w\s\W]*deviceVF[\w\s\W]*/ :
555 case ~/[\w\s\W]*SiteWANVF[\w\s\W]*/ :
556 case ~/[\w\s\W]*Site[\w\s\W]*/:
557 val = resp."vnf-response-information"."instance-id"
560 case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ :
561 case ~/[\w\s\W]*sotnvpnattachment[\w\s\W]*/:
562 val = resp."connection-attachment-response-information"."instance-id"
566 return val.toString()
569 public void sendSyncResponse (DelegateExecution execution) {
570 msoLogger.debug(" *** sendSyncResponse *** ")
573 String operationStatus = "finished"
574 // RESTResponse for main flow
575 String resourceOperationResp = """{"operationStatus":"${operationStatus}"}""".trim()
576 msoLogger.debug(" sendSyncResponse to APIH:" + "\n" + resourceOperationResp)
577 sendWorkflowResponse(execution, 202, resourceOperationResp)
578 execution.setVariable("sentSyncResponse", true)
580 } catch (Exception ex) {
581 String msg = "Exception in sendSyncResponse:" + ex.getMessage()
583 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
585 msoLogger.debug(" ***** Exit sendSyncResponse *****")