/*- * ============LICENSE_START======================================================= * ONAP - SO * ================================================================================ * Copyright (C) 2020 Tech Mahindra * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * ============LICENSE_END========================================================= */ package org.onap.so.bpmn.infrastructure.scripts import javax.ws.rs.NotFoundException import javax.ws.rs.core.Response import org.camunda.bpm.engine.delegate.BpmnError import org.camunda.bpm.engine.delegate.DelegateExecution import org.onap.aai.domain.yang.GenericVnf import org.onap.aai.domain.yang.RelatedToProperty import org.onap.aai.domain.yang.Relationship import org.onap.aai.domain.yang.RelationshipData import org.onap.aai.domain.yang.ServiceInstance import org.onap.aaiclient.client.aai.AAIObjectName import org.onap.aaiclient.client.aai.entities.AAIResultWrapper import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.Types import org.onap.logging.filter.base.ONAPComponents import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor import org.onap.so.bpmn.common.scripts.CatalogDbUtils import org.onap.so.bpmn.common.scripts.CatalogDbUtilsFactory import org.onap.so.bpmn.common.scripts.ExceptionUtil import org.onap.so.bpmn.common.scripts.RequestDBUtil import org.onap.so.bpmn.core.UrnPropertiesReader import org.onap.so.bpmn.core.json.JsonUtils import org.onap.so.client.HttpClient import org.onap.so.db.request.beans.ResourceOperationStatus import org.onap.so.serviceinstancebeans.CloudConfiguration import org.onap.so.serviceinstancebeans.LineOfBusiness import org.onap.so.serviceinstancebeans.ModelInfo import org.onap.so.serviceinstancebeans.ModelType import org.onap.so.serviceinstancebeans.OwningEntity import org.onap.so.serviceinstancebeans.Platform import org.onap.so.serviceinstancebeans.Project import org.onap.so.serviceinstancebeans.RequestDetails import org.onap.so.serviceinstancebeans.RequestInfo import org.onap.so.serviceinstancebeans.RequestParameters import org.onap.so.serviceinstancebeans.SubscriberInfo import org.slf4j.Logger import org.slf4j.LoggerFactory import com.fasterxml.jackson.databind.ObjectMapper class DoActivateCoreNSSI extends AbstractServiceTaskProcessor { String Prefix="DACTCNSSI_" private static final Logger logger = LoggerFactory.getLogger(DoActivateCoreNSSI.class); CatalogDbUtils catalogDbUtils = new CatalogDbUtilsFactory().create() private RequestDBUtil requestDBUtil = new RequestDBUtil() ExceptionUtil exceptionUtil = new ExceptionUtil() ObjectMapper mapper = new ObjectMapper(); JsonUtils jsonUtil = new JsonUtils() private final Long TIMEOUT = 60 * 60 * 1000 @Override public void preProcessRequest(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: preProcessRequest ****") String operationType = execution.getVariable("operationType") String oStatus= "" if(operationType.equals("activateInstance")) { oStatus ="activated" } else { oStatus ="deactivated" } execution.setVariable("oStatus", oStatus) String sNssaiListAsString = jsonUtil.getJsonValue(execution.getVariable("sliceParams"), "snssaiList") List sNssaiList = jsonUtil.StringArrayToList(sNssaiListAsString) String sNssai = sNssaiList.get(0) execution.setVariable("sNssai", sNssai) String serviceType = execution.getVariable("subscriptionServiceType") execution.setVariable("serviceType", serviceType) logger.debug("operationType: {} , sNssai: {}, serviceType: {}.",operationType, sNssai, serviceType) logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: preProcessRequest ****") } public void getNetworkInstanceWithSPInstanceAssociatedWithNssiId(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: getNetworkInstanceWithSPInstanceAssociatedWithNssiId ****") //NSSI Id as service Instance Id to get from Request String serviceInstanceId = execution.getVariable("serviceInstanceID") String errorMsg = "query Network Service Instance from AAI failed" AAIResultWrapper wrapper = queryAAI(execution, Types.SERVICE_INSTANCE, serviceInstanceId, errorMsg) Optional nsi = wrapper.asBean(ServiceInstance.class) String networkServiceInstanceName = "" String networkServiceInstanceId ="" if(nsi.isPresent()) { List relationshipList = nsi.get().getRelationshipList()?.getRelationship() List spiWithsNssaiAndOrchStatusList = new ArrayList<>() for (Relationship relationship : relationshipList) { String relatedTo = relationship.getRelatedTo() if ("service-instance".equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() List relatedToPropertyList = relationship.getRelatedToProperty() for (RelationshipData relationshipData : relationshipDataList) { if ("service-instance.service-instance-id".equals(relationshipData.getRelationshipKey())) { //Query Every related Service Instance From AAI by service Instance ID AAIResultWrapper instanceWrapper = queryAAI(execution, Types.SERVICE_INSTANCE, relationshipData.getRelationshipValue(), "No Instance Present") Optional relatedServiceInstance = instanceWrapper.asBean(ServiceInstance.class) if (relatedServiceInstance.isPresent()) { ServiceInstance relatedServiceInstanceObj = relatedServiceInstance.get() String role = relatedServiceInstanceObj.getServiceRole(); if(role == null || role.isEmpty()) { networkServiceInstanceId = relatedServiceInstanceObj.getServiceInstanceId() networkServiceInstanceName = relatedServiceInstanceObj.getServiceInstanceName() logger.debug("networkServiceInstanceId: {} networkServiceInstanceName: {} ",networkServiceInstanceId, networkServiceInstanceName) execution.setVariable("networkServiceInstanceId", networkServiceInstanceId) execution.setVariable("networkServiceInstanceName", networkServiceInstanceName) } else if("slice-profile".equals(role)) { String orchestrationStatus= relatedServiceInstanceObj.getOrchestrationStatus() String sNssai = relatedServiceInstanceObj.getEnvironmentContext() if(sNssai.equals(execution.getVariable("sNssai"))) { orchestrationStatus = execution.getVariable("oStatus") //Slice Profile Service Instance to be updated in AAI execution.setVariable("sliceProfileServiceInstance", relatedServiceInstanceObj) } Map spiWithsNssaiAndOrchStatus = new LinkedHashMap<>() spiWithsNssaiAndOrchStatus.put("snssai", sNssai) spiWithsNssaiAndOrchStatus.put("status", orchestrationStatus) spiWithsNssaiAndOrchStatusList.add(spiWithsNssaiAndOrchStatus) logger.debug("service Profile's NSSAI And Orchestration Status: "+spiWithsNssaiAndOrchStatus) } } } } } } execution.setVariable("snssaiAndOrchStatusList", spiWithsNssaiAndOrchStatusList) } logger.debug("NSSI Id: ${serviceInstanceId}, network Service Instance Id: ${networkServiceInstanceId}, serviceName: ${networkServiceInstanceName}") //Get ServiceInstance Relationships getServiceInstanceRelationships(execution) //Get Vnf Relationships getVnfRelationships(execution) logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: getNetworkInstanceWithSPInstanceAssociatedWithNssiId ****") } private String prepareVnfInstanceParamsJson(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: prepareVnfInstanceParamsJson ****") List instanceParamsvalues = execution.getVariable("snssaiAndOrchStatusList") Map nSsai= new LinkedHashMap<>() nSsai.put("sNssai", instanceParamsvalues) String supportedsNssaiJson = mapper.writeValueAsString(nSsai) logger.debug(Prefix+" **** Exit DoActivateCoreNSSI ::: prepareVnfInstanceParamsJson ****") return supportedsNssaiJson } private void getServiceInstanceRelationships(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: getServiceInstanceRelationships ****") String serviceInstanceId = execution.getVariable("networkServiceInstanceId") String errorMsg = "query Network Service Instance from AAI failed" AAIResultWrapper wrapper = queryAAI(execution, Types.SERVICE_INSTANCE, serviceInstanceId, errorMsg) Optional si = wrapper.asBean(ServiceInstance.class) String networkServiceModelInvariantUuid = si.get().getModelInvariantId() execution.setVariable("networkServiceModelInvariantUuid", networkServiceModelInvariantUuid) if(si.isPresent()) { List relationshipList = si.get().getRelationshipList()?.getRelationship() for (Relationship relationship : relationshipList) { String relatedTo = relationship.getRelatedTo() if (("owning-entity").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() for (RelationshipData relationshipData : relationshipDataList) { if (("owning-entity.owning-entity-id").equals(relationshipData.getRelationshipKey())) { execution.setVariable("owningEntityId", relationshipData.getRelationshipValue()) } } } else if (("generic-vnf").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() List relatedToPropertyList = relationship.getRelatedToProperty() //Get VnfId for (RelationshipData relationshipData : relationshipDataList) { if (("generic-vnf.vnf-id").equals(relationshipData.getRelationshipKey())) { execution.setVariable("vnfId", relationshipData.getRelationshipValue()) } } //Get Vnf Name Check If necessary for (RelatedToProperty relatedToProperty : relatedToPropertyList) { if (("generic-vnf.vnf-name").equals(relatedToProperty.getPropertyKey())) { execution.setVariable("vnfName", relatedToProperty.getPropertyValue()) } } } else if (("project").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() for (RelationshipData relationshipData : relationshipDataList) { if (("project.project-name").equals(relationshipData.getRelationshipKey())) { execution.setVariable("projectName", relationshipData.getRelationshipValue()) } } } } logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: getServiceInstanceRelationships ****") } } private void getVnfRelationships(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: getVnfRelationships ****") String msg = "query Generic Vnf from AAI failed" try { AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().genericVnf(execution.getVariable('vnfId'))) if (!getAAIClient().exists(uri)) { exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) } AAIResultWrapper wrapper = getAAIClient().get(uri, NotFoundException.class) Optional vnf = wrapper.asBean(GenericVnf.class) if(vnf.isPresent()) { List relationshipList = vnf.get().getRelationshipList()?.getRelationship() for (Relationship relationship : relationshipList) { String relatedTo = relationship.getRelatedTo() if (("tenant").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() for (RelationshipData relationshipData : relationshipDataList) { if (("tenant.tenant-id").equals(relationshipData.getRelationshipKey())) { execution.setVariable("tenantId", relationshipData.getRelationshipValue()) } } } else if (("cloud-region").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() for (RelationshipData relationshipData : relationshipDataList) { if (("cloud-region.cloud-owner").equals(relationshipData.getRelationshipKey())) { execution.setVariable("cloudOwner", relationshipData.getRelationshipValue()) } else if (("cloud-region.cloud-region-id").equals(relationshipData.getRelationshipKey())) { execution.setVariable("lcpCloudRegionId", relationshipData.getRelationshipValue()) } } } else if (("platform").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() for (RelationshipData relationshipData : relationshipDataList) { if (("platform.platform-name").equals(relationshipData.getRelationshipKey())) { execution.setVariable("platformName", relationshipData.getRelationshipValue()) } } } else if (("line-of-business").equals(relatedTo)) { List relationshipDataList = relationship.getRelationshipData() for (RelationshipData relationshipData : relationshipDataList) { if (("line-of-business.line-of-business-name").equals(relationshipData.getRelationshipKey())) { execution.setVariable("lineOfBusinessName", relationshipData.getRelationshipValue()) } } } } } } catch(BpmnError e){ throw e } catch (Exception ex){ msg = "Exception in getVnfRelationships " + ex.getMessage() logger.debug(msg) exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: getVnfRelationships ****") } /** * query AAI * @param execution * @param aaiObjectType * @param instanceId * @return AAIResultWrapper */ private AAIResultWrapper queryAAI(DelegateExecution execution, AAIObjectName aaiObjectName, String instanceId, String errorMsg) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: queryAAI ****") String globalSubscriberId = execution.getVariable("globalSubscriberId") String serviceType = execution.getVariable("serviceType") AAIResourceUri resourceUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer(globalSubscriberId).serviceSubscription(serviceType).serviceInstance(instanceId)) if (!getAAIClient().exists(resourceUri)) { exceptionUtil.buildAndThrowWorkflowException(execution, 2500, errorMsg) } AAIResultWrapper wrapper = getAAIClient().get(resourceUri, NotFoundException.class) logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: queryAAI ****") return wrapper } public void getServiceVNFAndVFsFromCatalogDB(DelegateExecution execution) { logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: getServiceVNFAndVFsFromCatalogDB ****") String modelInvariantUuid = execution.getVariable("networkServiceModelInvariantUuid") try{ CatalogDbUtils catalogDbUtils = new CatalogDbUtilsFactory().create() String json = catalogDbUtils.getServiceResourcesByServiceModelInvariantUuidString(execution, modelInvariantUuid) logger.debug("***** JSON IS: "+json) String serviceVnfs = jsonUtil.getJsonValue(json, "serviceResources.serviceVnfs") ?: "" String serviceModelInfo = jsonUtil.getJsonValue(json, "serviceResources.modelInfo") ?: "" execution.setVariable("serviceVnfs",serviceVnfs) execution.setVariable("serviceModelInfo", serviceModelInfo) logger.debug(Prefix +" ***** serviceVnfs : "+ serviceVnfs) }catch(BpmnError e){ throw e } catch (Exception ex){ String msg = "Exception in getServiceVNFAndVFsFromCatalogDB " + ex.getMessage() logger.debug(msg) exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: getServiceVNFAndVFsFromCatalogDB ****") } public void prepareSOMacroRequestPayLoad(DelegateExecution execution) { logger.debug("**** Enter DoActivateCoreNSSI ::: prepareSOMacroRequestPayLoad ****") String json = execution.getVariable("serviceVnfs") List vnfList = mapper.readValue(json, List.class); Map serviceMap = mapper.readValue(execution.getVariable("serviceModelInfo"), Map.class); ModelInfo serviceModelInfo = new ModelInfo() serviceModelInfo.setModelType(ModelType.service) serviceModelInfo.setModelInvariantId(serviceMap.get("modelInvariantUuid")) serviceModelInfo.setModelVersionId(serviceMap.get("modelUuid")) serviceModelInfo.setModelName(serviceMap.get("modelName")) serviceModelInfo.setModelVersion(serviceMap.get("modelVersion")) //List of Vnfs List vnfModelInfoList = new ArrayList<>() Map vnfMap = vnfList.get(0) //List of VFModules List> vfModuleList = vnfMap.get("vfModules") //List of VfModules List vfModelInfoList = new ArrayList<>() //Traverse VFModules List and add in vfModelInfoList for (vfModule in vfModuleList) { ModelInfo vfModelInfo = vfModule.get("modelInfo") vfModelInfo.setModelCustomizationId(vfModelInfo.getModelCustomizationUuid()) vfModelInfo.setModelVersionId(vfModelInfo.getModelId()) vfModelInfoList.add(vfModelInfo) } String networkServiceInstanceName = execution.getVariable("networkServiceInstanceName") //RequestInfo RequestInfo requestInfo = new RequestInfo() //Dummy Product FamilyId requestInfo.setProductFamilyId("test1234") requestInfo.setSource("VID") requestInfo.setInstanceName(networkServiceInstanceName) requestInfo.setSuppressRollback(false) requestInfo.setRequestorId("NBI") //Service Level InstanceParams List> serviceParams = new ArrayList<>() Map serviceParamsValues = new LinkedHashMap<>() serviceParams.add(serviceParamsValues) //Cloud Configuration String lcpCloudRegionId = execution.getVariable("lcpCloudRegionId") String tenantId = execution.getVariable("tenantId") String cloudOwner = execution.getVariable("cloudOwner") CloudConfiguration cloudConfiguration = new CloudConfiguration() cloudConfiguration.setLcpCloudRegionId(lcpCloudRegionId) cloudConfiguration.setTenantId(tenantId) cloudConfiguration.setCloudOwner(cloudOwner) //VFModules List List> vfModules = new ArrayList<>() for (ModelInfo vfModuleModelInfo : vfModelInfoList) { //Individual VFModule List Map vfModuleValues = new LinkedHashMap<>() vfModuleValues.put("modelInfo", vfModuleModelInfo) vfModuleValues.put("instanceName", vfModuleModelInfo.getModelName()) //VFModule InstanceParams should be empty or this field should not be there? List> vfModuleInstanceParams = new ArrayList<>() vfModuleValues.put("instanceParams", vfModuleInstanceParams) vfModules.add(vfModuleValues) } //Vnf intsanceParams List> vnfInstanceParamsList = new ArrayList<>() String supportedsNssaiJson= prepareVnfInstanceParamsJson(execution) Map supportedNssai= new LinkedHashMap<>() supportedNssai.put("supportedsNssai", supportedsNssaiJson) vnfInstanceParamsList.add(supportedNssai) Platform platform = new Platform() String platformName = execution.getVariable("platformName") platform.setPlatformName(platformName) LineOfBusiness lineOfbusiness = new LineOfBusiness() String lineOfBusinessName = execution.getVariable("lineOfBusinessName") lineOfbusiness.setLineOfBusinessName(lineOfBusinessName) ModelInfo vnfModelInfo = vnfMap.get("modelInfo") vnfModelInfo.setModelCustomizationId(vnfModelInfo.getModelCustomizationUuid()) vnfModelInfo.setModelVersionId(vnfModelInfo.getModelId()) //Vnf Values Map vnfValues = new LinkedHashMap<>() vnfValues.put("lineOfBusiness", lineOfbusiness) vnfValues.put("platform", platform) vnfValues.put("productFamilyId", "test1234") vnfValues.put("cloudConfiguration", cloudConfiguration) vnfValues.put("vfModules", vfModules) vnfValues.put("modelInfo", vnfModelInfo) vnfValues.put("instanceName", vnfModelInfo.getModelInstanceName()) vnfValues.put("instanceParams",vnfInstanceParamsList) vnfModelInfoList.add(vnfValues) //Service Level Resources Map serviceResources = new LinkedHashMap<>() serviceResources.put("vnfs", vnfModelInfoList) //Service Values String serviceInstanceName = execution.getVariable("networkServiceInstanceName") Map serviceValues = new LinkedHashMap<>() serviceValues.put("modelInfo", serviceModelInfo) serviceValues.put("instanceName", serviceInstanceName) serviceValues.put("resources", serviceResources) serviceValues.put("instanceParams", serviceParams) //UserParams Values Map userParamsValues = new LinkedHashMap<>() Map homingSolution = new LinkedHashMap<>() homingSolution.put("Homing_Solution", "none") userParamsValues.put("service", serviceValues) //UserParams List> userParams = new ArrayList<>() userParams.add(homingSolution) userParams.add(userParamsValues) //Request Parameters String serviceType = execution.getVariable("serviceType") RequestParameters requestParameters = new RequestParameters() requestParameters.setaLaCarte(false) requestParameters.setSubscriptionServiceType(serviceType) requestParameters.setUserParams(userParams) //SubscriberInfo String globalSubscriberId = execution.getVariable("globalSubscriberId") SubscriberInfo subscriberInfo = new SubscriberInfo() subscriberInfo.setGlobalSubscriberId(globalSubscriberId) //Owning Entity String owningEntityId = execution.getVariable("owningEntityId") OwningEntity owningEntity = new OwningEntity() owningEntity.setOwningEntityId(owningEntityId) //Project String projectName = execution.getVariable("projectName") Project project = new Project() project.setProjectName(projectName) RequestDetails requestDetails = new RequestDetails() requestDetails.setModelInfo(serviceModelInfo) requestDetails.setSubscriberInfo(subscriberInfo) requestDetails.setRequestInfo(requestInfo) requestDetails.setRequestParameters(requestParameters) requestDetails.setCloudConfiguration(cloudConfiguration) requestDetails.setOwningEntity(owningEntity) requestDetails.setProject(project) Map requestDetailsMap = new LinkedHashMap<>() requestDetailsMap.put("requestDetails", requestDetails) String requestPayload = mapper.writeValueAsString(requestDetailsMap) logger.debug("requestDetails "+requestPayload) execution.setVariable("requestPayload", requestPayload) logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: prepareSOMacroRequestPayLoad ****") } public void sendPutRequestToSOMacro(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: sendPutRequestToSOMacro ****") try { String msoEndpoint = UrnPropertiesReader.getVariable("mso.infra.endpoint.url", execution) String networkServiceInstanceId = execution.getVariable("networkServiceInstanceId") String vnfId = execution.getVariable("vnfId") String url = msoEndpoint+"/serviceInstantiation/v7/serviceInstances/"+networkServiceInstanceId+"/vnfs/"+vnfId String requestBody = execution.getVariable("requestPayload") String msoKey = UrnPropertiesReader.getVariable("mso.msoKey", execution) String basicAuth = UrnPropertiesReader.getVariable("mso.adapters.po.auth", execution) String encodeString = utils.getBasicAuth(basicAuth, msoKey) logger.debug("msoEndpoint: "+msoEndpoint +" "+ "url: "+url +" requestBody: "+requestBody +" "+ "encodeString: "+encodeString) HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(url), ONAPComponents.SO) httpClient.addAdditionalHeader("Authorization", encodeString) httpClient.addAdditionalHeader("Accept", "application/json") Response httpResponse = httpClient.put(requestBody) handleSOResponse(httpResponse, execution) } catch (BpmnError e) { throw e } catch (any) { String msg = Prefix+" Exception in DoActivateCoreNSSI " + any.getCause() logger.error(msg) exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: sendPostRequestToSOMacro ****") } /** * Handle SO Response for PUT and prepare update operation status * @param execution */ private void handleSOResponse(Response httpResponse, DelegateExecution execution){ logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: handleSOResponse ****") int soResponseCode = httpResponse.getStatus() logger.debug("soResponseCode : "+soResponseCode) if (soResponseCode >= 200 && soResponseCode < 204 && httpResponse.hasEntity()) { String soResponse = httpResponse.readEntity(String.class) logger.debug("soResponse: "+soResponse) String macroOperationId = jsonUtil.getJsonValue(soResponse, "requestReferences.requestId") String requestSelfLink = jsonUtil.getJsonValue(soResponse, "requestReferences.requestSelfLink") execution.setVariable("macroOperationId", macroOperationId) execution.setVariable("requestSelfLink", requestSelfLink) execution.setVariable("isSOTimeOut", "no") execution.setVariable("isSOResponseSucceed","yes") } else { execution.setVariable("isSOResponseSucceed","no") prepareFailedOperationStatusUpdate(execution) } logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: handleSOResponse ****") } public void getSOPUTProgress(DelegateExecution execution) { logger.debug(Prefix+ " **** Enter DoActivateCoreNSSI ::: getSOPUTProgress ****") String url= execution.getVariable("requestSelfLink") HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(url), ONAPComponents.SO) String msoKey = UrnPropertiesReader.getVariable("mso.msoKey", execution) String basicAuth = UrnPropertiesReader.getVariable("mso.adapters.po.auth", execution) String encodeString = utils.getBasicAuth(basicAuth, msoKey) httpClient.addAdditionalHeader("Authorization", encodeString) httpClient.addAdditionalHeader("Accept", "application/json") Response httpResponse = httpClient.get() logger.debug("httpResponse "+httpResponse) int soResponseCode = httpResponse.getStatus() logger.debug("soResponseCode : "+soResponseCode) if (soResponseCode >= 200 && soResponseCode < 204 && httpResponse.hasEntity()) { String soResponse = httpResponse.readEntity(String.class) logger.debug("soResponse: "+soResponse) String requestState= jsonUtil.getJsonValue(soResponse, "request.requestStatus.requestState") logger.debug("requestState: "+requestState) execution.setVariable("requestState", requestState) } else { execution.setVariable("isSOResponseSucceed","no") prepareFailedOperationStatusUpdate(execution) } logger.debug(Prefix+ " **** Exit DoActivateCoreNSSI ::: getSOPUTProgress ****") } public void timeDelay() { try { logger.debug(Prefix+ " **** DoActivateCoreNSSI ::: timeDelay going to sleep for 5 sec") Thread.sleep(5000) logger.debug("**** DoActivateCoreNSSI ::: timeDelay wakeup after 5 sec") } catch(InterruptedException e) { logger.error(Prefix+ " **** DoActivateCoreNSSI ::: timeDelay exception" + e) } } void prepareUpdateResourceOperationStatus(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: prepareUpdateResourceOperationStatus ****") String soRequestState = execution.getVariable("requestState") //Prepare Update Status for PUT failure and success if("COMPLETE".equalsIgnoreCase(soRequestState)) { execution.setVariable("progress", "100") execution.setVariable("status", "finished") execution.setVariable("operationContent", "AllocteCoreNSSI successful.") logger.debug("Success ,result:${execution.getVariable("result")}, reason: ${execution.getVariable("reason")}") } else { logger.debug("SO PUT Failure with State: "+soRequestState) exceptionUtil.buildAndThrowWorkflowException(execution, 7000, "SO PUT Failure") } setResourceOperationStatus(execution) logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: prepareUpdateResourceOperationStatus ****") } void updateSliceProfileOrchestrationStatus(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: updateSliceProfileOrchestrationStatus ****") String globalCustId = execution.getVariable("globalSubscriberId") String serviceType = execution.getVariable("serviceType") String oStatus = execution.getVariable("oStatus") ServiceInstance si = execution.getVariable("sliceProfileServiceInstance") String sliceProfileInstanceId = si.getServiceInstanceId() if(sliceProfileInstanceId==null) { exceptionUtil.buildAndThrowWorkflowException(execution, 7000, "Slice Profile Instance Update failed") } si.setOrchestrationStatus(oStatus) AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer(globalCustId).serviceSubscription(serviceType).serviceInstance(sliceProfileInstanceId)) try { getAAIClient().update(uri, si) setResourceOperationStatus(execution) } catch (Exception e) { logger.info("Update OrchestrationStatus in AAI failed") String msg = "Update OrchestrationStatus in AAI failed, " + e.getMessage() exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: updateSliceProfileOrchestrationStatus ****") } /** * prepare ResourceOperation status * @param execution * @param operationType */ private void setResourceOperationStatus(DelegateExecution execution) { logger.debug(Prefix +" **** Enter DoActivateCoreNSSI ::: setResourceOperationStatus ****") String serviceId = execution.getVariable("nsiId") String jobId = execution.getVariable("jobId") String nssiId = execution.getVariable("serviceInstanceID") String modelUuid= execution.getVariable("modelUuid") String operationType = execution.getVariable("operationType") ResourceOperationStatus resourceOperationStatus = new ResourceOperationStatus() resourceOperationStatus.setServiceId(serviceId) resourceOperationStatus.setJobId(jobId) resourceOperationStatus.setOperationId(jobId) resourceOperationStatus.setResourceTemplateUUID(modelUuid) resourceOperationStatus.setResourceInstanceID(nssiId) resourceOperationStatus.setOperType(operationType) resourceOperationStatus.setStatus("finished") resourceOperationStatus.setProgress("100") resourceOperationStatus.setStatusDescription("Core Activation Successful") requestDBUtil.prepareUpdateResourceOperationStatus(execution, resourceOperationStatus) logger.debug(Prefix +" **** Exit DoActivateCoreNSSI ::: setResourceOperationStatus ****") } void prepareFailedOperationStatusUpdate(DelegateExecution execution){ logger.debug(Prefix + " **** Enter DoActivateCoreNSSI ::: prepareFailedOperationStatusUpdate ****") String serviceId = execution.getVariable("nsiId") String jobId = execution.getVariable("jobId") String nssiId = execution.getVariable("serviceInstanceID") String operationType = execution.getVariable("operationType") String modelUuid= execution.getVariable("modelUuid") ResourceOperationStatus resourceOperationStatus = new ResourceOperationStatus() resourceOperationStatus.setServiceId(serviceId) resourceOperationStatus.setJobId(jobId) resourceOperationStatus.setOperationId(jobId) resourceOperationStatus.setResourceInstanceID(nssiId) resourceOperationStatus.setResourceTemplateUUID(modelUuid) resourceOperationStatus.setOperType(operationType) resourceOperationStatus.setProgress("0") resourceOperationStatus.setStatus("failed") resourceOperationStatus.setStatusDescription("Core NSSI Activation Failed") requestDBUtil.prepareUpdateResourceOperationStatus(execution, resourceOperationStatus) logger.debug(Prefix + " **** Exit DoActivateCoreNSSI ::: prepareFailedOperationStatusUpdate ****") } }