summaryrefslogtreecommitdiffstats
path: root/blueprints-processor/plugin/assignment-provider/src/main
diff options
context:
space:
mode:
authorSingal, Kapil (ks220y) <ks220y@att.com>2018-09-04 21:57:47 -0400
committerSingal, Kapil (ks220y) <ks220y@att.com>2018-09-04 21:57:47 -0400
commitcadd88348aa9934a63849e149ddb4b60f7fbef5a (patch)
treec110b8ecead0b88841b0383ef2ce4a9ae65b4e12 /blueprints-processor/plugin/assignment-provider/src/main
parent021d63c68b4d5fbb8cf5e34549d5b17bce488df3 (diff)
Blueprints Processor MDSAL Resource Assignment
Creating SDN Blueprints Processor MDSAL Resource Assignment Processor Change-Id: I111c9682a5601f32536e93180d4357fc7ac8a961 Issue-ID: CCSDK-498 Signed-off-by: Singal, Kapil (ks220y) <ks220y@att.com>
Diffstat (limited to 'blueprints-processor/plugin/assignment-provider/src/main')
-rw-r--r--blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/processor/MdsalResourceProcessor.java239
1 files changed, 239 insertions, 0 deletions
diff --git a/blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/processor/MdsalResourceProcessor.java b/blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/processor/MdsalResourceProcessor.java
new file mode 100644
index 000000000..15528e13e
--- /dev/null
+++ b/blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/processor/MdsalResourceProcessor.java
@@ -0,0 +1,239 @@
+/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ * Modifications Copyright © 2018 IBM.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.ccsdk.config.assignment.processor;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.collections.MapUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.ccsdk.config.assignment.service.ConfigAssignmentUtils;
+import org.onap.ccsdk.config.model.ConfigModelConstant;
+import org.onap.ccsdk.config.model.ConfigModelException;
+import org.onap.ccsdk.config.model.data.ResourceAssignment;
+import org.onap.ccsdk.config.model.data.dict.ResourceDefinition;
+import org.onap.ccsdk.config.model.data.dict.SourcesDefinition;
+import org.onap.ccsdk.config.model.service.ComponentNode;
+import org.onap.ccsdk.config.model.utils.ResourceAssignmentUtils;
+import org.onap.ccsdk.config.model.utils.TransformationUtils;
+import org.onap.ccsdk.config.rest.adaptor.ConfigRestAdaptorConstants;
+import org.onap.ccsdk.config.rest.adaptor.service.ConfigRestAdaptorService;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.fasterxml.jackson.databind.JsonNode;
+
+public class MdsalResourceProcessor implements ComponentNode {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(MdsalResourceProcessor.class);
+ private ConfigRestAdaptorService configRestAdaptorService;
+ private Map<String, ResourceDefinition> dictionaries;
+
+ public MdsalResourceProcessor(ConfigRestAdaptorService configRestAdaptorService) {
+ this.configRestAdaptorService = configRestAdaptorService;
+ }
+
+ @Override
+ public Boolean preCondition(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+ return Boolean.TRUE;
+ }
+
+ @Override
+ public void preProcess(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+ // Auto-generated method stub
+ }
+
+ @Override
+ public void process(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ // Auto-generated method stub
+ }
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public void process(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+ try {
+ List<ResourceAssignment> batchResourceAssignment =
+ (List<ResourceAssignment>) componentContext.get(ConfigModelConstant.PROPERTY_RESOURCE_ASSIGNMENTS);
+ dictionaries =
+ (Map<String, ResourceDefinition>) componentContext.get(ConfigModelConstant.PROPERTY_DICTIONARIES);
+
+ if (CollectionUtils.isNotEmpty(batchResourceAssignment)) {
+ for (ResourceAssignment resourceAssignment : batchResourceAssignment) {
+ processResourceAssignmnet(ctx, componentContext, resourceAssignment);
+ }
+ }
+ } catch (Exception e) {
+ throw new SvcLogicException(String.format("MdsalResourceProcessor Exception : (%s) ", e), e);
+ }
+ }
+
+ private void processResourceAssignmnet(SvcLogicContext ctx, Map<String, Object> componentContext,
+ ResourceAssignment resourceAssignment) throws ConfigModelException, SvcLogicException {
+
+ try {
+ // Validating Resource Assignment and Dictionary Definition data
+ validate(resourceAssignment);
+
+ // Check if It has Input
+ Object value = ConfigAssignmentUtils.getContextKeyValue(ctx, resourceAssignment.getName());
+ if (value != null) {
+ logger.info("mdsal source template key ({}) found from input and value is ({})",
+ resourceAssignment.getName(), value);
+ ResourceAssignmentUtils.setResourceDataValue(componentContext, resourceAssignment, value);
+ return;
+ }
+
+ ResourceDefinition resourceDefinition = dictionaries.get(resourceAssignment.getDictionaryName());
+ SourcesDefinition sourceMdsal = resourceDefinition.getSources().get("mdsal");
+ String urlPath = sourceMdsal.getProperties().getUrlPath();
+ String path = sourceMdsal.getProperties().getPath();
+ Map<String, String> inputKeyMapping = sourceMdsal.getProperties().getInputKeyMapping();
+ Map<String, String> outputKeyMapping = sourceMdsal.getProperties().getOutputKeyMapping();
+
+ logger.info(
+ "mdsal dictionary information : urlpath ({}), path({}), inputKeyMapping ({}), outputKeyMapping ({})",
+ urlPath, path, inputKeyMapping, outputKeyMapping);
+
+ // Resolving url Variables
+ Map<String, Object> urlVariables = populateUrlVariables(inputKeyMapping, componentContext);
+ for (Map.Entry<String, Object> entry : urlVariables.entrySet()) {
+ urlPath = urlPath.replaceAll("\\$" + entry.getKey(), entry.getValue().toString());
+ }
+
+ String restResponse = fetchResourceFromMDSAL(urlPath);
+ // if restResponse is null don't call processMdsalResults to populate the value
+ if (StringUtils.isNotBlank(restResponse)) {
+ // Processing MDSAL Response
+ processMdsalResults(ctx, componentContext, resourceAssignment, sourceMdsal, restResponse);
+ } else {
+ logger.warn("Coudn't get proper mdsal Response content ({}) for Resource Name ({}) for URI ({})",
+ restResponse, resourceAssignment.getDictionaryName(), urlPath);
+ }
+
+ // Check the value has populated for mandatory case
+ ResourceAssignmentUtils.assertTemplateKeyValueNotNull(componentContext, resourceAssignment);
+ } catch (Exception e) {
+ ResourceAssignmentUtils.setFailedResourceDataValue(componentContext, resourceAssignment, e.getMessage());
+ throw new SvcLogicException(
+ String.format("Failed in assignments for (%s) with (%s)", resourceAssignment, e), e);
+ }
+ }
+
+ private String fetchResourceFromMDSAL(String urlPath) {
+ String response = null;
+ try {
+ response = configRestAdaptorService.getResource(ConfigRestAdaptorConstants.SELECTOR_RESTCONF, urlPath,
+ String.class);
+ } catch (Exception e) {
+ logger.warn("Fetching MDSAL data for URL ({}) failed with Error ({})", urlPath, e);
+ }
+ return response;
+ }
+
+ private void validate(ResourceAssignment resourceAssignment) throws SvcLogicException {
+ if (resourceAssignment == null) {
+ throw new SvcLogicException("resource assignment is not defined");
+ }
+
+ if (StringUtils.isBlank(resourceAssignment.getName())) {
+ throw new SvcLogicException("resource assignment template key is not defined");
+ }
+
+ if (StringUtils.isBlank(resourceAssignment.getDictionaryName())) {
+ throw new SvcLogicException(
+ String.format("resource assignment dictionary name is not defined for template key (%s)",
+ resourceAssignment.getName()));
+ }
+
+ if (!ConfigModelConstant.SOURCE_MDSAL.equalsIgnoreCase(resourceAssignment.getDictionarySource())) {
+ throw new SvcLogicException(String.format("resource assignment source is not mdsal, it is (%s)",
+ resourceAssignment.getDictionarySource()));
+ }
+
+ ResourceDefinition resourceDefinition = dictionaries.get(resourceAssignment.getDictionaryName());
+ if (resourceDefinition == null) {
+ throw new SvcLogicException(String.format("missing resource dictionary definition for name (%s) ",
+ resourceAssignment.getDictionaryName()));
+ }
+
+ if (StringUtils.isBlank(resourceDefinition.getProperty().getType())) {
+ throw new SvcLogicException(String.format(String.format("Failed to get dictionary (%s) data type info.",
+ resourceAssignment.getDictionaryName())));
+ }
+
+ if (resourceDefinition.getSources() == null || resourceDefinition.getSources().get("mdsal") == null) {
+ throw new SvcLogicException(
+ String.format("missing resource dictionary mdsal source definition for name (%s) ",
+ resourceAssignment.getDictionaryName()));
+ }
+
+ SourcesDefinition sourceMdsal = resourceDefinition.getSources().get("mdsal");
+ if (StringUtils.isBlank(sourceMdsal.getProperties().getUrlPath())) {
+ throw new SvcLogicException(String.format("Failed to get request URL Path for dictionary (%s)",
+ resourceAssignment.getDictionaryName()));
+ }
+
+ if (StringUtils.isBlank(sourceMdsal.getProperties().getPath())) {
+ throw new SvcLogicException(String.format("Failed to get request Path for dictionary (%s)",
+ resourceAssignment.getDictionaryName()));
+ }
+ }
+
+ private Map<String, Object> populateUrlVariables(Map<String, String> inputKeyMapping,
+ Map<String, Object> componentContext) {
+ Map<String, Object> urlVariables = new HashMap<>();
+ if (MapUtils.isNotEmpty(inputKeyMapping)) {
+
+ for (Map.Entry<String, String> mapping : inputKeyMapping.entrySet()) {
+ ResourceDefinition referenceDictionaryDefinition = dictionaries.get(mapping.getValue());
+ Object expressionValue =
+ ResourceAssignmentUtils.getDictionaryKeyValue(componentContext, referenceDictionaryDefinition);
+ logger.trace("Reference dictionary key ({}), value ({})", mapping.getKey(), expressionValue);
+ urlVariables.put(mapping.getKey(), expressionValue);
+ }
+ }
+ return urlVariables;
+ }
+
+ private void processMdsalResults(SvcLogicContext ctx, Map<String, Object> componentContext,
+ ResourceAssignment resourceAssignment, SourcesDefinition sourceMdsal, String restResponse)
+ throws SvcLogicException, ConfigModelException {
+
+ Map<String, String> outputKeyMapping = sourceMdsal.getProperties().getOutputKeyMapping();
+ JsonNode responseNode = TransformationUtils.getJsonNodeForString(restResponse);
+ if (StringUtils.isNotBlank(sourceMdsal.getProperties().getPath())) {
+ responseNode = responseNode.at(sourceMdsal.getProperties().getPath());
+ }
+ if (responseNode != null) {
+ ConfigAssignmentUtils.populateValueForOutputMapping(ctx, componentContext, resourceAssignment,
+ outputKeyMapping, responseNode);
+ }
+ }
+
+ @Override
+ public void postProcess(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+ // Do Nothing
+ }
+
+}