diff options
Diffstat (limited to 'blueprints-processor/plugin/assignment-provider/src')
2 files changed, 477 insertions, 0 deletions
diff --git a/blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/service/ConfigAssignmentNode.java b/blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/service/ConfigAssignmentNode.java new file mode 100644 index 000000000..8ed0b71fc --- /dev/null +++ b/blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/config/assignment/service/ConfigAssignmentNode.java @@ -0,0 +1,231 @@ +/*
+ * 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.service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.apache.commons.collections.MapUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.ccsdk.config.assignment.ConfigAssignmentConstants;
+import org.onap.ccsdk.config.assignment.data.ResourceAssignmentData;
+import org.onap.ccsdk.config.data.adaptor.service.ConfigResourceService;
+import org.onap.ccsdk.config.generator.service.ConfigGeneratorService;
+import org.onap.ccsdk.config.model.ConfigModelConstant;
+import org.onap.ccsdk.config.model.service.ComponentNode;
+import org.onap.ccsdk.config.model.service.ComponentNodeService;
+import org.onap.ccsdk.config.model.service.ConfigModelService;
+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 com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+public class ConfigAssignmentNode implements ComponentNode {
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigAssignmentNode.class);
+
+ private ComponentNodeService componentNodeService;
+ private ConfigResourceService configResourceService;
+ private ConfigModelService configModelService;
+ private ConfigRestAdaptorService configRestAdaptorService;
+ private ConfigGeneratorService configGeneratorService;
+
+ public ConfigAssignmentNode(ConfigResourceService configResourceService,
+ ConfigRestAdaptorService configRestAdaptorService, ConfigModelService configModelService,
+ ComponentNodeService componentNodeService, ConfigGeneratorService configGeneratorService) {
+ logger.info("{} Constrctor Initiated", "ConfigAssignmentNode");
+ this.componentNodeService = componentNodeService;
+ this.configResourceService = configResourceService;
+ this.configModelService = configModelService;
+ this.configRestAdaptorService = configRestAdaptorService;
+ this.configGeneratorService = configGeneratorService;
+ }
+
+ @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
+ }
+
+ /**
+ * This method is used to resolve the resources defined in the template. Generic Resource API DG
+ * calls this execute node.
+ *
+ * @param inParams This is the input parameter to process this node
+ *
+ * <pre>
+ request-id (string): Tracking Id
+ resource-type (string): Resource Type ( ex : vnf-type)
+ resource-id (string): Resource Id
+ service-template-name (string): Blueprint Name
+ service-template-version (string): Blueprint Version
+ action-name (string):
+ template-names (List of string): Template Names / Artifact Node Names to resolve. ["template1", "template2"]
+ input-data (string): Input Data in JSON String, for the substitution in the Template.
+ prifix (string): Return Value selector
+ * </pre>
+ *
+ * @param ctx This is the service logger context, Output will be stored (
+ * <responsePrefix>.resource-assignment-params.<template-name> : Output Data in JSON String.
+ * <responsePrefix>.status <responsePrefix>.error-message )
+ * @throws SvcLogicException On processing error.
+ */
+
+ @Override
+ public void process(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+
+ final String responsePrefix = StringUtils.isNotBlank(inParams.get(ConfigModelConstant.PROPERTY_SELECTOR))
+ ? (inParams.get(ConfigModelConstant.PROPERTY_SELECTOR) + ".")
+ : "";
+ try {
+
+ ResourceAssignmentData resourceAssignmentData = populateResourceData(inParams);
+ resourceAssignmentData.setSvcLogicContext(ctx);
+ Map<String, Object> componentContext = new HashMap<>();
+ resourceAssignmentData.setContext(componentContext);
+ resourceAssignmentData.setReloadModel(true);
+
+ ConfigAssignmentProcessService configAssignmentProcessService =
+ new ConfigAssignmentProcessService(configResourceService, configRestAdaptorService,
+ configModelService, componentNodeService, configGeneratorService);
+ configAssignmentProcessService.resolveResources(resourceAssignmentData);
+
+ if (MapUtils.isNotEmpty(resourceAssignmentData.getTemplatesMashedContents())) {
+ resourceAssignmentData.getTemplatesMashedContents().forEach((templateName, previewContent) -> {
+ logger.debug("For Template name : ({}),\n Preview Content is : ({})", templateName, previewContent);
+ ctx.setAttribute(
+ responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_MASHED_DATA + "." + templateName,
+ previewContent);
+ });
+ }
+ ctx.setAttribute(responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_STATUS,
+ ConfigAssignmentConstants.OUTPUT_STATUS_SUCCESS);
+ } catch (Exception e) {
+ ctx.setAttribute(responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_STATUS,
+ ConfigAssignmentConstants.OUTPUT_STATUS_FAILURE);
+ ctx.setAttribute(responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
+ throw new SvcLogicException(e.getMessage(), e);
+ }
+ }
+
+ @Override
+ public void process(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+
+ final String responsePrefix = StringUtils.isNotBlank(inParams.get(ConfigModelConstant.PROPERTY_SELECTOR))
+ ? (inParams.get(ConfigModelConstant.PROPERTY_SELECTOR) + ".")
+ : "";
+ try {
+
+ ResourceAssignmentData resourceAssignmentData = populateResourceData(inParams);
+ resourceAssignmentData.setSvcLogicContext(ctx);
+ resourceAssignmentData.setContext(componentContext);
+ resourceAssignmentData.setReloadModel(false);
+
+ ConfigAssignmentProcessService configAssignmentProcessService =
+ new ConfigAssignmentProcessService(configResourceService, configRestAdaptorService,
+ configModelService, componentNodeService, configGeneratorService);
+ configAssignmentProcessService.resolveResources(resourceAssignmentData);
+ ctx.setAttribute(responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_STATUS,
+ ConfigAssignmentConstants.OUTPUT_STATUS_SUCCESS);
+
+ } catch (Exception e) {
+ ctx.setAttribute(responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_STATUS,
+ ConfigAssignmentConstants.OUTPUT_STATUS_FAILURE);
+ ctx.setAttribute(responsePrefix + ConfigAssignmentConstants.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
+ throw new SvcLogicException(e.getMessage(), e);
+ }
+ }
+
+ @Override
+ public void postProcess(Map<String, String> inParams, SvcLogicContext ctx, Map<String, Object> componentContext)
+ throws SvcLogicException {
+ // Do Nothing
+ }
+
+ private ResourceAssignmentData populateResourceData(Map<String, String> inParams) throws SvcLogicException {
+ validateInputParams(inParams);
+
+ String requestId = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_REQUEST_ID);
+ String resourceId = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_ID);
+ String resourceType = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_TYPE);
+ String serviceTemplateName = inParams.get(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_NAME);
+ String serviceTemplateVersion = inParams.get(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_VERSION);
+ String actionName = inParams.get(ConfigModelConstant.PROPERTY_ACTION_NAME);
+ String inputData = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_INPUT_DATA);
+
+ String templateNamesStr = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_TEMPLATE_NAMES);
+ List<String> templateNames = TransformationUtils.getListfromJson(templateNamesStr, String.class);
+
+ ResourceAssignmentData resourceAssignmentData = new ResourceAssignmentData();
+ resourceAssignmentData.setRequestId(requestId);
+ resourceAssignmentData.setResourceId(resourceId);
+ resourceAssignmentData.setResourceType(resourceType);
+ resourceAssignmentData.setServiceTemplateName(serviceTemplateName);
+ resourceAssignmentData.setServiceTemplateVersion(serviceTemplateVersion);
+ resourceAssignmentData.setActionName(actionName);
+ resourceAssignmentData.setInputData(inputData);
+ resourceAssignmentData.setTemplateNames(templateNames);
+
+ return resourceAssignmentData;
+ }
+
+ private void validateInputParams(Map<String, String> inParams) throws SvcLogicException {
+ if (inParams == null) {
+ throw new SvcLogicException("Input parameters missing");
+ }
+
+ String requestId = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_REQUEST_ID);
+ if (StringUtils.isBlank(requestId)) {
+ throw new SvcLogicException("Request id parameters missing");
+ }
+ String resourceId = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_ID);
+ if (StringUtils.isBlank(resourceId)) {
+ throw new SvcLogicException("Resource id parameter is missing");
+ }
+ String resourceType = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_TYPE);
+ if (StringUtils.isBlank(resourceType)) {
+ throw new SvcLogicException("Resource type parameter is missing");
+ }
+ String recipeName = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_ACTION_NAME);
+ if (StringUtils.isBlank(recipeName)) {
+ throw new SvcLogicException("Action name is parameter is missing");
+ }
+ String templateNames = inParams.get(ConfigAssignmentConstants.INPUT_PARAM_TEMPLATE_NAMES);
+ if (StringUtils.isBlank(templateNames)) {
+ throw new SvcLogicException("Template names parameter missing");
+ }
+ String serviceTemplateName = inParams.get(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_NAME);
+ if (StringUtils.isBlank(serviceTemplateName)) {
+ throw new SvcLogicException("Service Template name parameter missing");
+ }
+ String serviceTemplateVersion = inParams.get(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_VERSION);
+ if (StringUtils.isBlank(serviceTemplateVersion)) {
+ throw new SvcLogicException("Service Template version parameter missing");
+ }
+
+ }
+
+}
diff --git a/blueprints-processor/plugin/assignment-provider/src/test/java/org/onap/ccsdk/config/assignment/service/ConfigAssignmentNodeTest.java b/blueprints-processor/plugin/assignment-provider/src/test/java/org/onap/ccsdk/config/assignment/service/ConfigAssignmentNodeTest.java new file mode 100644 index 000000000..9ad94dcd0 --- /dev/null +++ b/blueprints-processor/plugin/assignment-provider/src/test/java/org/onap/ccsdk/config/assignment/service/ConfigAssignmentNodeTest.java @@ -0,0 +1,246 @@ +/*
+ * 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.service;
+
+import java.io.File;
+import java.nio.charset.Charset;
+import java.util.HashMap;
+import java.util.Map;
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.sling.testing.mock.osgi.MockOsgi;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.mockito.runners.MockitoJUnitRunner;
+import org.onap.ccsdk.config.assignment.ConfigAssignmentConstants;
+import org.onap.ccsdk.config.data.adaptor.service.ConfigResourceService;
+import org.onap.ccsdk.config.generator.service.ConfigGeneratorService;
+import org.onap.ccsdk.config.generator.service.ConfigGeneratorServiceImpl;
+import org.onap.ccsdk.config.model.ConfigModelConstant;
+import org.onap.ccsdk.config.model.service.ComponentNodeDelegate;
+import org.onap.ccsdk.config.model.service.ComponentNodeService;
+import org.onap.ccsdk.config.model.service.ComponentNodeServiceImpl;
+import org.onap.ccsdk.config.model.service.ConfigModelService;
+import org.onap.ccsdk.config.model.service.ConfigModelServiceImpl;
+import org.onap.ccsdk.config.rest.adaptor.service.ConfigRestAdaptorService;
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.osgi.framework.BundleContext;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+@RunWith(MockitoJUnitRunner.class)
+public class ConfigAssignmentNodeTest {
+
+ private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigAssignmentNodeTest.class);
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Mock
+ private ConfigResourceService configResourceService;
+
+ @Mock
+ private ConfigRestAdaptorService configRestAdaptorService;
+
+ private ConfigModelService configModelService;
+
+ private ComponentNodeService componentNodeService;
+
+ private ConfigGeneratorService configGeneratorService;
+
+ BundleContext bundleContext = MockOsgi.newBundleContext();
+
+ @SuppressWarnings("unchecked")
+ @Before
+ public void before() throws Exception {
+ MockitoAnnotations.initMocks(this);
+ /*
+ * ConfigAssignmentNode configAssignmentNode = new ConfigAssignmentNode(componentNodeService,
+ * configResourceService, configModelService, configRestAdaptorService, configGeneratorService);
+ * bundleContext.registerService(ConfigAssignmentNode.class, configAssignmentNode, null);
+ */
+ }
+
+ @Test
+ public void testResourceAssignment() throws Exception {
+ ConfigResourceAssignmentTestUtils.injectTransactionLogSaveMock(configResourceService);
+
+ ConfigResourceAssignmentTestUtils.injectConfigModelMock(configRestAdaptorService, "resource_assignment");
+
+ ConfigResourceAssignmentTestUtils.injectResourceDictionaryMock(configRestAdaptorService,
+ "assignments/empty-dictionary.json");
+
+ ConfigResourceAssignmentTestUtils.injectConfigResourceSaveMock(configResourceService);
+
+ componentNodeService =
+ new ComponentNodeServiceImpl(bundleContext, configResourceService, configRestAdaptorService);
+ configModelService = new ConfigModelServiceImpl(configRestAdaptorService);
+ configGeneratorService = new ConfigGeneratorServiceImpl(configResourceService);
+
+ ConfigAssignmentNode configAssignmentNode = new ConfigAssignmentNode(configResourceService,
+ configRestAdaptorService, configModelService, componentNodeService, configGeneratorService);
+
+ String inputContent = FileUtils.readFileToString(
+ new File("src/test/resources/service_templates/input/input.json"), Charset.defaultCharset());
+
+ Map<String, String> inParams = new HashMap<>();
+ inParams.put(ConfigModelConstant.PROPERTY_SELECTOR, "test");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_REQUEST_ID, "1234");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_ID, "resourceid-1234");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_TYPE, "vnf-type");
+ inParams.put(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_NAME, "vpe-201802-baseconfig");
+ inParams.put(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_VERSION, "1.0.0");
+ inParams.put(ConfigModelConstant.PROPERTY_ACTION_NAME, "resource-assignment-action");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_INPUT_DATA, inputContent);
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_TEMPLATE_NAMES, "[\"base-config-template\"]");
+
+ // Populate the SvcContext ( Simulation)
+ SvcLogicContext svcLogicContext = new SvcLogicContext();
+ Map<String, String> context = new HashMap<>();
+ context.put(ConfigModelConstant.PROPERTY_ACTION_NAME, "resource-assignment-action");
+ context = configModelService.prepareContext(context, inputContent, "vpe-201802-baseconfig", "1.0.0");
+ context.forEach((key, value) -> svcLogicContext.setAttribute(key, value));
+
+ Map<String, Object> componentContext = new HashMap<>();
+ configAssignmentNode.process(inParams, svcLogicContext, componentContext);
+ Assert.assertNotNull("Failed to get response status", svcLogicContext.getAttribute("test.status"));
+
+ }
+
+ @Test
+ public void testSimplePreview() throws Exception {
+ ConfigResourceAssignmentTestUtils.injectTransactionLogSaveMock(configResourceService);
+
+ ConfigResourceAssignmentTestUtils.injectConfigModelMock(configRestAdaptorService, "resource_assignment");
+
+ ConfigResourceAssignmentTestUtils.injectResourceDictionaryMock(configRestAdaptorService,
+ "assignments/empty-dictionary.json");
+
+ ConfigResourceAssignmentTestUtils.injectConfigResourceSaveMock(configResourceService);
+
+ componentNodeService =
+ new ComponentNodeServiceImpl(bundleContext, configResourceService, configRestAdaptorService);
+ configModelService = new ConfigModelServiceImpl(configRestAdaptorService);
+ configGeneratorService = new ConfigGeneratorServiceImpl(configResourceService);
+
+ ConfigAssignmentNode configAssignmentNode = new ConfigAssignmentNode(configResourceService,
+ configRestAdaptorService, configModelService, componentNodeService, configGeneratorService);
+
+ String inputContent = FileUtils.readFileToString(
+ new File("src/test/resources/service_templates/input/input.json"), Charset.defaultCharset());
+
+ Map<String, String> inParams = new HashMap<>();
+ inParams.put(ConfigModelConstant.PROPERTY_SELECTOR, "test");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_REQUEST_ID, "1234");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_ID, "resourceid-1234");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_TYPE, "vnf-type");
+ inParams.put(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_NAME, "vpe-201802-baseconfig");
+ inParams.put(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_VERSION, "1.0.0");
+ inParams.put(ConfigModelConstant.PROPERTY_ACTION_NAME, "resource-assignment-action");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_INPUT_DATA, inputContent);
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_TEMPLATE_NAMES, "[\"base-config-template\"]");
+ SvcLogicContext ctx = new SvcLogicContext();
+ configAssignmentNode.process(inParams, ctx);
+ Assert.assertNotNull("Failed to get response mashed Content",
+ ctx.getAttribute("test.mashed-data.base-config-template"));
+ }
+
+ @Test
+ public void testComplexPreview() throws Exception {
+ ConfigResourceAssignmentTestUtils.injectTransactionLogSaveMock(configResourceService);
+
+ ConfigResourceAssignmentTestUtils.injectConfigModelMock(configRestAdaptorService, "vpe-201802-baseconfig");
+
+ ConfigResourceAssignmentTestUtils.injectResourceDictionaryMock(configRestAdaptorService,
+ "service_templates/vpe-201802-baseconfig/dict.json");
+
+ ConfigResourceAssignmentTestUtils.injectConfigResourceSaveMock(configResourceService);
+
+ componentNodeService =
+ new ComponentNodeServiceImpl(bundleContext, configResourceService, configRestAdaptorService);
+ configModelService = new ConfigModelServiceImpl(configRestAdaptorService);
+ configGeneratorService = new ConfigGeneratorServiceImpl(configResourceService);
+
+ ConfigAssignmentNode configAssignmentNode = new ConfigAssignmentNode(configResourceService,
+ configRestAdaptorService, configModelService, componentNodeService, configGeneratorService);
+
+ String inputContent = FileUtils.readFileToString(
+ new File("src/test/resources/service_templates/vpe-201802-baseconfig/input-complex.json"),
+ Charset.defaultCharset());
+
+ Map<String, String> inParams = new HashMap<>();
+ inParams.put(ConfigModelConstant.PROPERTY_SELECTOR, "complex-test");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_REQUEST_ID, "request-1234");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_ID, "resourceid-1234");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_TYPE, "vnf-type");
+ inParams.put(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_NAME, "vpe-201802-baseconfig");
+ inParams.put(ConfigModelConstant.SERVICE_TEMPLATE_KEY_ARTIFACT_VERSION, "1.0.0");
+ inParams.put(ConfigModelConstant.PROPERTY_ACTION_NAME, "resource-assignment-action");
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_INPUT_DATA, inputContent);
+ inParams.put(ConfigAssignmentConstants.INPUT_PARAM_TEMPLATE_NAMES, "[\"base-config-template\"]");
+ SvcLogicContext ctx = new SvcLogicContext();
+ configAssignmentNode.process(inParams, ctx);
+ Assert.assertNotNull("Failed to get response mashed Content",
+ ctx.getAttribute("complex-test.mashed-data.base-config-template"));
+
+ }
+
+ @Test
+ public void inputValidator() {
+ SvcLogicContext ctx = new SvcLogicContext();
+ try {
+
+ logger.info(" ******************************* inputValidator ***************************");
+ String serviceTemplateContent = FileUtils.readFileToString(
+ new File("src/test/resources/service_templates/resource_assignment.json"),
+ Charset.defaultCharset());
+
+ String inputcontent = FileUtils.readFileToString(
+ new File("src/test/resources/service_templates/input/inputValidateTest.json"),
+ Charset.defaultCharset());
+
+ Map<String, String> context = new HashMap<>();
+ configModelService.prepareContext(context, inputcontent, serviceTemplateContent);
+
+ // TransformationUtils.printMap(context);
+
+ context.forEach((name, value) -> {
+ if (StringUtils.isNotBlank(name) && StringUtils.isNotBlank(value)) {
+ ctx.setAttribute(name, value);
+ }
+ });
+
+ ComponentNodeDelegate componentNodeDelegate = new ComponentNodeDelegate(componentNodeService);
+ Map<String, String> inParams = new HashMap<>();
+ inParams.put(ConfigModelConstant.PROPERTY_SELECTOR, "resource-assignment");
+ componentNodeDelegate.process(inParams, ctx);
+ Assert.fail();
+ } catch (Exception e) {
+ logger.error("Failed in inputValidator" + e.getMessage());
+ logger.info("** ctx.getAttribute Check for **" + ctx.getAttribute("resource-assignment.error-message"));
+ }
+
+ }
+
+}
|