2 * Copyright © 2017-2018 AT&T Intellectual Property.
4 * Modifications Copyright © 2019 IBM, Bell Canada.
6 * Licensed under the Apache License, Version 2.0 (the "License");
7 * you may not use this file except in compliance with the License.
8 * You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
19 package org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.processor
21 import com.fasterxml.jackson.databind.node.NullNode
22 import io.mockk.coEvery
25 import kotlinx.coroutines.runBlocking
27 import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.ResourceAssignmentRuntimeService
28 import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.resourceAssignment
29 import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.ComponentFunctionScriptingService
30 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
31 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
32 import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
33 import org.onap.ccsdk.cds.controllerblueprints.core.data.PropertyDefinition
34 import org.onap.ccsdk.cds.controllerblueprints.core.logger
35 import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintContext
36 import org.onap.ccsdk.cds.controllerblueprints.core.utils.BluePrintMetadataUtils
37 import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
38 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceAssignment
39 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceDefinition
40 import kotlin.test.assertEquals
41 import kotlin.test.assertNotNull
42 import kotlin.test.assertTrue
44 class CapabilityResourceResolutionProcessorTest {
47 fun `test kotlin capability`() {
49 val componentFunctionScriptingService = mockk<ComponentFunctionScriptingService>()
51 componentFunctionScriptingService
52 .scriptInstance<ResourceAssignmentProcessor>(any(), any(), any())
53 } returns MockCapabilityScriptRA()
56 componentFunctionScriptingService.cleanupInstance(any(), any())
59 val raRuntimeService = mockk<ResourceAssignmentRuntimeService>()
60 every { raRuntimeService.bluePrintContext() } returns mockk<BluePrintContext>()
61 every { raRuntimeService.getInputValue("test-property") } returns NullNode.getInstance()
63 val capabilityResourceResolutionProcessor =
64 CapabilityResourceResolutionProcessor(componentFunctionScriptingService)
65 capabilityResourceResolutionProcessor.raRuntimeService = raRuntimeService
67 val resourceAssignment = BluePrintTypes.resourceAssignment(
68 name = "test-property", dictionaryName = "ra-dict-name",
69 dictionarySource = "capability"
71 property("string", true, "")
75 scriptClassReference(MockCapabilityScriptRA::class.qualifiedName!!)
76 keyDependencies(arrayListOf("dep-property"))
80 val status = capabilityResourceResolutionProcessor.applyNB(resourceAssignment)
81 assertTrue(status, "failed to execute capability source")
83 "assigned-data".asJsonPrimitive(), resourceAssignment.property!!.value,
84 "assigned value miss match"
90 fun `test jython capability`() {
93 val bluePrintContext = BluePrintMetadataUtils.getBluePrintContext(
94 "./../../../../components/model-catalog/blueprint-model/test-blueprint/capability_python"
97 val componentFunctionScriptingService = mockk<ComponentFunctionScriptingService>()
99 componentFunctionScriptingService
100 .scriptInstance<ResourceAssignmentProcessor>(any(), BluePrintConstants.SCRIPT_JYTHON, any())
101 } returns MockCapabilityScriptRA()
104 componentFunctionScriptingService.cleanupInstance(any(), any())
107 val resourceAssignmentRuntimeService = ResourceAssignmentRuntimeService("1234", bluePrintContext)
109 val capabilityResourceResolutionProcessor =
110 CapabilityResourceResolutionProcessor(componentFunctionScriptingService)
112 capabilityResourceResolutionProcessor.raRuntimeService = resourceAssignmentRuntimeService
114 val resourceDefinition = JacksonUtils
115 .readValueFromClassPathFile(
116 "mapping/capability/jython-resource-definitions.json",
117 ResourceDefinition::class.java
119 val resourceDefinitions: MutableMap<String, ResourceDefinition> = mutableMapOf()
120 resourceDefinitions[resourceDefinition.name] = resourceDefinition
121 capabilityResourceResolutionProcessor.resourceDictionaries = resourceDefinitions
123 val resourceAssignment = ResourceAssignment().apply {
124 name = "service-instance-id"
125 dictionaryName = "service-instance-id"
126 dictionarySource = "capability"
127 property = PropertyDefinition().apply {
132 val processorName = capabilityResourceResolutionProcessor.processNB(resourceAssignment)
133 assertNotNull(processorName, "couldn't get Jython script resource assignment processor name")
134 println(processorName)
139 open class MockCapabilityService
141 open class MockCapabilityScriptRA : ResourceAssignmentProcessor() {
143 val log = logger(MockCapabilityScriptRA::class)
145 override fun getName(): String {
146 return "MockCapabilityScriptRA"
149 override suspend fun processNB(executionRequest: ResourceAssignment) {
150 log.info("executing RA mock capability : ${executionRequest.name}")
151 executionRequest.property!!.value = "assigned-data".asJsonPrimitive()
154 override fun process(executionRequest: ResourceAssignment) {
155 log.info("executing RA mock capability : ${executionRequest.name}")
156 executionRequest.property!!.value = "assigned-data".asJsonPrimitive()
159 override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ResourceAssignment) {
160 TODO("not implemented") // To change body of created functions use File | Settings | File Templates.