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 io.mockk.coEvery
24 import kotlinx.coroutines.runBlocking
26 import org.junit.runner.RunWith
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.blueprintsprocessor.services.execution.scripts.BlueprintJythonService
31 import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.scripts.PythonExecutorProperty
32 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
33 import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
34 import org.onap.ccsdk.cds.controllerblueprints.core.data.PropertyDefinition
35 import org.onap.ccsdk.cds.controllerblueprints.core.logger
36 import org.onap.ccsdk.cds.controllerblueprints.core.scripts.BluePrintScriptsServiceImpl
37 import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintContext
38 import org.onap.ccsdk.cds.controllerblueprints.core.utils.BluePrintMetadataUtils
39 import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
40 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceAssignment
41 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceDefinition
42 import org.springframework.beans.factory.annotation.Autowired
43 import org.springframework.test.context.ContextConfiguration
44 import org.springframework.test.context.TestPropertySource
45 import org.springframework.test.context.junit4.SpringRunner
46 import kotlin.test.assertEquals
47 import kotlin.test.assertNotNull
48 import kotlin.test.assertTrue
50 @RunWith(SpringRunner::class)
51 @ContextConfiguration(classes = [CapabilityResourceResolutionProcessor::class, ComponentFunctionScriptingService::class,
52 BluePrintScriptsServiceImpl::class,
53 BlueprintJythonService::class, PythonExecutorProperty::class, MockCapabilityService::class])
54 @TestPropertySource(properties =
55 ["blueprints.processor.functions.python.executor.modulePaths=./../../../../components/scripts/python/ccsdk_blueprints",
56 "blueprints.processor.functions.python.executor.executionPath=./../../../../components/scripts/python/ccsdk_blueprints"])
57 class CapabilityResourceResolutionProcessorTest {
60 lateinit var capabilityResourceResolutionProcessor: CapabilityResourceResolutionProcessor
63 fun `test kotlin capability`() {
65 val componentFunctionScriptingService = mockk<ComponentFunctionScriptingService>()
67 componentFunctionScriptingService
68 .scriptInstance<ResourceAssignmentProcessor>(any(), any(), any())
69 } returns MockCapabilityScriptRA()
71 val raRuntimeService = mockk<ResourceAssignmentRuntimeService>()
72 every { raRuntimeService.bluePrintContext() } returns mockk<BluePrintContext>()
74 val capabilityResourceResolutionProcessor = CapabilityResourceResolutionProcessor(componentFunctionScriptingService)
75 capabilityResourceResolutionProcessor.raRuntimeService = raRuntimeService
77 val resourceAssignment = BluePrintTypes.resourceAssignment(name = "test-property", dictionaryName = "ra-dict-name",
78 dictionarySource = "capability") {
79 property("string", true, "")
83 scriptClassReference(MockCapabilityScriptRA::class.qualifiedName!!)
84 keyDependencies(arrayListOf("dep-property"))
88 val status = capabilityResourceResolutionProcessor.applyNB(resourceAssignment)
89 assertTrue(status, "failed to execute capability source")
90 assertEquals("assigned-data".asJsonPrimitive(), resourceAssignment.property!!.value,
91 "assigned value miss match")
96 fun `test jython capability`() {
99 val bluePrintContext = BluePrintMetadataUtils.getBluePrintContext(
100 "./../../../../components/model-catalog/blueprint-model/test-blueprint/capability_python")
102 val resourceAssignmentRuntimeService = ResourceAssignmentRuntimeService("1234", bluePrintContext)
104 capabilityResourceResolutionProcessor.raRuntimeService = resourceAssignmentRuntimeService
106 val resourceDefinition = JacksonUtils
107 .readValueFromClassPathFile("mapping/capability/jython-resource-definitions.json",
108 ResourceDefinition::class.java)!!
109 val resourceDefinitions: MutableMap<String, ResourceDefinition> = mutableMapOf()
110 resourceDefinitions[resourceDefinition.name] = resourceDefinition
111 capabilityResourceResolutionProcessor.resourceDictionaries = resourceDefinitions
113 val resourceAssignment = ResourceAssignment().apply {
114 name = "service-instance-id"
115 dictionaryName = "service-instance-id"
116 dictionarySource = "capability"
117 property = PropertyDefinition().apply {
122 val processorName = capabilityResourceResolutionProcessor.processNB(resourceAssignment)
123 assertNotNull(processorName, "couldn't get Jython script resource assignment processor name")
124 println(processorName)
129 open class MockCapabilityService {
133 open class MockCapabilityScriptRA : ResourceAssignmentProcessor() {
134 val log = logger(MockCapabilityScriptRA::class)
136 override fun getName(): String {
137 return "MockCapabilityScriptRA"
140 override suspend fun processNB(executionRequest: ResourceAssignment) {
141 log.info("executing RA mock capability : ${executionRequest.name}")
142 executionRequest.property!!.value = "assigned-data".asJsonPrimitive()
145 override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ResourceAssignment) {
146 TODO("not implemented") //To change body of created functions use File | Settings | File Templates.