path: root/docs/developer_info/BPMN-INFRA_Workflow_Understanding.rst

.. 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