bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCreateTnNssiInstance.groovy

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2020 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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.onap.so.bpmn.infrastructure.scripts
  22
  23 import org.camunda.bpm.engine.delegate.BpmnError
  24 import org.camunda.bpm.engine.delegate.DelegateExecution
  25 import org.onap.aai.domain.yang.NetworkPolicy
  26 import org.onap.aai.domain.yang.SliceProfile
  27 import org.onap.aaiclient.client.aai.AAIResourcesClient
  28 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri
  29 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory
  30 import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder
  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.slf4j.Logger
  35 import org.slf4j.LoggerFactory
  36
  37 import static org.apache.commons.lang3.StringUtils.isBlank
  38 import static org.apache.commons.lang3.StringUtils.isNotBlank
  39
  40 class DoCreateTnNssiInstance extends AbstractServiceTaskProcessor {
  41
  42     private static final Logger logger = LoggerFactory.getLogger(DoCreateTnNssiInstance.class);
  43     JsonUtils jsonUtil = new JsonUtils()
  44     TnNssmfUtils tnNssmfUtils = new TnNssmfUtils()
  45     ExceptionUtil exceptionUtil = new ExceptionUtil()
  46     String Prefix = "DCTN_"
  47
  48     void preProcessRequest(DelegateExecution execution) {
  49         String msg = ""
  50         logger.trace("Enter preProcessRequest()")
  51
  52         execution.setVariable("prefix", Prefix)
  53
  54         String modelInvariantUuid = execution.getVariable("modelInvariantUuid")
  55         String modelUuid = execution.getVariable("modelUuid")
  56         //here modelVersion is not set, we use modelUuid to decompose the service.
  57         def isDebugLogEnabled = true
  58         execution.setVariable("isDebugLogEnabled", isDebugLogEnabled)
  59         String serviceModelInfo = """{
  60             "modelInvariantUuid":"${modelInvariantUuid}",
  61             "modelUuid":"${modelUuid}",
  62             "modelVersion":""
  63              }"""
  64         execution.setVariable("serviceModelInfo", serviceModelInfo)
  65
  66         if (isBlank(execution.getVariable("enableSdnc"))) {
  67             tnNssmfUtils.setEnableSdncConfig(execution)
  68         }
  69
  70         logger.trace("Exit preProcessRequest")
  71     }
  72
  73
  74     void createSliceProfile(DelegateExecution execution) {
  75
  76         String ssInstanceId = execution.getVariable("sliceServiceInstanceId")
  77         String sliceProfileStr = execution.getVariable("sliceProfile")
  78         String sliceProfileId = UUID.randomUUID().toString()
  79         SliceProfile sliceProfile = new SliceProfile();
  80         sliceProfile.setProfileId(sliceProfileId)
  81         sliceProfile.setLatency(Integer.parseInt(jsonUtil.getJsonValue(sliceProfileStr, "latency")))
  82         sliceProfile.setResourceSharingLevel(jsonUtil.getJsonValue(sliceProfileStr, "resourceSharingLevel"))
  83         //sliceProfile.setSNssai(tnNssmfUtils.getFirstSnssaiFromSliceProfile(sliceProfileStr))
  84
  85         sliceProfile.setMaxBandwidth(Integer.parseInt(jsonUtil.getJsonValue(sliceProfileStr, "maxBandwidth")))
  86
  87         //sliceProfile.setReliability(new Object())
  88         try {
  89             AAIResourcesClient client = getAAIClient()
  90             AAIResourceUri uri =
  91                     AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business()
  92                             .customer(execution.getVariable("globalSubscriberId"))
  93                             .serviceSubscription(execution.getVariable("subscriptionServiceType"))
  94                             .serviceInstance(ssInstanceId)
  95                             .sliceProfile(sliceProfileId))
  96             client.create(uri, sliceProfile)
  97
  98         } catch (BpmnError e) {
  99             throw e
 100         } catch (Exception ex) {
 101             String msg = "Exception in DoCreateSliceServiceInstance.instantiateSliceService. " + ex.getMessage()
 102             logger.info(msg)
 103             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 104         }
 105     }
 106
 107
 108     void createServiceInstance(DelegateExecution execution) {
 109
 110         String serviceRole = "nssi"
 111         String serviceType = execution.getVariable("subscriptionServiceType")
 112         String ssInstanceId = execution.getVariable("sliceServiceInstanceId")
 113         String sliceProfileStr = execution.getVariable("sliceProfile")
 114         String sst = execution.getVariable("sst")
 115         try {
 116             if (sliceProfileStr == null || sliceProfileStr.isEmpty()) {
 117                 String msg = "ERROR: createServiceInstance: sliceProfile is null"
 118                 logger.error(msg)
 119                 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 120             }
 121
 122             org.onap.aai.domain.yang.ServiceInstance ss = new org.onap.aai.domain.yang.ServiceInstance()
 123             ss.setServiceInstanceId(ssInstanceId)
 124             String sliceInstanceName = execution.getVariable("sliceServiceInstanceName")
 125             if (isBlank(sliceInstanceName)) {
 126                 logger.error("ERROR: createServiceInstance: sliceInstanceName is null")
 127                 sliceInstanceName = ssInstanceId
 128             }
 129             ss.setServiceInstanceName(sliceInstanceName)
 130             ss.setServiceType(sst)
 131             String serviceStatus = "deactivated"
 132             ss.setOrchestrationStatus(serviceStatus)
 133             String modelInvariantUuid = execution.getVariable("modelInvariantUuid")
 134             String modelUuid = execution.getVariable("modelUuid")
 135             ss.setModelInvariantId(modelInvariantUuid)
 136             ss.setModelVersionId(modelUuid)
 137             String serviceInstanceLocationId = tnNssmfUtils.getFirstPlmnIdFromSliceProfile(sliceProfileStr)
 138             ss.setServiceInstanceLocationId(serviceInstanceLocationId)
 139             String snssai = tnNssmfUtils.getFirstSnssaiFromSliceProfile(sliceProfileStr)
 140             //ss.setEnvironmentContext(snssai)
 141             ss.setEnvironmentContext("tn")
 142             ss.setServiceRole(serviceRole)
 143
 144             String domainTypeStr = jsonUtil.getJsonValue(sliceProfileStr, "domainType")
 145             if (isNotBlank(domainTypeStr)) {
 146                 ss.setWorkloadContext(domainTypeStr)
 147             }
 148
 149             AAIResourcesClient client = getAAIClient()
 150             AAIResourceUri uri =
 151                     AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business()
 152                             .customer(execution.getVariable("globalSubscriberId"))
 153                             .serviceSubscription(execution.getVariable("subscriptionServiceType"))
 154                             .serviceInstance(ssInstanceId))
 155             client.create(uri, ss)
 156         } catch (BpmnError e) {
 157             throw e
 158         } catch (Exception ex) {
 159             String msg = "Exception in DoCreateTnNssiInstance.createServiceInstance: " + ex.getMessage()
 160             logger.error(msg)
 161             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 162         }
 163     }
 164
 165
 166     void createAllottedResource(DelegateExecution execution) {
 167         String ssInstanceId = execution.getVariable('sliceServiceInstanceId')
 168
 169         try {
 170             List<String> networkStrList = jsonUtil.StringArrayToList(execution.getVariable("transportSliceNetworks"))
 171
 172             for (String networkStr : networkStrList) {
 173                 String allottedResourceId = UUID.randomUUID().toString()
 174                 AAIResourceUri allottedResourceUri =
 175                         AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business()
 176                                 .customer(execution.getVariable("globalSubscriberId"))
 177                                 .serviceSubscription(execution.getVariable("subscriptionServiceType"))
 178                                 .serviceInstance(execution.getVariable("sliceServiceInstanceId"))
 179                                 .allottedResource(allottedResourceId))
 180                 execution.setVariable("allottedResourceUri", allottedResourceUri)
 181                 String modelInvariantId = execution.getVariable("modelInvariantUuid")
 182                 String modelVersionId = execution.getVariable("modelUuid")
 183
 184                 org.onap.aai.domain.yang.AllottedResource resource = new org.onap.aai.domain.yang.AllottedResource()
 185                 resource.setId(allottedResourceId)
 186                 resource.setType("TsciNetwork")
 187                 resource.setAllottedResourceName("network_" + execution.getVariable("sliceServiceInstanceName"))
 188                 getAAIClient().create(allottedResourceUri, resource)
 189
 190                 createNetworkPolicyForAllocatedResource(execution, ssInstanceId, allottedResourceId)
 191
 192                 String linkArrayStr = jsonUtil.getJsonValue(networkStr, "connectionLinks")
 193                 createLogicalLinksForAllocatedResource(execution, linkArrayStr, ssInstanceId, allottedResourceId)
 194             }
 195         } catch (BpmnError e) {
 196             throw e
 197         } catch (Exception ex) {
 198             String msg = "Exception in DoCreateTnNssiInstance.createAllottedResource: " + ex.getMessage()
 199             logger.error(msg)
 200             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 201         }
 202     }
 203
 204     void createNetworkPolicy(DelegateExecution execution, String ssInstanceId, String networkPolicyId) {
 205         try {
 206
 207             String sliceProfileStr = execution.getVariable("sliceProfile")
 208             if (sliceProfileStr == null || sliceProfileStr.isEmpty()) {
 209                 String msg = "ERROR: createNetworkPolicy: sliceProfile is null"
 210                 logger.error(msg)
 211                 exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 212             }
 213
 214             NetworkPolicy networkPolicy = new NetworkPolicy();
 215             networkPolicy.setNetworkPolicyId(networkPolicyId)
 216             networkPolicy.setName("TSCi policy")
 217             networkPolicy.setType("SLA")
 218             networkPolicy.setNetworkPolicyFqdn(ssInstanceId)
 219
 220             String latencyStr = jsonUtil.getJsonValue(sliceProfileStr, "latency")
 221             if (latencyStr != null && !latencyStr.isEmpty()) {
 222                 networkPolicy.setLatency(Integer.parseInt(latencyStr))
 223             }
 224
 225             String bwStr = jsonUtil.getJsonValue(sliceProfileStr, "maxBandwidth")
 226             if (bwStr != null && !bwStr.isEmpty()) {
 227                 networkPolicy.setMaxBandwidth(Integer.parseInt(bwStr))
 228             } else {
 229                 logger.debug("ERROR: createNetworkPolicy: maxBandwidth is null")
 230             }
 231
 232             //networkPolicy.setReliability(new Object())
 233
 234             AAIResourceUri networkPolicyUri =
 235                     AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().networkPolicy(networkPolicyId))
 236             getAAIClient().create(networkPolicyUri, networkPolicy)
 237
 238         } catch (BpmnError e) {
 239             throw e
 240         } catch (Exception ex) {
 241             String msg = "Exception in DoCreateSliceServiceInstance.instantiateSliceService. " + ex.getMessage()
 242             logger.error(msg)
 243             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 244         }
 245     }
 246
 247     void createNetworkPolicyForAllocatedResource(DelegateExecution execution,
 248                                                  String ssInstanceId,
 249                                                  String allottedResourceId) {
 250         try {
 251             AAIResourceUri allottedResourceUri =
 252                     AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business()
 253                             .customer(execution.getVariable("globalSubscriberId"))
 254                             .serviceSubscription(execution.getVariable("subscriptionServiceType"))
 255                             .serviceInstance(ssInstanceId)
 256                             .allottedResource(allottedResourceId))
 257
 258             if (!getAAIClient().exists(allottedResourceUri)) {
 259                 logger.info("ERROR: createLogicalLinksForAllocatedResource: allottedResource not exist: uri={}",
 260                         allottedResourceUri)
 261                 return
 262             }
 263
 264             String networkPolicyId = UUID.randomUUID().toString()
 265             createNetworkPolicy(execution, ssInstanceId, networkPolicyId)
 266
 267             tnNssmfUtils.attachNetworkPolicyToAllottedResource(execution, tnNssmfUtils.AAI_VERSION,
 268                     allottedResourceUri,
 269                     networkPolicyId);
 270
 271         } catch (BpmnError e) {
 272             throw e
 273         } catch (Exception ex) {
 274             String msg = "Exception in DoCreateSliceServiceInstance.instantiateSliceService. " + ex.getMessage()
 275             logger.error(msg)
 276             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 277         }
 278     }
 279
 280     void createLogicalLinksForAllocatedResource(DelegateExecution execution,
 281                                                 String linkArrayStr, String ssInstanceId,
 282                                                 String allottedResourceId) {
 283         try {
 284             AAIResourceUri allottedResourceUri =
 285                     AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business()
 286                             .customer(execution.getVariable("globalSubscriberId"))
 287                             .serviceSubscription(execution.getVariable("subscriptionServiceType"))
 288                             .serviceInstance(ssInstanceId)
 289                             .allottedResource(allottedResourceId))
 290
 291             if (!getAAIClient().exists(allottedResourceUri)) {
 292                 logger.info("ERROR: createLogicalLinksForAllocatedResource: allottedResource not exist: uri={}",
 293                         allottedResourceUri)
 294                 return
 295             }
 296
 297             List<String> linkStrList = jsonUtil.StringArrayToList(linkArrayStr)
 298
 299             for (String linkStr : linkStrList) {
 300                 String linkId = jsonUtil.getJsonValue(linkStr, "name")
 301                 if (isBlank(linkId)) {
 302                     linkId = "tn-nssmf-" + UUID.randomUUID().toString()
 303                 }
 304                 logger.debug("createLogicalLinksForAllocatedResource: linkId=" + linkId)
 305
 306                 String epA = jsonUtil.getJsonValue(linkStr, "transportEndpointA")
 307                 String epB = jsonUtil.getJsonValue(linkStr, "transportEndpointB")
 308                 String modelInvariantId = execution.getVariable("modelInvariantUuid")
 309                 String modelVersionId = execution.getVariable("modelUuid")
 310
 311                 org.onap.aai.domain.yang.LogicalLink resource = new org.onap.aai.domain.yang.LogicalLink()
 312                 resource.setLinkId(linkId)
 313                 resource.setLinkName(epA)
 314                 resource.setLinkName2(epB)
 315                 resource.setLinkType("TsciConnectionLink")
 316                 resource.setInMaint(false)
 317
 318                 //epA is link-name
 319                 AAIResourceUri logicalLinkUri =
 320                         AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().logicalLink(epA))
 321                 getAAIClient().create(logicalLinkUri, resource)
 322
 323                 tnNssmfUtils.attachLogicalLinkToAllottedResource(execution, tnNssmfUtils.AAI_VERSION,
 324                         allottedResourceUri, epA);
 325             }
 326         } catch (BpmnError e) {
 327             throw e
 328         } catch (Exception ex) {
 329             String msg = "Exception in DoCreateTnNssiInstance.createLogicalLinksForAllocatedResource: " + ex.getMessage()
 330             logger.error(msg)
 331             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 332         }
 333     }
 334
 335     void preprocessSdncAllocateTnNssiRequest(DelegateExecution execution) {
 336         def method = getClass().getSimpleName() + '.preProcessSDNCActivateRequest(' +
 337                 'execution=' + execution.getId() +
 338                 ')'
 339         def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
 340         logger.trace('Entered ' + method)
 341
 342         logger.trace("STARTED preProcessSDNCActivateRequest Process")
 343         try {
 344             String serviceInstanceId = execution.getVariable("sliceServiceInstanceId")
 345
 346             String createSDNCRequest = tnNssmfUtils.buildSDNCRequest(execution, serviceInstanceId, "create")
 347
 348             execution.setVariable("TNNSSMF_SDNCRequest", createSDNCRequest)
 349             logger.debug("Outgoing SDNCRequest is: \n" + createSDNCRequest)
 350
 351         } catch (Exception e) {
 352             logger.debug("Exception Occured Processing preProcessSDNCActivateRequest. Exception is:\n" + e)
 353             exceptionUtil.buildAndThrowWorkflowException(execution, 1002,
 354                     "Error Occured during  preProcessSDNCActivateRequest Method:\n" + e.getMessage())
 355         }
 356         logger.trace("COMPLETED  preProcessSDNCActivateRequest Process")
 357     }
 358
 359
 360     void validateSDNCResponse(DelegateExecution execution, String response, String method) {
 361         tnNssmfUtils.validateSDNCResponse(execution, response, method)
 362     }
 363 }