2 * Copyright © 2017-2018 AT&T Intellectual Property.
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
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
17 package org.onap.ccsdk.apps.blueprintsprocessor.functions.resource.resolution.processor
19 import org.onap.ccsdk.apps.blueprintsprocessor.functions.resource.resolution.CapabilityResourceSource
20 import org.onap.ccsdk.apps.controllerblueprints.core.BluePrintProcessorException
21 import org.onap.ccsdk.apps.controllerblueprints.core.interfaces.BluePrintScriptsService
22 import org.onap.ccsdk.apps.controllerblueprints.core.utils.JacksonUtils
23 import org.onap.ccsdk.apps.controllerblueprints.resource.dict.ResourceAssignment
24 import org.springframework.context.ApplicationContext
25 import org.springframework.stereotype.Service
27 @Service("resource-assignment-processor-capability")
28 open class CapabilityResourceAssignmentProcessor(private var applicationContext: ApplicationContext,
29 private val bluePrintScriptsService: BluePrintScriptsService) :
30 ResourceAssignmentProcessor() {
33 const val CAPABILITY_TYPE_KOTLIN_COMPONENT = "KOTLIN-COMPONENT"
34 const val CAPABILITY_TYPE_JAVA_COMPONENT = "JAVA-COMPONENT"
35 const val CAPABILITY_TYPE_JYTHON_COMPONENT = "JYTHON-COMPONENT"
38 override fun getName(): String {
39 return "resource-assignment-processor-capability"
42 override fun process(resourceAssignment: ResourceAssignment) {
44 val resourceDefinition = resourceDictionaries[resourceAssignment.dictionaryName]
45 ?: throw BluePrintProcessorException("couldn't get resource definition for ${resourceAssignment.dictionaryName}")
47 val resourceSource = resourceDefinition.sources[resourceAssignment.dictionarySource]
48 ?: throw BluePrintProcessorException("couldn't get resource definition " +
49 "${resourceAssignment.dictionaryName} source(${resourceAssignment.dictionarySource})")
51 val resourceSourceProps = checkNotNull(resourceSource.properties) { "failed to get $resourceSource properties" }
53 * Get the Capability Resource Source Info from Property Definitions.
55 val capabilityResourceSourceProperty = JacksonUtils
56 .getInstanceFromMap(resourceSourceProps, CapabilityResourceSource::class.java)
58 val instanceType = capabilityResourceSourceProperty.type
59 val instanceName = capabilityResourceSourceProperty.instanceName
61 var componentResourceAssignmentProcessor: ResourceAssignmentProcessor? = null
64 CAPABILITY_TYPE_KOTLIN_COMPONENT -> {
65 componentResourceAssignmentProcessor = getKotlinResourceAssignmentProcessorInstance(instanceName,
66 capabilityResourceSourceProperty.instanceDependencies)
68 CAPABILITY_TYPE_JAVA_COMPONENT -> {
69 // Initialize Capability Resource Assignment Processor
70 componentResourceAssignmentProcessor = applicationContext.getBean(instanceName, ResourceAssignmentProcessor::class.java)
72 CAPABILITY_TYPE_JYTHON_COMPONENT -> {
73 TODO(" No implementation")
77 checkNotNull(componentResourceAssignmentProcessor) { "failed to get capability resource assignment processor($instanceName)" }
79 // Assign Current Blueprint runtime and ResourceDictionaries
80 componentResourceAssignmentProcessor.raRuntimeService = raRuntimeService
81 componentResourceAssignmentProcessor.resourceDictionaries = resourceDictionaries
83 // Invoke componentResourceAssignmentProcessor
84 componentResourceAssignmentProcessor.apply(resourceAssignment)
87 override fun recover(runtimeException: RuntimeException, resourceAssignment: ResourceAssignment) {
92 private fun getKotlinResourceAssignmentProcessorInstance(scriptClassName: String,
93 instanceNames: List<String>? = null): ResourceAssignmentProcessor {
94 var scriptPropertyInstances: MutableMap<String, Any>? = null
96 if (instanceNames != null && instanceNames.isNotEmpty()) {
97 scriptPropertyInstances = hashMapOf()
98 instanceNames.forEach {
99 scriptPropertyInstances[it] = applicationContext.getBean(it)
100 ?: throw BluePrintProcessorException("couldn't get the dependency instance($it)")
104 return getKotlinResourceAssignmentProcessorInstance(scriptClassName, scriptPropertyInstances)
108 fun getKotlinResourceAssignmentProcessorInstance(scriptClassName: String,
109 scriptPropertyInstances: MutableMap<String, Any>? = null):
110 ResourceAssignmentProcessor {
112 val resourceAssignmentProcessor = bluePrintScriptsService
113 .scriptInstance<ResourceAssignmentProcessor>(raRuntimeService.bluePrintContext(),
114 scriptClassName, false)
116 // Add additional Instance
117 if (scriptPropertyInstances != null) {
118 resourceAssignmentProcessor.scriptPropertyInstances = scriptPropertyInstances
121 return resourceAssignmentProcessor