diff options
Diffstat (limited to 'cba/lock-device')
| -rw-r--r-- | cba/lock-device/Definitions/lock-device.json | 98 | ||||
| -rwxr-xr-x | cba/lock-device/Scripts/kotlin/ProcessOperation.kt | 49 | ||||
| -rw-r--r-- | cba/lock-device/TOSCA-Metadata/TOSCA.meta | 8 | ||||
| -rw-r--r-- | cba/lock-device/Templates/base-mapping.json | 23 |
4 files changed, 178 insertions, 0 deletions
diff --git a/cba/lock-device/Definitions/lock-device.json b/cba/lock-device/Definitions/lock-device.json new file mode 100644 index 0000000..c90021c --- /dev/null +++ b/cba/lock-device/Definitions/lock-device.json @@ -0,0 +1,98 @@ +{ + "metadata": { + "template_author": "Selffish", + "author-email": "test@bell.ca", + "template_name": "RT-lock-device", + "template_version": "1.0.0", + "template_tags": "Bell, CBA, test" + }, + "dsl_definitions": {}, + "topology_template": { + "workflows": { + "resolve-deploy-kotlin": { + "steps": { + "resolve": { + "description": "resolve vnf-id", + "target": "resource-resolution", + "on_success": [ + "execute-script" + ] + }, + "execute-script": { + "description": "Execute Kotlin Script", + "target": "execute-kotlin" + } + }, + "outputs": { + "response-data": { + "type": "string", + "value": { + "get_attribute": [ + "execute-kotlin", + "response-data" + ] + } + } + } + } + }, + "node_templates": { + "resource-resolution": { + "type": "component-resource-resolution", + "interfaces": { + "ResourceResolutionComponent": { + "operations": { + "process": { + "inputs": { + "artifact-prefix-names": [ + "base" + ], + "resolution-summary": true + } + } + } + } + }, + "artifacts": { + "base-mapping": { + "type": "artifact-mapping-resource", + "file": "Templates/base-mapping.json" + } + } + }, + "execute-kotlin": { + "type": "component-script-executor", + "interfaces": { + "ComponentScriptExecutor": { + "operations": { + "process": { + "implementation": { + "primary": "component-script", + "lock": { + "key": { + "get_attribute": [ + "resource-resolution", + "", + "assignment-map", + "base", + "vnf-id" + ] + }, + "acquireTimeout": { + "get_input": "lock-acquire-timeout" + } + } + }, + "inputs": { + "script-type": "kotlin", + "script-class-reference": "cba.cds.RT.ProcessOperation" + }, + "outputs": {} + } + } + } + } + } + } + } +} diff --git a/cba/lock-device/Scripts/kotlin/ProcessOperation.kt b/cba/lock-device/Scripts/kotlin/ProcessOperation.kt new file mode 100755 index 0000000..e84623a --- /dev/null +++ b/cba/lock-device/Scripts/kotlin/ProcessOperation.kt @@ -0,0 +1,49 @@ +/* + * Copyright © 2019 Bell Canada. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package cba.cds.RT + +import org.onap.ccsdk.cds.controllerblueprints.core.logger +import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput +import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction +import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.ComponentScriptExecutor +import org.onap.ccsdk.cds.controllerblueprints.core.asJsonType +import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BasicAuthRestClientService +import org.onap.ccsdk.cds.blueprintsprocessor.rest.BasicAuthRestClientProperties +import kotlinx.coroutines.delay + +open class ProcessOperation : AbstractScriptComponentFunction() { + + private val log = logger(ProcessOperation::class) + + override suspend fun processNB(executionRequest: ExecutionServiceInput) { + val time : Long = 30_000 + try { + log.info("Processing for $time ms... ${executionRequest.commonHeader.requestId}") + delay(time) + log.info("Done processing ${executionRequest.commonHeader.requestId}!") + setAttribute(ComponentScriptExecutor.ATTRIBUTE_RESPONSE_DATA, "Success: ${executionRequest.commonHeader.requestId}".asJsonType()) + } catch (e: Exception) { + e.message?.let { addError(it) } + } + } + + override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) { + setAttribute(ComponentScriptExecutor.ATTRIBUTE_RESPONSE_DATA, runtimeException.message!!.asJsonType()) + addError(runtimeException.message!!) + log.info("Executing Recovery") + } +} diff --git a/cba/lock-device/TOSCA-Metadata/TOSCA.meta b/cba/lock-device/TOSCA-Metadata/TOSCA.meta new file mode 100644 index 0000000..e182865 --- /dev/null +++ b/cba/lock-device/TOSCA-Metadata/TOSCA.meta @@ -0,0 +1,8 @@ +TOSCA-Meta-File-Version: 1.0.0 +CSAR-Version: 1.0 +Created-By: Selffish +Entry-Definitions: Definitions/lock-device.json +Template-Tags: test, regression +Template-Name: RT-lock-device +Template-Version: 1.0.0 +Template-Type: DEFAULT
\ No newline at end of file diff --git a/cba/lock-device/Templates/base-mapping.json b/cba/lock-device/Templates/base-mapping.json new file mode 100644 index 0000000..b5b64a8 --- /dev/null +++ b/cba/lock-device/Templates/base-mapping.json @@ -0,0 +1,23 @@ +[ + { + "name": "vnf-id", + "input-param": true, + "property": { + "type": "string", + "default": "rt-vnf-xyz-123" + }, + "dictionary-name": "input-source", + "dictionary-source": "default", + "dependencies": [] + }, + { + "name": "lock-acquire-timeout", + "input-param": true, + "property": { + "type": "integer" + }, + "dictionary-name": "input-source", + "dictionary-source": "input", + "dependencies": [] + } +] |