diff options
Diffstat (limited to 'docs/developer_info/BPMN-INFRA_Workflow_Understanding.rst')
| -rw-r--r-- | docs/developer_info/BPMN-INFRA_Workflow_Understanding.rst | 658 |
1 files changed, 658 insertions, 0 deletions
diff --git a/docs/developer_info/BPMN-INFRA_Workflow_Understanding.rst b/docs/developer_info/BPMN-INFRA_Workflow_Understanding.rst new file mode 100644 index 0000000000..b1ef356c35 --- /dev/null +++ b/docs/developer_info/BPMN-INFRA_Workflow_Understanding.rst @@ -0,0 +1,658 @@ +.. 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 |