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