ms/blueprintsprocessor/modules/services/execution-service/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/services/execution/ComponentRemoteScriptExecutor.kt

   1 /*
   2  * Copyright © 2018-2019 AT&T Intellectual Property.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package org.onap.ccsdk.cds.blueprintsprocessor.services.execution
  18
  19 import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput
  20 import org.onap.ccsdk.cds.blueprintsprocessor.core.asJsonType
  21 import org.onap.ccsdk.cds.blueprintsprocessor.core.utils.PayloadUtils
  22 import org.onap.ccsdk.cds.blueprintsprocessor.core.utils.createActionIdentifiersProto
  23 import org.onap.ccsdk.cds.blueprintsprocessor.core.utils.createCommonHeaderProto
  24 import org.onap.ccsdk.cds.blueprintsprocessor.core.utils.createExecutionServiceInputProto
  25 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
  26 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException
  27 import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
  28 import org.springframework.beans.factory.config.ConfigurableBeanFactory
  29 import org.springframework.context.annotation.Scope
  30 import org.springframework.stereotype.Component
  31 import java.util.UUID
  32
  33 /**
  34  * This is generic Remote Script Component Executor function
  35  * @author Brinda Santh
  36  */
  37 @Component("component-remote-script-executor")
  38 @Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
  39 open class ComponentRemoteScriptExecutor(
  40     private var streamingRemoteExecutionService: StreamingRemoteExecutionService<
  41         org.onap.ccsdk.cds.controllerblueprints.processing.api.ExecutionServiceInput,
  42         org.onap.ccsdk.cds.controllerblueprints.processing.api.ExecutionServiceOutput>
  43 ) : AbstractComponentFunction() {
  44
  45     companion object {
  46
  47         const val INPUT_SELECTOR = "selector"
  48         const val INPUT_BLUEPRINT_NAME = "blueprint-name"
  49         const val INPUT_BLUEPRINT_VERSION = "blueprint-version"
  50         const val INPUT_BLUEPRINT_ACTION = "blueprint-action"
  51         const val INPUT_TIMEOUT = "timeout"
  52         const val INPUT_REQUEST_DATA = "request-data"
  53
  54         const val ATTRIBUTE_RESPONSE_DATA = "response-data"
  55         const val ATTRIBUTE_STATUS = "status"
  56
  57         const val OUTPUT_RESPONSE_DATA = "response-data"
  58         const val OUTPUT_STATUS = "status"
  59     }
  60
  61     override suspend fun processNB(executionRequest: ExecutionServiceInput) {
  62         val selector = getOperationInput(INPUT_SELECTOR)
  63         val blueprintName = getOperationInput(INPUT_BLUEPRINT_NAME).asText()
  64         val blueprintVersion = getOperationInput(INPUT_BLUEPRINT_VERSION).asText()
  65         val blueprintAction = getOperationInput(INPUT_BLUEPRINT_ACTION).asText()
  66         val requestData = getOperationInput(INPUT_REQUEST_DATA)
  67         val timeout = getOperationInput(INPUT_TIMEOUT).asLong()
  68
  69         val requestPayload = PayloadUtils.prepareRequestPayloadStr(blueprintAction, requestData)
  70
  71         val txId = UUID.randomUUID().toString()
  72         val commonHeader = createCommonHeaderProto(
  73             executionRequest.commonHeader.subRequestId,
  74             txId, BluePrintConstants.APP_NAME
  75         )
  76         val actionIdentifier = createActionIdentifiersProto(blueprintName, blueprintVersion, blueprintAction)
  77
  78         val executionServiceInputProto =
  79             createExecutionServiceInputProto(commonHeader, actionIdentifier, requestPayload)
  80
  81         /** Invoke remote implementation using GRPC */
  82         val executionServiceOutputProto =
  83             streamingRemoteExecutionService.sendNonInteractive(selector, txId, executionServiceInputProto, timeout)
  84
  85         /** Set the response data */
  86         if (executionServiceOutputProto.payload != null) {
  87             val outputData = PayloadUtils.getResponseDataFromPayload(
  88                 blueprintAction,
  89                 executionServiceOutputProto.payload.asJsonType()
  90             )
  91             setAttribute(ATTRIBUTE_RESPONSE_DATA, outputData)
  92         }
  93
  94         /** set node template attribute */
  95         val statusMessage = executionServiceOutputProto.status.message
  96         if (statusMessage == BluePrintConstants.STATUS_SUCCESS) {
  97             setAttribute(ATTRIBUTE_STATUS, BluePrintConstants.STATUS_SUCCESS.asJsonPrimitive())
  98         } else {
  99             val errorMessage = executionServiceOutputProto.status.errorMessage ?: "failed in remote execution"
 100             throw BluePrintProcessorException(errorMessage)
 101         }
 102     }
 103
 104     override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) {
 105         addError("Failed in ComponentRemoteScriptExecutor : ${runtimeException.message}")
 106     }
 107 }