.. This work is licensed under a Creative Commons Attribution 4.0 International License. .. http://creativecommons.org/licenses/by/4.0 .. Copyright 2017 Huawei Technologies Co., Ltd. CODE FLOWS OF BPMN-INFRA ======================== API Handler is a SO Component. Every Rest API will first reach to the API Handler. Curl command which is mentioned below will directly hit to the E2EServiceInstances.java file of the API Handler component. API HANDLER ( E2EServiceInstances.java ) ---------------------------------------- curl -v -H "Content-Type: application/json" -X POST --data @request_body_file_name.json -u mso_admin:password1$ http://localhost:8080/onap/so/infra/e2eServiceInstances/v3 .. code-block:: bash Request Body: { "service":{ "name":"SliceService", "description":"SliceService", "serviceInvariantUuid":"dfcd7471-16c7-444e-8268-d4c50d90593a", "serviceUuid":"dfcd7471-16c7-444e-8268-d4c50d90593a", "globalSubscriberId":"test_custormer", "serviceType":"embb", "parameters":{ "locationConstraints":[ ], "resources":[ { "resourceIndex":"1", "resourceName":"allottedResource", "resourceInvariantUuid":"eeefcd86-7b5b-41ae-9516-08acc5d59d92", "resourceUuid":"265da937-76c7-4152-98e3-5f0d0a844b7f", "resourceCustomizationUuid":"a4eda1d9-1af4-424b-997f-12c57b74c67a", "parameters":{ "locationConstraints":[ ], "resources":[ ], "requestInputs":{ } } } ], "requestInputs":{ "sST": "embb", "sNSSAI": "1-10101", "uEMobilityLevel": "stationary", "areaTrafficCapDL": 123, "maxNumberofUEs": 1000, "expDataRateUL": 2000, "plmnIdList": "39-00|39-01", "areaTrafficCapUL": 456, "latency": 300, "expDataRateDL": 400, "coverageAreaTAList": 101001, "activityFactor": 99, "resourceSharingLevel": "shared", "nstar0_allottedresource0_providing_service_uuid": "4e8d930b-7483-4b9b-8c82-4708638ade4a", "nstar0_allottedresource0_providing_service_invariant_uuid": "1899e5c1-df4e-43a8-a889-48c157dad7bc" } } } .. code-block:: bash Response body: { "service": { "serviceId": "ebe2d37f-f65b-43d8-8906-f81811ed8f22", "operationId": "ed9b4c84-17db-4874-8896-25324a0401fe" } } Code flows: ----------- 1. It reaches to the E2EServiceInstances.java file of API-Handeler infra project and Input json is mapped to the createE2EServiceInstance method 2. A unique request id is generated corresponding to every request and checked if request Id already exists in requestdb InfraActiveReqest table a. http://request-db-adapter:8083/infraActiveRequests/requestID (GET), which will return a 404 if not exists b. createInstance is set to the action variable 3. Running local validations on input json. 4. Gets the orchestration url from the recipe table a. Checks whether the service already exists in catalogdb http://catalog-db-adapter:8082/service/{modelNameVersionId} (GET) b. Checks the service recipe table with the modelNameVersionId and the action to be perfomed http://catalog-db- adapter:8082/serviceRecipe/search/findFirstByServiceModelUUIDAndAction?serviceModelUUID= {modelNameVersionId}&action=createInstance . Returns a 404 if no recipe exists with the corresponding id. c. As recipe corresponding to this doesnt exist, we try to get with a default value. This flow comes under default flow so the defaultvalue is UUI_DEFAULT. First we get service with this value http://catalog-db-adapter:8082/service/search/findFirstByModelNameOrderByModelVersionDesc?modelName=UUI_DEFAULT (GET) . It returns a service with modelUUID as dfcd7471-16c7-444e-8268-d4c50d90593a, and further can be used to get the recipe . d. http://so-catalog-db-adapter.onap:8082/serviceRecipe/search/findFirstByServiceModelUUIDAndAction? serviceModelUUID=dfcd7471-16c7-444e-8268-d4c50d90593a&action=createInstance gives a recipe which has a parameter "orchestrationUri" as "/mso/async/services/CreateCustomE2EServiceInstance" BPMN-INFRA ---------- Hits CreateCustomE2EServiceInstances Address: http://bpmn-infra:8081/mso/async/services/CreateCustomE2EServiceInstance Payload will be reaching to bpmn in the form of: .. code-block:: bash { "variables": { "bpmnRequest": { "value": { "requestDetails": { "modelInfo": { "modelInvariantId": "699dd37d-c82f-4bd5-adec-856900fc2796", "modelType": "service", "modelNameVersionId": "0692e0c9-8913-41ca-893a-58626f4afff2", "modelName": "voLTE", "modelVersion": "1.0", "modelVersionId": "0692e0c9-8913-41ca-893a-58626f4afff2", "modelUuid": "0692e0c9-8913-41ca-893a-58626f4afff2", "modelInvariantUuid": "699dd37d-c82f-4bd5-adec-856900fc2796" }, "requestInfo": { "source": "UUI", "instanceName": "SliceService", "suppressRollback": true }, "subscriberInfo": { "globalSubscriberId": "test_custormer" }, "requestParameters": { "subscriptionServiceType": "MOG", "userParams": [ { "ServiceInstanceName": "SliceService", "UUIRequest": { "service": { "name": "SliceService", "description": "SliceService", "serviceInvariantUuid": "699dd37d-c82f-4bd5-adec-856900fc2796", "serviceUuid": "0692e0c9-8913-41ca-893a-58626f4afff2", "globalSubscriberId": "test_custormer", "serviceType": "embb", "parameters": { "locationConstraints": [], "resources": [ { "resourceIndex": "1", "resourceName": "allottedResource", "resourceInvariantUuid": "eeefcd86-7b5b-41ae-9516-08acc5d59d92", "resourceUuid": "265da937-76c7-4152-98e3-5f0d0a844b7f", "resourceCustomizationUuid": "a4eda1d9-1af4-424b-997f-12c57b74c67a", "parameters": { "locationConstraints": [], "resources": [], "requestInputs": {} } } ], "requestInputs": { "sST": "embb", "sNSSAI": "1-10101", "uEMobilityLevel": "stationary", "areaTrafficCapDL": 123, "maxNumberofUEs": 1000, "expDataRateUL": 2000, "plmnIdList": "39-00|39-01", "areaTrafficCapUL": 456, "latency": 300, "expDataRateDL": 400, "coverageAreaTAList": 101001, "activityFactor": 99, "resourceSharingLevel": "shared", "nstar0_allottedresource0_providing_service_uuid": "4e8d930b-7483-4b9b-8c82-4708638ade4a", "nstar0_allottedresource0_providing_service_invariant_uuid": "1899e5c1-df4e-43a8-a889-48c157dad7bc" } } } } } ], "aLaCarte": true, "usePreload": true } }, "serviceInstanceId": null, "vnfInstanceId": null, "pnfName": null, "networkInstanceId": null, "volumeGroupInstanceId": null, "vfModuleInstanceId": null, "configurationId": null, "instanceGroupId": null }, "type": "String" }, "requestId": { "value": "6fa42cd2-4f49-4e2c-92fb-fae133277e9e", "type": "String" }, "mso-request-id": { "value": "6fa42cd2-4f49-4e2c-92fb-fae133277e9e", "type": "String" }, "isBaseVfModule": { "value": false, "type": "Boolean" }, "recipeTimeout": { "value": 180, "type": "Integer" }, "requestAction": { "value": "createInstance", "type": "String" }, "serviceInstanceId": { "value": "", "type": "String" }, "pnfCorrelationId": { "value": "", "type": "String" }, "vnfId": { "value": "", "type": "String" }, "vfModuleId": { "value": "", "type": "String" }, "volumeGroupId": { "value": "", "type": "String" }, "networkId": { "value": "", "type": "String" }, "configurationId": { "value": "", "type": "String" }, "serviceType": { "value": "embb", "type": "String" }, "vnfType": { "value": "", "type": "String" }, "vfModuleType": { "value": "", "type": "String" }, "networkType": { "value": "", "type": "String" }, "recipeParams": { "value": null, "type": "String" }, "host": { "value": null, "type": "String" }, "operationType": { "value": "", "type": "String" }, "apiVersion": { "value": "v3", "type": "String" }, "aLaCarte": { "value": false, "type": "Boolean" }, "requestUri": { "value": "", "type": "String" }, "instanceGroupId": { "value": "", "type": "String" }, "generateIdsOnly": { "value": false, "type": "Boolean" } } } Based on the serviceUuid which is mentioned in the request body it will call the the CreateCommunicationService.bpmn file and This CreateCommunicationService.bpmn is taken as a example to this workflow Understanding which then call the subprocess of this flow and so on. .. image:: ../images/CreateCommunicationService.png 1. CreateCommunicationService -> preProcessRequest() a. Get Input Request will be logged as shown above b. Get Request ID c. Here ServiceInstanceId is null so serviceInstanceId is generated randomly. d. Input productFamilyId is null e. Now it will get the user input parameter from the request json. 2. CreateCommunicationService--> prepareInitOperationStatus a. Generate a new operation based on serviceInstanceId and operationId b. call to prepareUpdateOperationStatus() method 3. RequestDBUtil--> prepareUpdateOperationStatus() a. This method will be called to update the operation status in the requestDB b. Exit prepareUpdateOperationStatus() c. Exit prepareInitOperationStatus() 4. Based on the bpmn structure DecomposeService class is called a. This class takes input as - msoRequestId - isDebugLogEnabled - serviceInstanceId - serviceModelInfo - requestParameters b. Sent GET request to catalogdb to fetch the data based on serviceModelInvariantId and modelVersion http://so-catalog-db-adapter.onap:8082/ecomp/mso/catalog/v2/{serviceModelUuid} c. Response from catalogdb will be looking like: .. code-block:: bash { "serviceResources": { "modelInfo": { "modelName": "CST", "modelUuid": "bfc2775b-64ad-41e5-95fe-d3bc57df6c73", "modelInvariantUuid": "d4df55ca-c985-46c9-8088-f952181f553e", "modelVersion": "1.0" }, "serviceType": "embb", "serviceRole": "", "environmentContext": "General_Revenue-Bearing", "resourceOrder": "ServiceProfile Service Proxy", "workloadContext": "Production", "serviceVnfs": [], "serviceNetworks": [], "serviceInfo": { "id": 11, "serviceInput": [ { "default": true, "name": "skip_post_instantiation_configuration", "type": "boolean", "required": false }, { "default": "", "name": "useInterval", "type": "string", "required": false }, { "default": "SO-REF-DATA", "name": "controller_actor", "type": "string", "required": false }, { "default": "", "name": "maxNumberofUEs", "type": "integer", "required": false }, { "default": "", "name": "latency", "type": "integer", "required": false }, { "default": "", "name": "cds_model_version", "type": "string", "required": false }, { "default": "", "name": "uEMobilityLevel", "type": "string", "required": false }, { "default": "", "name": "cds_model_name", "type": "string", "required": false }, { "default": "", "name": "expDataRateUL", "type": "integer", "required": false }, { "default": "", "name": "expDataRateDL", "type": "integer", "required": false }, { "default": "", "name": "coverageAreaList", "type": "string", "required": false }, { "default": "", "name": "resourceSharingLevel", "type": "string", "required": false } ], "serviceProperties": [ { "default": true, "name": "skip_post_instantiation_configuration", "type": "boolean", "constraints": [ { "valid_values": [ true, false ] } ] }, { "default": "SO-REF-DATA", "name": "controller_actor", "type": "string", "constraints": [ { "valid_values": [ "SO-REF-DATA", "CDS", "SDNC", "APPC" ] } ] }, { "name": "maxNumberofUEs", "type": "integer", "required": false }, { "name": "latency", "type": "integer", "required": false }, { "name": "expDataRateUL", "type": "integer", "required": false }, { "name": "sNSSAI", "type": "string", "required": false }, { "name": "useInterval", "type": "string", "required": false }, { "default": "39-00", "name": "plmnIdList", "type": "string", "required": false }, { "name": "cds_model_version", "type": "string" }, { "name": "uEMobilityLevel", "type": "string", "required": false }, { "name": "cds_model_name", "type": "string" }, { "name": "expDataRateDL", "type": "integer", "required": false }, { "name": "coverageAreaList", "type": "string", "required": false }, { "name": "resourceSharingLevel", "type": "string", "required": false } ], "serviceArtifact": [] }, "serviceProxy": [ { "modelInfo": { "modelName": "ServiceProfile Service Proxy", "modelUuid": "ed00301c-51ec-46a4-b766-e3af50c210d2", "modelInvariantUuid": "071d426c-3f9b-44a9-9757-422043d80fc1", "modelVersion": "1.0", "modelCustomizationUuid": "81c5a468-37d3-4d8d-95f5-e72b0933d3d4", "modelInstanceName": "serviceprofile_proxy 0" }, "toscaNodeType": "org.openecomp.nodes.serviceprofile_proxy", "description": "A Proxy for Service ServiceProfile", "sourceModelUuid": "94553b32-e075-4cb0-b309-dd318ebbf670" } ], "serviceAllottedResources": [] } } 5. CreateCommunicationService--> prepareDoComposeE2E() a. To decompose the service based on serviceModelUuid 6. CreateCommunicationService--> parseCSParamsFromReq() a. To parse the CreateCommunication parameter Request from the Request json 7. Now sending PUT request to AAI based on globalSubscriberId and serviceType a. https://aai.onap:8443/aai/v19/business/customers/customer/{globalSubscriberId}/service-subscriptions/service- subscription/{seviceType}/service-instances/service-instance/{serviceInstanceId} b. Customer can be got by GET request with https://aai.onap:8443/aai/v19/business/customers/customer/{globalSubscriberId} c. Service-Subscription can be got by GET request with https://aai.onap:8443/aai/v19/business/customers/customer/{globalSubscriberId}/service-subscriptions/service- subscription/{seviceType} d. Request body for PUT request to the AAI from bpmn: { "service-instance-name": "SliceService", "service-role": "communication-service", "environment-context": "01-70CAA6B", "created-at": "2020-06-23 05:02:56", "model-invariant-id": "d4df55ca-c985-46c9-8088-f952181f553e", "model-version-id": "bfc2775b-64ad-41e5-95fe-d3bc57df6c73", "orchestration-status": "processing", "input-parameters": "{ \"service\":{ \"name\":\"SliceService\", \"description\":\"SliceService\", \"serviceInvariantUuid\":\"d4df55ca-c985-46c9-8088-f952181f553e\", \"serviceUuid\":\"bfc2775b-64ad-41e5-95fe-d3bc57df6c73\", \"globalSubscriberId\":\"5GCustomer\", \"serviceType\":\"5G\", \"parameters\":{ \"locationConstraints\":[ ], \"resources\":[ { \"resourceIndex\":\"1\", \"resourceName\":\"allottedResource\", \"resourceInvariantUuid\":\"eeefcd86-7b5b-41ae-9516-08acc5d59d92\", \"resourceUuid\":\"265da937-76c7-4152-98e3-5f0d0a844b7f\", \"resourceCustomizationUuid\":\"a4eda1d9-1af4-424b-997f-12c57b74c67a\", \"parameters\":{ \"locationConstraints\":[ ], \"resources\":[ ], \"requestInputs\":{ } } } ], \"requestInputs\":{\t\t\t \"sST\": \"embb\", \"sNSSAI\": \"1-10101\", \"uEMobilityLevel\": \"stationary\", \"areaTrafficCapDL\": 123, \"maxNumberofUEs\": 1000, \"expDataRateUL\": 2000, \"plmnIdList\": \"39-00|39-01\", \"areaTrafficCapUL\": 456, \"latency\": 300, \"expDataRateDL\": 400, \"coverageAreaTAList\": 101001, \"activityFactor\": 99, \"resourceSharingLevel\": \"shared\", \"nstar0_allottedresource0_providing_service_uuid\": \"4e8d930b-7483-4b9b-8c82-4708638ade4a\", \"nstar0_allottedresource0_providing_service_invariant_uuid\": \"1899e5c1-df4e-43a8-a889-48c157dad7bc\" } } }}" } Response: Response is returned with an empty entity e. Sending PUT request to the AAI for communication service profile https://aai.onap:8443/aai/v19/business/customers/customer/5GCustomer/service-subscriptions/service-subscription/5G/service-instances/service-instance/8a95e3ac-32cd-4ffb-b9e3-5366b393a7a2/communication-service-profiles/communication-service-profile/202a5e9a-d1d7-4afd-922f-3e7a709c780c payload: {"profile-id":"202a5e9a-d1d7-4afd-922f-3e7a709c780c","max-number-of-UEs":1000,"latency":300,"exp-data-rate-UL":2000,"exp-data-rate-DL":400,"ue-mobility-level":"stationary","resource-sharing-level":"shared"} Response: Response is returned with an empty entity 8. CreateCommunicationService--> sendSyncResponse() a. Send a response to the API-Handler b. Response Body: { "service": { "serviceId":"8a95e3ac-32cd-4ffb-b9e3-5366b393a7a2", "operationId":"a970a804-7ac5-4de9-b6db-17352afbc6fa" } 9. CreateCommunicationService--> generateE2EServiceProfile() a. It gets the E2E service templete Id and change communication profile to E2E service profile b. Basically it generates the E2E service profile 10. CreateCommunicationService--> preRequestSend2NSMF() a. It sets the payload to send to the other bpmn file 11. Here based on the CreateCommunicationService bpmn structure required bpmn file will be called and corresponding to this bpmn, groovy file will be called. For example, Here CreateSliceService.groovy is being called. 12. CreateCommunicationService--> processNSMFResponse() a. It processes the NSMF response code which was returned from other groovy file 13. CreateCommunicationService--> createCSAndSSRelationship() a. It will create relationship between communication service and e2e service 14. CreateCommunicationService--> createRelationShipInAAI() a. Sending a PUT request to make a relationship between two services https://aai.onap:8443/aai/v19/business/customers/customer/5GCustomer/service-subscriptions/service- subscription/5G/service-instances/service-instance/8a95e3ac-32cd-4ffb-b9e3-5366b393a7a2/relationship- list/relationship b. Request body: { "related-link":"aai/v16/business/customers/customer/5GCustomer/service-subscriptions/service- subscription/5G/service-instances/service-instance/2e6c2d7f-85c0-4b1f-b7fd-5f2364c27ea7" } 15. CreateCommunicationService--> prepareUpdateOperationStatus() a. prepare update operation status after create relationship in aai 16. RequestDBUtil--> prepareUpdateOperationStatus() a. update operation status in requestDB b. DB Adapter Endpoint is: http://so-request-db-adapter.onap:8083/services/RequestsDbAdapter