diff options
Diffstat (limited to 'blueprints-processor/plugin')
8 files changed, 712 insertions, 0 deletions
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNode.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNode.java new file mode 100644 index 000000000..fd8e79c49 --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNode.java @@ -0,0 +1,41 @@ +/*
+ * 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.model.service;
+
+import java.util.Map;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin;
+
+public interface ComponentNode extends SvcLogicJavaPlugin {
+
+ public Boolean preCondition(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException;
+
+ public void preProcess(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException;
+
+ public void process(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException;
+
+ public void process(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException;
+
+ public void postProcess(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException;
+
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeDelegate.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeDelegate.java new file mode 100644 index 000000000..e2d332cd9 --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeDelegate.java @@ -0,0 +1,42 @@ +/*
+ * 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.model.service;
+
+import java.util.Map;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+public class ComponentNodeDelegate implements SvcLogicJavaPlugin {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ComponentNodeDelegate.class);
+ private ComponentNodeService componentNodeService;
+
+ public ComponentNodeDelegate(ComponentNodeService componentNodeService) {
+ logger.info("{} Constructor Initiated", "ComponentNodeDelegate");
+ this.componentNodeService = componentNodeService;
+
+ }
+
+ public void process(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ this.componentNodeService.process(inParams, ctx, null);
+ }
+
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeService.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeService.java new file mode 100644 index 000000000..6c954518a --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeService.java @@ -0,0 +1,32 @@ +/*
+ * 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.model.service;
+
+import java.util.Map;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+
+public interface ComponentNodeService {
+
+ public void process(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException;
+
+ public ComponentNode getComponentNodeInterface(String pluginName, String componentType) throws SvcLogicException;
+
+ public ComponentNode getComponentNode(SvcLogicContext ctx, String selectorName) throws SvcLogicException;
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeServiceImpl.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeServiceImpl.java new file mode 100644 index 000000000..a2f1e7af3 --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ComponentNodeServiceImpl.java @@ -0,0 +1,174 @@ +/*
+ * 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.model.service;
+
+import java.util.HashMap;
+import java.util.Map;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.ccsdk.config.data.adaptor.DataAdaptorConstants;
+import org.onap.ccsdk.config.data.adaptor.domain.TransactionLog;
+import org.onap.ccsdk.config.data.adaptor.service.ConfigResourceService;
+import org.onap.ccsdk.config.model.ConfigModelConstant;
+import org.onap.ccsdk.config.model.data.InterfaceAssignment;
+import org.onap.ccsdk.config.model.data.NodeTemplate;
+import org.onap.ccsdk.config.model.utils.TransformationUtils;
+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 org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceReference;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+public class ComponentNodeServiceImpl implements ComponentNodeService {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ComponentNodeServiceImpl.class);
+
+ private BundleContext bcontext;
+ private ConfigResourceService configResourceService;
+ private ConfigModelService configModelService;
+
+ public ComponentNodeServiceImpl(BundleContext blueprintBundleContext, ConfigResourceService configResourceService,
+ ConfigRestAdaptorService configRestAdaptorService) {
+ logger.info("{} Constructor Initiated", "ComponentNodeServiceImpl");
+ this.bcontext = blueprintBundleContext;
+ this.configResourceService = configResourceService;
+ this.configModelService = new ConfigModelServiceImpl(configRestAdaptorService);
+ }
+
+ @Override
+ public void process(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+ String requestId = null;
+ String selector = null;
+ try {
+ selector = inParams.get(ConfigModelConstant.PROPERTY_SELECTOR);
+ requestId = ctx.getAttribute(ConfigModelConstant.PROPERTY_REQUEST_ID);
+
+ logger.info("Component execution started with input params ({})", inParams);
+ configModelService.assignInParamsFromModel(ctx, inParams);
+
+ String currentInterface = inParams.get(ConfigModelConstant.PROPERTY_CURRENT_INTERFACE);
+ String currentNodeDerivedFrom = inParams.get(ConfigModelConstant.PROPERTY_CURRENT_NODETYPE_DERIVED_FROM);
+
+ configResourceService.save(new TransactionLog(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_COMPONENT,
+ String.format("Executing Component (%s) derived from (%s) with Params : (%s) ", currentInterface,
+ currentNodeDerivedFrom, inParams)));
+
+ ComponentNode handler = getComponentNodeInterface(currentInterface, currentNodeDerivedFrom);
+
+ if (handler == null) {
+ throw new SvcLogicException(
+ String.format("Could not find Component for Interface %s", currentInterface));
+ }
+ if (componentContext == null) {
+ componentContext = new HashMap<>();
+ }
+
+ logger.debug("Executing component ({})", currentInterface);
+
+ if (handler.preCondition(inParams, ctx, componentContext)) {
+ handler.preProcess(inParams, ctx, componentContext);
+ handler.process(inParams, ctx, componentContext);
+ handler.postProcess(inParams, ctx, componentContext);
+ logger.debug("Executed component ({}) successfully.", currentInterface);
+ configResourceService
+ .save(new TransactionLog(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_COMPONENT,
+ String.format("Component (%s) executed successfully. ", currentInterface)));
+
+ ctx.setAttribute(selector + ConfigModelConstant.PROPERTY_DOT_STATUS,
+ ConfigModelConstant.STATUS_SUCCESS);
+ } else {
+ logger.info("Skipped component execution ({})", handler.getClass());
+ configResourceService
+ .save(new TransactionLog(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_COMPONENT,
+ String.format("Skipping component (%s) execution.", handler.getClass())));
+ ctx.setAttribute(selector + ConfigModelConstant.PROPERTY_DOT_STATUS,
+ ConfigModelConstant.STATUS_SKIPPED);
+ }
+
+ configModelService.assignOutParamsFromModel(ctx, inParams);
+ ctx.setStatus(ConfigModelConstant.STATUS_SUCCESS);
+ } catch (Exception e) {
+ logger.error(String.format("Failed in component (%s) execution for request id (%s) with error %s", selector,
+ requestId, e.getMessage()));
+ configResourceService.save(new TransactionLog(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_COMPONENT,
+ String.format("Failed in component (%s) execution for request id (%s) with error %s", selector,
+ requestId, e.getMessage())));
+
+ ctx.setAttribute(selector + ConfigModelConstant.PROPERTY_DOT_STATUS, ConfigModelConstant.STATUS_FAILURE);
+ ctx.setAttribute(selector + ConfigModelConstant.PROPERTY_DOT_ERROR_MESSAGE, e.getMessage());
+ ctx.setAttribute(ConfigModelConstant.PROPERTY_ERROR_MESSAGE, e.getMessage());
+ ctx.setStatus(ConfigModelConstant.STATUS_FAILURE);
+ throw new SvcLogicException(e.getMessage(), e);
+ }
+ }
+
+ @Override
+ public ComponentNode getComponentNodeInterface(String pluginName, String componentType) throws SvcLogicException {
+
+ logger.info("Searching for component node plugin ({}) component type ({})", pluginName, componentType);
+
+ if (StringUtils.isBlank(pluginName)) {
+ throw new SvcLogicException(
+ String.format("Could not get Interface Name from Service Template : %s ", pluginName));
+ }
+
+ pluginName = pluginName.replace("-", ".");
+ ServiceReference sref = bcontext.getServiceReference(pluginName);
+
+ if (sref == null) {
+ throw new SvcLogicException(
+ String.format("Could not find service reference object for plugin %s", pluginName));
+ }
+ return (ComponentNode) bcontext.getService(sref);
+ }
+
+ @Override
+ public ComponentNode getComponentNode(SvcLogicContext ctx, String componentKey) throws SvcLogicException {
+
+ if (StringUtils.isBlank(componentKey)) {
+ logger.warn("Can't get node template content for a component key ({})", componentKey);
+ return null;
+ }
+
+ String nodeTemplateContent = ctx.getAttribute(ConfigModelConstant.PROPERTY_NODE_TEMPLATES_DOT + componentKey);
+ logger.info("Processing component template : ({})", nodeTemplateContent);
+
+ if (StringUtils.isBlank(nodeTemplateContent)) {
+ logger.warn("Couldn't get node template content for component key ({})", componentKey);
+ return null;
+ }
+
+ NodeTemplate nodeTemplate = TransformationUtils.readValue(nodeTemplateContent, NodeTemplate.class);
+ if (nodeTemplate == null || StringUtils.isBlank(nodeTemplate.getType())) {
+ logger.warn("Failed to convert content ({}) to node template.", nodeTemplateContent);
+ return null;
+ }
+
+ ComponentNode componentNode = null;
+ for (Map.Entry<String, InterfaceAssignment> nodeTemplateInterface : nodeTemplate.getInterfaces().entrySet()) {
+ if (nodeTemplateInterface != null && nodeTemplateInterface.getValue() != null) {
+ String pluginName = nodeTemplateInterface.getKey();
+ componentNode = getComponentNodeInterface(pluginName, ConfigModelConstant.MODEL_TYPE_NODE_COMPONENT);
+ }
+ }
+ return componentNode;
+ }
+
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigBlueprintService.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigBlueprintService.java new file mode 100644 index 000000000..49c64abc9 --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigBlueprintService.java @@ -0,0 +1,100 @@ +/*
+ * 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.model.service;
+
+import java.util.List;
+import java.util.Map;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.ccsdk.config.model.ConfigModelConstant;
+import org.onap.ccsdk.config.model.domain.ConfigModel;
+import org.onap.ccsdk.config.model.domain.ConfigModelContent;
+import org.onap.ccsdk.config.model.utils.PrepareContextUtils;
+import org.onap.ccsdk.config.rest.adaptor.ConfigRestAdaptorConstants;
+import org.onap.ccsdk.config.rest.adaptor.ConfigRestAdaptorException;
+import org.onap.ccsdk.config.rest.adaptor.service.ConfigRestAdaptorService;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+public class ConfigBlueprintService {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigBlueprintService.class);
+
+ private final ConfigRestAdaptorService configRestAdaptorService;
+
+ public ConfigBlueprintService(ConfigRestAdaptorService configRestAdaptorService) {
+ this.configRestAdaptorService = configRestAdaptorService;
+ }
+
+ public Map<String, String> prepareContext(Map<String, String> context, String input, String serviceTemplateName,
+ String serviceTemplateVersion) throws SvcLogicException {
+ try {
+ PrepareContextUtils prepareContextUtils = new PrepareContextUtils();
+ String serviceTemplateContent = getServiceModel(context, serviceTemplateName, serviceTemplateVersion);
+
+ if (StringUtils.isBlank(serviceTemplateContent)) {
+ throw new SvcLogicException(String.format("Failed to get the Service Template (%s), version (%s)",
+ serviceTemplateName, serviceTemplateVersion));
+ }
+
+ return prepareContextUtils.prepareContext(context, input, serviceTemplateContent);
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage(), e);
+ }
+ }
+
+ @SuppressWarnings("squid:S3776")
+ private String getServiceModel(Map<String, String> context, String serviceTemplateName,
+ String serviceTemplateVersion) throws SvcLogicException, ConfigRestAdaptorException {
+ String content = null;
+
+ logger.info("Getting service template ({}) of version ({}) ", serviceTemplateName, serviceTemplateVersion);
+
+ String path = "configmodelbyname/" + serviceTemplateName + "/version/" + serviceTemplateVersion;
+
+ ConfigModel configModel = configRestAdaptorService
+ .getResource(ConfigRestAdaptorConstants.SELECTOR_MODEL_SERVICE, path, ConfigModel.class);
+
+ if (configModel == null || configModel.getConfigModelContents() == null
+ || configModel.getConfigModelContents().isEmpty()) {
+ throw new SvcLogicException("Service template model is missing for service template name ("
+ + serviceTemplateName + "), service template version (" + serviceTemplateVersion + ") ");
+ } else {
+ if (configModel.getPublished() == null || !configModel.getPublished().equalsIgnoreCase("Y")) {
+ throw new SvcLogicException(String.format(
+ "Service template model is not published for service template (%s) ", serviceTemplateName));
+ }
+
+ List<ConfigModelContent> configModelContents = configModel.getConfigModelContents();
+ for (ConfigModelContent configModelContent : configModelContents) {
+ if (configModelContent != null) {
+ if (ConfigModelConstant.MODEL_CONTENT_TYPE_TOSCA_JSON.equals(configModelContent.getContentType())) {
+ content = configModelContent.getContent();
+ } else if (ConfigModelConstant.MODEL_CONTENT_TYPE_TEMPLATE
+ .equals(configModelContent.getContentType())) {
+ context.put(ConfigModelConstant.PROPERTY_NODE_TEMPLATES_DOT + configModelContent.getName()
+ + ".content", configModelContent.getContent());
+ }
+ }
+ }
+ logger.trace("Service model data : {} ", content);
+ }
+ return content;
+ }
+
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelNode.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelNode.java new file mode 100644 index 000000000..3347424fe --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelNode.java @@ -0,0 +1,24 @@ +/*
+ * 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.model.service;
+
+import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin;
+
+public class ConfigModelNode implements SvcLogicJavaPlugin {
+
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelService.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelService.java new file mode 100644 index 000000000..0c112baa8 --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelService.java @@ -0,0 +1,55 @@ +/*
+ * 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.model.service;
+
+import java.util.List;
+import java.util.Map;
+import org.onap.ccsdk.config.model.data.ServiceTemplate;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+
+public interface ConfigModelService {
+
+ public Boolean validateServiceTemplate(ServiceTemplate serviceTemplate) throws SvcLogicException;
+
+ public Map<String, String> prepareContext(Map<String, String> context, String input, String serviceTemplateName,
+ String serviceTemplateVersion) throws SvcLogicException;
+
+ public Map<String, String> prepareContext(Map<String, String> context, String input, String serviceTemplateContent)
+ throws SvcLogicException;
+
+ public Map<String, String> convertJson2properties(Map<String, String> context, String jsonContent,
+ List<String> blockKeys) throws SvcLogicException;
+
+ public Map<String, String> convertServiceTemplate2Properties(String serviceTemplateContent,
+ final Map<String, String> context) throws SvcLogicException;
+
+ public Map<String, String> convertServiceTemplate2Properties(ServiceTemplate serviceTemplate,
+ final Map<String, String> context) throws SvcLogicException;
+
+ public SvcLogicContext assignInParamsFromModel(final SvcLogicContext context, final Map<String, String> inParams)
+ throws SvcLogicException;
+
+ public SvcLogicContext assignOutParamsFromModel(final SvcLogicContext context, final Map<String, String> inParams)
+ throws SvcLogicException;
+
+ public String getNodeTemplateContent(final SvcLogicContext context, String templateName) throws SvcLogicException;
+
+ public String getNodeTemplateMapping(final SvcLogicContext context, String templateName) throws SvcLogicException;
+
+}
diff --git a/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelServiceImpl.java b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelServiceImpl.java new file mode 100644 index 000000000..a3014b6b8 --- /dev/null +++ b/blueprints-processor/plugin/model-provider/src/main/java/org/onap/ccsdk/config/model/service/ConfigModelServiceImpl.java @@ -0,0 +1,244 @@ +/*
+ * 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.model.service;
+
+import java.util.List;
+import java.util.Map;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.ccsdk.config.model.ConfigModelConstant;
+import org.onap.ccsdk.config.model.ConfigModelException;
+import org.onap.ccsdk.config.model.data.CapabilityAssignment;
+import org.onap.ccsdk.config.model.data.NodeTemplate;
+import org.onap.ccsdk.config.model.data.NodeType;
+import org.onap.ccsdk.config.model.data.ServiceTemplate;
+import org.onap.ccsdk.config.model.utils.NodePropertyUtils;
+import org.onap.ccsdk.config.model.utils.PrepareContextUtils;
+import org.onap.ccsdk.config.model.utils.ServiceTemplateUtils;
+import org.onap.ccsdk.config.model.utils.TransformationUtils;
+import org.onap.ccsdk.config.model.validator.ServiceTemplateValidator;
+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;
+
+public class ConfigModelServiceImpl implements ConfigModelService {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigModelServiceImpl.class);
+ private static final String CLASS_NAME = "ConfigModelServiceImpl";
+
+ private final ConfigRestAdaptorService configRestAdaptorService;
+
+ public ConfigModelServiceImpl(ConfigRestAdaptorService configRestAdaptorService) {
+ logger.info("{} Constuctor Initated...", CLASS_NAME);
+ this.configRestAdaptorService = configRestAdaptorService;
+ }
+
+ @Override
+ public Boolean validateServiceTemplate(ServiceTemplate serviceTemplate) throws SvcLogicException {
+ try {
+ ServiceTemplateValidator serviceTemplateValidator = new ServiceTemplateValidator();
+ return serviceTemplateValidator.validateServiceTemplate(serviceTemplate);
+ } catch (ConfigModelException e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ }
+
+ @Override
+ public Map<String, String> prepareContext(Map<String, String> context, String input, String serviceTemplateName,
+ String serviceTemplateVersion) throws SvcLogicException {
+
+ ConfigBlueprintService configBlueprintService = new ConfigBlueprintService(configRestAdaptorService);
+ return configBlueprintService.prepareContext(context, input, serviceTemplateName, serviceTemplateVersion);
+ }
+
+ @Override
+ public Map<String, String> prepareContext(Map<String, String> context, String input, String serviceTemplateContent)
+ throws SvcLogicException {
+ try {
+ PrepareContextUtils prepareContextUtils = new PrepareContextUtils();
+ return prepareContextUtils.prepareContext(context, input, serviceTemplateContent);
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ }
+
+ @Override
+ public Map<String, String> convertJson2properties(Map<String, String> context, String jsonContent,
+ List<String> blockKeys) throws SvcLogicException {
+ try {
+ return TransformationUtils.convertJson2Properties(context, jsonContent, blockKeys);
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ }
+
+ @Override
+ public Map<String, String> convertServiceTemplate2Properties(String serviceTemplateContent,
+ final Map<String, String> context) throws SvcLogicException {
+ try {
+ ServiceTemplateUtils serviceTemplateUtils = new ServiceTemplateUtils();
+ return serviceTemplateUtils.convertServiceTemplate2Properties(serviceTemplateContent, context);
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ }
+
+ @Override
+ public Map<String, String> convertServiceTemplate2Properties(ServiceTemplate serviceTemplate,
+ final Map<String, String> context) throws SvcLogicException {
+ try {
+ ServiceTemplateUtils serviceTemplateUtils = new ServiceTemplateUtils();
+ return serviceTemplateUtils.convertServiceTemplate2Properties(serviceTemplate, context);
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ }
+
+ @SuppressWarnings("squid:S3776")
+ @Override
+ public SvcLogicContext assignInParamsFromModel(final SvcLogicContext context, final Map<String, String> inParams)
+ throws SvcLogicException {
+ logger.debug("Processing component input param ({})", inParams);
+ try {
+ if (context != null && inParams != null && inParams.containsKey(ConfigModelConstant.PROPERTY_SELECTOR)) {
+ String componentKey = inParams.get(ConfigModelConstant.PROPERTY_SELECTOR);
+ if (StringUtils.isNotBlank(componentKey)) {
+ String nodeTemplateContent =
+ context.getAttribute(ConfigModelConstant.PROPERTY_NODE_TEMPLATES_DOT + componentKey);
+ logger.info("Processing node template content ({})", nodeTemplateContent);
+ if (StringUtils.isNotBlank(nodeTemplateContent)) {
+ NodeTemplate nodeTemplate =
+ TransformationUtils.readValue(nodeTemplateContent, NodeTemplate.class);
+ if (nodeTemplate != null && StringUtils.isNotBlank(nodeTemplate.getType())) {
+ String nodeTypeContent = context
+ .getAttribute(ConfigModelConstant.PROPERTY_NODE_TYPES_DOT + nodeTemplate.getType());
+ NodeType nodetype = TransformationUtils.readValue(nodeTypeContent, NodeType.class);
+ if (nodetype != null) {
+ inParams.put(ConfigModelConstant.PROPERTY_CURRENT_NODETYPE_DERIVED_FROM,
+ nodetype.getDerivedFrom());
+ NodePropertyUtils nodePropertyUtils = new NodePropertyUtils(context, inParams);
+ nodePropertyUtils.assignInParamsFromModel(nodetype, nodeTemplate);
+ } else {
+ throw new SvcLogicException(
+ String.format("Failed to get node type (%s) for node template (%s).",
+ nodeTemplate.getType(), componentKey));
+ }
+
+ } else {
+ throw new SvcLogicException(String
+ .format("Failed to convert content (%s) to node template.", nodeTemplateContent));
+ }
+ } else {
+ throw new SvcLogicException(String
+ .format("Couldn't get node template content for component key (%s).", componentKey));
+ }
+ } else {
+ throw new SvcLogicException(
+ String.format("Couldn't get component key (prefix) from inparam (%s)", inParams));
+ }
+ }
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ return context;
+ }
+
+ @Override
+ public SvcLogicContext assignOutParamsFromModel(final SvcLogicContext context, final Map<String, String> inParams)
+ throws SvcLogicException {
+ try {
+ if (context != null && inParams != null && inParams.containsKey(ConfigModelConstant.PROPERTY_SELECTOR)) {
+ String componentKey = inParams.get(ConfigModelConstant.PROPERTY_SELECTOR);
+ logger.info("Processing component output for prefix key ({})", componentKey);
+ if (StringUtils.isNotBlank(componentKey)) {
+ String nodeTemplateContent =
+ context.getAttribute(ConfigModelConstant.PROPERTY_NODE_TEMPLATES_DOT + componentKey);
+ if (StringUtils.isNotBlank(nodeTemplateContent)) {
+ NodeTemplate nodeTemplate =
+ TransformationUtils.readValue(nodeTemplateContent, NodeTemplate.class);
+ if (nodeTemplate != null && StringUtils.isNotBlank(nodeTemplate.getType())) {
+ String nodeTypeContent = context
+ .getAttribute(ConfigModelConstant.PROPERTY_NODE_TYPES_DOT + nodeTemplate.getType());
+ NodeType nodetype = TransformationUtils.readValue(nodeTypeContent, NodeType.class);
+ NodePropertyUtils nodePropertyUtils = new NodePropertyUtils(context, inParams);
+ nodePropertyUtils.assignOutParamsFromModel(nodetype, nodeTemplate);
+ }
+ }
+ }
+ }
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ return context;
+ }
+
+ @Override
+ public String getNodeTemplateContent(final SvcLogicContext context, String templateName) throws SvcLogicException {
+ String content = null;
+ try {
+ if (context != null && StringUtils.isNotBlank(templateName)) {
+ logger.info("Processing Artifact Node Template for content : ({})", templateName);
+ content = context
+ .getAttribute(ConfigModelConstant.PROPERTY_NODE_TEMPLATES_DOT + templateName + ".content");
+ }
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ return content;
+ }
+
+ @SuppressWarnings("squid:S3776")
+ @Override
+ public String getNodeTemplateMapping(final SvcLogicContext context, String templateName) throws SvcLogicException {
+ String mapping = null;
+ try {
+ if (context != null && StringUtils.isNotBlank(templateName)) {
+ logger.info("Processing artifact node template for mapping : ({})", templateName);
+ if (StringUtils.isNotBlank(templateName)) {
+ String nodeTemplateContent =
+ context.getAttribute(ConfigModelConstant.PROPERTY_NODE_TEMPLATES_DOT + templateName);
+ if (StringUtils.isNotBlank(nodeTemplateContent)) {
+
+ NodeTemplate nodeTemplate =
+ TransformationUtils.readValue(nodeTemplateContent, NodeTemplate.class);
+
+ if (nodeTemplate != null && nodeTemplate.getCapabilities() != null && nodeTemplate
+ .getCapabilities().containsKey(ConfigModelConstant.CAPABILITY_PROPERTY_MAPPING)) {
+
+ CapabilityAssignment capability =
+ nodeTemplate.getCapabilities().get(ConfigModelConstant.CAPABILITY_PROPERTY_MAPPING);
+ if (capability.getProperties() != null) {
+ List mappingList = (List) capability.getProperties()
+ .get(ConfigModelConstant.CAPABILITY_PROPERTY_MAPPING);
+ if (mappingList != null) {
+ mapping = TransformationUtils.getJson(mappingList);
+ }
+
+ }
+ }
+ }
+ }
+ }
+ } catch (Exception e) {
+ throw new SvcLogicException(e.getMessage());
+ }
+ return mapping;
+ }
+
+}
|