ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/factory/ComponentNodeFactory.kt

   1 /*
   2  *  Copyright © 2017-2018 AT&T Intellectual Property.
   3  *  Modifications Copyright © 2018 IBM.
   4  *
   5  *  Licensed under the Apache License, Version 2.0 (the "License");
   6  *  you may not use this file except in compliance with the License.
   7  *  You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *  Unless required by applicable law or agreed to in writing, software
  12  *  distributed under the License is distributed on an "AS IS" BASIS,
  13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *  See the License for the specific language governing permissions and
  15  *  limitations under the License.
  16  */
  17
  18 package org.onap.ccsdk.cds.blueprintsprocessor.core.factory
  19
  20 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException
  21 import org.slf4j.LoggerFactory
  22 import org.springframework.context.ApplicationContext
  23 import org.springframework.context.ApplicationContextAware
  24
  25 /**
  26  * ComponentNode
  27  *
  28  * @author Brinda Santh
  29  */
  30 interface ComponentNode {
  31
  32     @Throws(BluePrintProcessorException::class)
  33     fun validate(context: MutableMap<String, Any>, componentContext: MutableMap<String, Any?>)
  34
  35     @Throws(BluePrintProcessorException::class)
  36     fun process(context: MutableMap<String, Any>, componentContext: MutableMap<String, Any?>)
  37
  38     @Throws(BluePrintProcessorException::class)
  39     fun errorHandle(context: MutableMap<String, Any>, componentContext: MutableMap<String, Any?>)
  40
  41     @Throws(BluePrintProcessorException::class)
  42     fun reTrigger(context: MutableMap<String, Any>, componentContext: MutableMap<String, Any?>)
  43 }
  44
  45 /**
  46  * ComponentNodeFactory
  47  *
  48  * @author Brinda Santh
  49  */
  50 open class ComponentNodeFactory : ApplicationContextAware {
  51
  52     private val log = LoggerFactory.getLogger(ComponentNodeFactory::class.java)
  53
  54     var componentNodes: MutableMap<String, ComponentNode> = hashMapOf()
  55
  56     fun getInstance(instanceName: String): ComponentNode? {
  57         log.trace("looking for Component Nodes : {}", instanceName)
  58         return componentNodes.get(instanceName)
  59     }
  60
  61     fun injectInstance(instanceName: String, componentNode: ComponentNode) {
  62         this.componentNodes[instanceName] = componentNode
  63     }
  64
  65     override fun setApplicationContext(context: ApplicationContext) {
  66         componentNodes = context.getBeansOfType(ComponentNode::class.java)
  67         log.info("Injected Component Nodes : {}", componentNodes)
  68     }
  69 }