2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018 Nokia. All rights reserved.
6 * Copyright (C) 2018 AT&T intellectual property. All rights reserved.
7 * =============================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
21 package org.onap.appc.flow.controller.node;
23 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.ACTION_LEVEL;
24 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.APPC_FLOW_CONTROLLER;
25 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.PAYLOAD;
26 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.REQUEST_ACTION;
27 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.SEQ_GENERATOR_PWD;
28 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.SEQ_GENERATOR_UID;
29 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.SEQ_GENERATOR_URL;
30 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.VNFC_NAME;
31 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.VNF_ID;
32 import static org.onap.appc.flow.controller.utils.FlowControllerConstants.VSERVER_ID;
34 import com.att.eelf.configuration.EELFLogger;
35 import com.att.eelf.configuration.EELFManager;
36 import com.fasterxml.jackson.annotation.JsonInclude.Include;
37 import com.fasterxml.jackson.core.type.TypeReference;
38 import com.fasterxml.jackson.databind.DeserializationFeature;
39 import com.fasterxml.jackson.databind.JsonNode;
40 import com.fasterxml.jackson.databind.ObjectMapper;
41 import com.fasterxml.jackson.databind.SerializationFeature;
42 import java.io.IOException;
43 import java.util.List;
44 import java.util.Properties;
45 import java.util.function.Consumer;
46 import org.apache.commons.lang3.StringUtils;
47 import org.onap.appc.flow.controller.data.Transaction;
48 import org.onap.appc.flow.controller.dbervices.FlowControlDBService;
49 import org.onap.appc.flow.controller.interfaceData.ActionIdentifier;
50 import org.onap.appc.flow.controller.interfaceData.Capabilities;
51 import org.onap.appc.flow.controller.interfaceData.DependencyInfo;
52 import org.onap.appc.flow.controller.interfaceData.Input;
53 import org.onap.appc.flow.controller.interfaceData.InventoryInfo;
54 import org.onap.appc.flow.controller.interfaceData.RequestInfo;
55 import org.onap.appc.flow.controller.interfaceData.Vnfcs;
56 import org.onap.appc.flow.controller.utils.EncryptionTool;
57 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
58 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
60 class InputParamsCollector {
62 private static final EELFLogger log = EELFManager.getInstance().getLogger(InputParamsCollector.class);
64 private final EnvVariables envVariables;
65 private final FlowControlDBService dbService;
67 static final String SDNC_CONFIG_DIR_VAR = "SDNC_CONFIG_DIR";
69 InputParamsCollector() {
70 this.envVariables = new EnvVariables();
71 this.dbService = FlowControlDBService.initialise();
74 InputParamsCollector(EnvVariables envVariables, FlowControlDBService dbService) {
75 this.envVariables = envVariables;
76 this.dbService = dbService;
79 Transaction collectInputParams(SvcLogicContext ctx) throws Exception {
81 String fn = "FlowExecuteNode.collectInputParams";
82 Properties prop = loadProperties();
83 log.info("Loaded Properties " + prop.toString());
85 String vnfId = ctx.getAttribute(VNF_ID);
86 log.debug(fn + "vnfId :" + vnfId);
88 if (StringUtils.isBlank(vnfId)) {
89 throw new Exception("VnfId is missing");
92 String resourceUri = prop.getProperty(SEQ_GENERATOR_URL);
93 log.info(fn + "resourceUri= " + resourceUri);
95 String pass = EncryptionTool.getInstance().decrypt(prop.getProperty(SEQ_GENERATOR_PWD));
97 Transaction transaction = new Transaction();
98 transaction.setPayload(getInputData(ctx, fn, vnfId));
99 transaction.setExecutionRPC("POST");
100 transaction.setuId(prop.getProperty(SEQ_GENERATOR_UID));
101 transaction.setPswd(pass);
102 transaction.setExecutionEndPoint(resourceUri);
107 private String getInputData(SvcLogicContext ctx, String fn, String vnfId) throws IOException, SvcLogicException {
108 ActionIdentifier actionIdentifier = new ActionIdentifier();
109 log.debug("Enter ActionIdentifier");
111 applyIfNotBlank(vnfId, actionIdentifier::setVnfId);
112 applyIfNotBlank(ctx.getAttribute(VSERVER_ID), actionIdentifier::setVserverId);
113 applyIfNotBlank(ctx.getAttribute(VNFC_NAME), actionIdentifier::setVnfcName);
115 log.info("ActionIdentifierData" + actionIdentifier.toString());
117 log.info("Enter RequestInfo");
118 RequestInfo requestInfo = getRequestInfo(ctx, actionIdentifier);
119 log.debug("RequestInfo: " + requestInfo.toString());
121 InventoryInfo inventoryInfo = new InventoryInfoExtractor().getInventoryInfo(ctx, vnfId);
122 Capabilities capabilities = new CapabilitiesDataExtractor(dbService).getCapabilitiesData(ctx);
123 ctx.setAttribute("artifact-content", null);
125 log.info("Enter InputData");
126 Input input = getInput(requestInfo, inventoryInfo, null, capabilities);
127 log.info(fn + "Input parameters:" + input.toString());
129 ObjectMapper mapper = new ObjectMapper();
130 mapper.setSerializationInclusion(Include.NON_NULL);
131 mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);
132 String inputData = mapper.writeValueAsString(input);
133 log.info("InputDataJson:" + inputData);
138 private Input getInput(RequestInfo requestInfo, InventoryInfo inventoryInfo,
139 DependencyInfo dependencyInfo, Capabilities capabilities) {
140 Input input = new Input();
141 input.setRequestInfo(requestInfo);
142 input.setInventoryInfo(inventoryInfo);
143 input.setDependencyInfo(dependencyInfo);
144 input.setCapabilities(capabilities);
148 private RequestInfo getRequestInfo(SvcLogicContext ctx, ActionIdentifier actionIdentifier) {
149 RequestInfo requestInfo = new RequestInfo();
150 requestInfo.setAction(ctx.getAttribute(REQUEST_ACTION));
151 requestInfo.setActionLevel(ctx.getAttribute(ACTION_LEVEL));
152 requestInfo.setPayload(ctx.getAttribute(PAYLOAD));
153 requestInfo.setActionIdentifier(actionIdentifier);
157 DependencyInfo getDependencyInfo(SvcLogicContext ctx) throws SvcLogicException, IOException {
159 String fn = "FlowExecutorNode.getDependencyInfo";
160 String dependencyData = dbService.getDependencyInfo(ctx);
161 log.info(fn + "dependencyDataInput:" + dependencyData);
163 DependencyInfo dependencyInfo = new DependencyInfo();
164 if (dependencyData == null) {
165 return dependencyInfo;
168 ObjectMapper mapper = new ObjectMapper();
169 mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
170 mapper.enable(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY);
171 //JsonNode dependencyInfoData = mapper.readTree(dependencyData).get("dependencyInfo");
172 JsonNode vnfcData = mapper.readTree(dependencyData).get("vnfcs");
173 dependencyInfo.getVnfcs().addAll(mapper.readValue(vnfcData.toString(), new TypeReference<List<Vnfcs>>(){}));
175 log.info("Dependency Output:" + dependencyInfo.toString());
176 return dependencyInfo;
179 private Properties loadProperties() throws Exception {
180 String directory = envVariables.getenv(SDNC_CONFIG_DIR_VAR);
181 if (directory == null) {
182 throw new Exception("Cannot find Property file -" + SDNC_CONFIG_DIR_VAR);
184 String path = directory + APPC_FLOW_CONTROLLER;
185 return PropertiesLoader.load(path);
188 private void applyIfNotBlank(String parameter, Consumer<String> consumer) {
189 if (StringUtils.isNotBlank(parameter)) {
190 consumer.accept(parameter);