ms/blueprintsprocessor/functions/resource-resolution/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/resource/resolution/processor/CapabilityResourceResolutionProcessorTest.kt

   1 /*
   2  * Copyright © 2017-2018 AT&T Intellectual Property.
   3  *
   4  * Modifications Copyright © 2019 IBM, Bell Canada.
   5  *
   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
   9  *
  10  *     http://www.apache.org/licenses/LICENSE-2.0
  11  *
  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.
  17  */
  18
  19 package org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.processor
  20
  21 import com.fasterxml.jackson.databind.node.NullNode
  22 import io.mockk.coEvery
  23 import io.mockk.every
  24 import io.mockk.mockk
  25 import kotlinx.coroutines.runBlocking
  26 import org.junit.Test
  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
  43
  44 class CapabilityResourceResolutionProcessorTest {
  45
  46     @Test
  47     fun `test kotlin capability`() {
  48         runBlocking {
  49             val componentFunctionScriptingService = mockk<ComponentFunctionScriptingService>()
  50             coEvery {
  51                 componentFunctionScriptingService
  52                     .scriptInstance<ResourceAssignmentProcessor>(any(), any(), any())
  53             } returns MockCapabilityScriptRA()
  54
  55             val raRuntimeService = mockk<ResourceAssignmentRuntimeService>()
  56             every { raRuntimeService.bluePrintContext() } returns mockk<BlueprintContext>()
  57             every { raRuntimeService.getInputValue("test-property") } returns NullNode.getInstance()
  58
  59             val capabilityResourceResolutionProcessor =
  60                 CapabilityResourceResolutionProcessor(componentFunctionScriptingService)
  61             capabilityResourceResolutionProcessor.raRuntimeService = raRuntimeService
  62
  63             val resourceAssignment = BlueprintTypes.resourceAssignment(
  64                 name = "test-property", dictionaryName = "ra-dict-name",
  65                 dictionarySource = "capability"
  66             ) {
  67                 property("string", true, "")
  68                 sourceCapability {
  69                     definedProperties {
  70                         type("internal")
  71                         scriptClassReference(MockCapabilityScriptRA::class.qualifiedName!!)
  72                         keyDependencies(arrayListOf("dep-property"))
  73                     }
  74                 }
  75             }
  76             val status = capabilityResourceResolutionProcessor.applyNB(resourceAssignment)
  77             assertTrue(status, "failed to execute capability source")
  78             assertEquals(
  79                 "assigned-data".asJsonPrimitive(), resourceAssignment.property!!.value,
  80                 "assigned value miss match"
  81             )
  82         }
  83     }
  84
  85     @Test
  86     fun `test jython capability`() {
  87         runBlocking {
  88
  89             val bluePrintContext = BlueprintMetadataUtils.getBlueprintContext(
  90                 "./../../../../components/model-catalog/blueprint-model/test-blueprint/capability_python"
  91             )
  92
  93             val componentFunctionScriptingService = mockk<ComponentFunctionScriptingService>()
  94             coEvery {
  95                 componentFunctionScriptingService
  96                     .scriptInstance<ResourceAssignmentProcessor>(any(), BlueprintConstants.SCRIPT_JYTHON, any())
  97             } returns MockCapabilityScriptRA()
  98
  99             val resourceAssignmentRuntimeService = ResourceAssignmentRuntimeService("1234", bluePrintContext)
 100
 101             val capabilityResourceResolutionProcessor =
 102                 CapabilityResourceResolutionProcessor(componentFunctionScriptingService)
 103
 104             capabilityResourceResolutionProcessor.raRuntimeService = resourceAssignmentRuntimeService
 105
 106             val resourceDefinition = JacksonUtils
 107                 .readValueFromClassPathFile(
 108                     "mapping/capability/jython-resource-definitions.json",
 109                     ResourceDefinition::class.java
 110                 )!!
 111             val resourceDefinitions: MutableMap<String, ResourceDefinition> = mutableMapOf()
 112             resourceDefinitions[resourceDefinition.name] = resourceDefinition
 113             capabilityResourceResolutionProcessor.resourceDictionaries = resourceDefinitions
 114
 115             val resourceAssignment = ResourceAssignment().apply {
 116                 name = "service-instance-id"
 117                 dictionaryName = "service-instance-id"
 118                 dictionarySource = "capability"
 119                 property = PropertyDefinition().apply {
 120                     type = "string"
 121                 }
 122             }
 123
 124             val processorName = capabilityResourceResolutionProcessor.processNB(resourceAssignment)
 125             assertNotNull(processorName, "couldn't get Jython script resource assignment processor name")
 126             println(processorName)
 127         }
 128     }
 129 }
 130
 131 open class MockCapabilityService
 132
 133 open class MockCapabilityScriptRA : ResourceAssignmentProcessor() {
 134
 135     val log = logger(MockCapabilityScriptRA::class)
 136
 137     override fun getName(): String {
 138         return "MockCapabilityScriptRA"
 139     }
 140
 141     override suspend fun processNB(executionRequest: ResourceAssignment) {
 142         log.info("executing RA mock capability : ${executionRequest.name}")
 143         executionRequest.property!!.value = "assigned-data".asJsonPrimitive()
 144     }
 145
 146     override fun process(executionRequest: ResourceAssignment) {
 147         log.info("executing RA mock capability : ${executionRequest.name}")
 148         executionRequest.property!!.value = "assigned-data".asJsonPrimitive()
 149     }
 150
 151     override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ResourceAssignment) {
 152         TODO("not implemented") // To change body of created functions use File | Settings | File Templates.
 153     }
 154 }