Implement so-oof-adapter to handle OOF Callback

	- Add NSI/NST selection callback for Networkslicing

Issue-ID: SO-3205
Signed-off-by: Priyadharshini <priyadharshini.b96@wipro.com>
Change-Id: Ica88d503495949ecce8b897c3a990fbdaa5d4f0e

2 files changed, 44 insertions, 102 deletions

diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSliceService.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSliceService.groovy
index 15a0f34482..389f0a089c 100644
--- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSliceService.groovy
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSliceService.groovy
@@ -178,60 +178,36 @@ public class CreateSliceService extends AbstractServiceTaskProcessor {
         logger.debug("Finish preProcessRequest")
     }
 
-    public void getNSTSelection(DelegateExecution execution) {
-        logger.debug("Start getNSTSelection")
+    public void prepareSelectNSTRequest(DelegateExecution execution) {
+        logger.debug("Start prepareSelectNSTRequest")
         String requestId = execution.getVariable("msoRequestId")
+	String messageType = "NSTSelectionResponse"
         Map<String, Object> serviceProfile = execution.getVariable("serviceProfile")
-        String oofUrl = UrnPropertiesReader.getVariable("mso.oof.endpoint", execution)
-
-        def authHeader = ""
-        String basicAuth = UrnPropertiesReader.getVariable("mso.oof.auth", execution)
-        String msokey = UrnPropertiesReader.getVariable("mso.msoKey", execution)
-
-        String basicAuthValue = utils.encrypt(basicAuth, msokey)
-        if (basicAuthValue != null) {
-            logger.debug( "Obtained BasicAuth username and password for OOF: " + basicAuthValue)
-            try {
-                authHeader = utils.getBasicAuth(basicAuthValue, msokey)
-                execution.setVariable("BasicAuthHeaderValue", authHeader)
-            } catch (Exception ex) {
-                logger.debug( "Unable to encode username and password string: " + ex)
-                exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - Unable to " +
-                        "encode username and password string")
-            }
-        } else {
-            logger.debug( "Unable to obtain BasicAuth - BasicAuth value null")
-            exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - BasicAuth " +
-                    "value null")
-        }
-
-        URL requestUrl = new URL(oofUrl + "/api/oof/v1/selection/nst")
-        String oofRequest = oofUtils.buildSelectNSTRequest(requestId, serviceProfile)
-        HttpClient httpClient = new HttpClientFactory().newJsonClient(requestUrl, ONAPComponents.OOF)
-        httpClient.addAdditionalHeader("Authorization", authHeader)
-        Response httpResponse = httpClient.post(oofRequest)
-
-        int responseCode = httpResponse.getStatus()
-        logger.debug("OOF sync response code is: " + responseCode)
-
-        if(responseCode != 200){
-            exceptionUtil.buildAndThrowWorkflowException(execution, responseCode, "Received a Bad Sync Response from OOF.")
-        }
-
-        Map<String, Object> nstSolution
-        try {
-            Map<String, Object> resMap = httpResponse.readEntity(Map.class)
-            List<Map<String, Object>> nstSolutions = (List<Map<String, Object>>) resMap.get("solutions")
-            nstSolution = nstSolutions.get(0)
-            execution.setVariable("nstSolution", nstSolution)
-        } catch (Exception ex) {
-            logger.debug( "Failed to get NST solution suggested by OOF.")
-            exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Failed to get NST solution suggested by OOF.")
-        }
-
-        logger.debug("Finish getNSTSelection")
+		execution.setVariable("nstSelectionUrl", "/api/oof/v1/selection/nst")
+		execution.setVariable("nstSelection_messageType",messageType)
+		execution.setVariable("nstSelection_correlator",requestId)
+		String timeout = UrnPropertiesReader.getVariable("mso.adapters.oof.timeout", execution);
+		execution.setVariable("nstSelection_timeout",timeout)
+        String oofRequest = oofUtils.buildSelectNSTRequest(requestId,messageType, serviceProfile)
+        execution.setVariable("nstSelection_oofRequest",oofRequest)
+        logger.debug("Finish prepareSelectNSTRequest")
 
     }
+	
+	public void processNSTSolutions(DelegateExecution execution) {
+		Map<String, Object> nstSolution
+		try {
+			logger.debug("Start processing NSTSolutions")
+			Map<String, Object> resMap = objectMapper.readValue(execution.getVariable("nstSelection_oofResponse"),Map.class)
+			List<Map<String, Object>> nstSolutions = (List<Map<String, Object>>) resMap.get("solutions")
+			nstSolution = nstSolutions.get(0)
+			execution.setVariable("nstSolution", nstSolution)
+		} catch (Exception ex) {
+			logger.debug( "Failed to get NST solution suggested by OOF.")
+			exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Failed to get NST solution suggested by OOF.")
+		}
+
+	}
 
     public void prepareDecomposeService(DelegateExecution execution) {
         logger.debug("Start prepareDecomposeService")
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCreateSliceServiceOption.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCreateSliceServiceOption.groovy
index ec9596e7f3..9b78afba03 100644
--- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCreateSliceServiceOption.groovy
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCreateSliceServiceOption.groovy
@@ -64,38 +64,16 @@ class DoCreateSliceServiceOption extends AbstractServiceTaskProcessor{
     }
 
 
-    void getNSIOptionfromOOF(DelegateExecution execution) {
+    void prepareSelectNSIRequest(DelegateExecution execution) {
 
         String urlString = UrnPropertiesReader.getVariable("mso.oof.endpoint", execution)
         logger.debug( "get NSI option OOF Url: " + urlString)
 
         boolean isNSISuggested = true
         execution.setVariable("isNSISuggested",isNSISuggested)
-
-        //Prepare auth for OOF - Begin
-        def authHeader = ""
-        String basicAuth = UrnPropertiesReader.getVariable("mso.oof.auth", execution)
-        String msokey = UrnPropertiesReader.getVariable("mso.msoKey", execution)
-
-        String basicAuthValue = utils.encrypt(basicAuth, msokey)
-        if (basicAuthValue != null) {
-            logger.debug( "Obtained BasicAuth username and password for OOF: " + basicAuthValue)
-            try {
-                authHeader = utils.getBasicAuth(basicAuthValue, msokey)
-                execution.setVariable("BasicAuthHeaderValue", authHeader)
-            } catch (Exception ex) {
-                logger.debug( "Unable to encode username and password string: " + ex)
-                exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - Unable to " +
-                        "encode username and password string")
-            }
-        } else {
-            logger.debug( "Unable to obtain BasicAuth - BasicAuth value null")
-            exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - BasicAuth " +
-                    "value null")
-        }
-        //Prepare auth for OOF - End
-
         String requestId = execution.getVariable("msoRequestId")
+		String messageType = "NSISelectionResponse"
+		
         Map<String, Object> profileInfo = execution.getVariable("serviceProfile")
         Map<String, Object> nstSolution = execution.getVariable("nstSolution")
         logger.debug("Get NST selection from OOF: " + nstSolution.toString())
@@ -104,36 +82,21 @@ class DoCreateSliceServiceOption extends AbstractServiceTaskProcessor{
             "modelVersionId":"${nstSolution.UUID}",
             "modelName":"${nstSolution.NSTName}"
          }"""
-
-        String oofRequest = oofUtils.buildSelectNSIRequest(requestId, nstInfo, profileInfo)
-        logger.debug("Sending request to OOF: " + oofRequest)
-
-        //send request to get NSI option - Begin
-        URL url = new URL(urlString+"/api/oof/selection/nsi/v1")
-        HttpClient httpClient = new HttpClientFactory().newJsonClient(url, ONAPComponents.OOF)
-        httpClient.addAdditionalHeader("Authorization", authHeader)
-        Response httpResponse = httpClient.post(oofRequest)
-
-        processOOFResponse(httpResponse, execution)
-
-        //解析sliceProfile
-        logger.debug("start parseServiceProfile")
-        parseServiceProfile(execution)
-        logger.debug("end parseServiceProfile")
+		
+		 execution.setVariable("nsiSelectionUrl", "/api/oof/selection/nsi/v1")
+		 execution.setVariable("nsiSelection_messageType",messageType)
+		 execution.setVariable("nsiSelection_correlator",requestId)
+		 String timeout = UrnPropertiesReader.getVariable("mso.adapters.oof.timeout", execution);
+		 execution.setVariable("nsiSelection_timeout",timeout)
+		 String oofRequest = oofUtils.buildSelectNSIRequest(requestId, nstInfo,messageType, profileInfo)
+		 execution.setVariable("nsiSelection_oofRequest",oofRequest)
+		 logger.debug("Sending request to OOF: " + oofRequest)
     }
 
-    private void processOOFResponse(Response httpResponse, DelegateExecution execution) {
+    void processOOFResponse(Response httpResponse, DelegateExecution execution) {
         int responseCode = httpResponse.getStatus()
-        logger.debug("OOF sync response code is: " + responseCode)
-
-        if (responseCode != 200) {
-            exceptionUtil.buildAndThrowWorkflowException(execution, responseCode, "Received a Bad Sync Response from OOF.")
-            logger.debug("Info: No NSI suggested by OOF")
-        }
-
         SliceTaskParams sliceTaskParams = execution.getVariable("sliceTaskParams")
-        if (httpResponse.hasEntity()) {
-            String OOFResponse = httpResponse.readEntity(String.class)
+            String OOFResponse = execution.getVariable("nsiSelection_oofResponse")
             logger.debug("NSI OOFResponse is: " + OOFResponse)
             execution.setVariable("OOFResponse", OOFResponse)
             //This needs to be changed to derive a value when we add policy to decide the solution options.
@@ -154,8 +117,11 @@ class DoCreateSliceServiceOption extends AbstractServiceTaskProcessor{
             }
             execution.setVariable("sliceTaskParams", sliceTaskParams)
             logger.debug("sliceTaskParams: "+sliceTaskParams.convertToJson())
-        }
         logger.debug("*** Completed options Call to OOF ***")
+		//解析sliceProfile
+		logger.debug("start parseServiceProfile")
+		parseServiceProfile(execution)
+		logger.debug("end parseServiceProfile")
     }
 
     private boolean hasSharedNSIsolutions( Map solutions){