blueprints-processor/plugin/assignment-provider/src/main/java/org/onap/ccsdk/features/assignment/service/ConfigAssignmentProcessService.java

   1 /*\r
   2  * Copyright © 2017-2018 AT&T Intellectual Property.\r
   3  * Modifications Copyright © 2018 IBM.\r
   4  * \r
   5  * Licensed under the Apache License, Version 2.0 (the "License");\r
   6  * you may not use this file except in compliance with the License.\r
   7  * You may obtain a copy of the License at\r
   8  * \r
   9  * http://www.apache.org/licenses/LICENSE-2.0\r
  10  * \r
  11  * Unless required by applicable law or agreed to in writing, software\r
  12  * distributed under the License is distributed on an "AS IS" BASIS,\r
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  14  * See the License for the specific language governing permissions and\r
  15  * limitations under the License.\r
  16  */\r
  17 \r
  18 package org.onap.ccsdk.features.assignment.service;\r
  19 \r
  20 import java.util.HashMap;\r
  21 import java.util.List;\r
  22 import java.util.Map;\r
  23 import org.apache.commons.collections.CollectionUtils;\r
  24 import org.apache.commons.lang3.StringUtils;\r
  25 import org.onap.ccsdk.features.assignment.ConfigAssignmentConstants;\r
  26 import org.onap.ccsdk.features.assignment.data.ResourceAssignmentData;\r
  27 import org.onap.ccsdk.features.assignment.processor.ProcessorFactory;\r
  28 import org.onap.ccsdk.features.assignment.processor.ResourceAssignmentProcessor;\r
  29 import org.onap.ccsdk.features.data.adaptor.service.ConfigResourceService;\r
  30 import org.onap.ccsdk.features.generator.service.ConfigGeneratorService;\r
  31 import org.onap.ccsdk.features.model.ConfigModelConstant;\r
  32 import org.onap.ccsdk.features.model.data.ResourceAssignment;\r
  33 import org.onap.ccsdk.features.model.data.dict.ResourceDefinition;\r
  34 import org.onap.ccsdk.features.model.service.ComponentNode;\r
  35 import org.onap.ccsdk.features.model.service.ComponentNodeService;\r
  36 import org.onap.ccsdk.features.model.service.ConfigModelService;\r
  37 import org.onap.ccsdk.features.model.utils.ResourceAssignmentUtils;\r
  38 import org.onap.ccsdk.features.model.utils.TransformationUtils;\r
  39 import org.onap.ccsdk.features.rest.adaptor.service.ConfigRestAdaptorService;\r
  40 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;\r
  41 import org.onap.ccsdk.sli.core.sli.SvcLogicException;\r
  42 import com.att.eelf.configuration.EELFLogger;\r
  43 import com.att.eelf.configuration.EELFManager;\r
  44 \r
  45 public class ConfigAssignmentProcessService {\r
  46 \r
  47     private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigAssignmentProcessService.class);\r
  48 \r
  49     private ComponentNodeService componentNodeService;\r
  50     private ConfigResourceService configResourceService;\r
  51     private ConfigModelService configModelService;\r
  52     private ConfigRestAdaptorService configRestAdaptorService;\r
  53     private ConfigGeneratorService configGeneratorService;\r
  54 \r
  55     public ConfigAssignmentProcessService(ConfigResourceService configResourceService,\r
  56             ConfigRestAdaptorService configRestAdaptorService, ConfigModelService configModelService,\r
  57             ComponentNodeService componentNodeService, ConfigGeneratorService configGeneratorService) {\r
  58         this.componentNodeService = componentNodeService;\r
  59         this.configResourceService = configResourceService;\r
  60         this.configModelService = configModelService;\r
  61         this.configRestAdaptorService = configRestAdaptorService;\r
  62         this.configGeneratorService = configGeneratorService;\r
  63     }\r
  64 \r
  65     @SuppressWarnings("squid:S1141")\r
  66     public void resolveResources(ResourceAssignmentData resourceAssignmentData) throws SvcLogicException {\r
  67         try {\r
  68             validateInputParams(resourceAssignmentData);\r
  69 \r
  70             String serviceTemplateName = resourceAssignmentData.getServiceTemplateName();\r
  71             String serviceTemplateVersion = resourceAssignmentData.getServiceTemplateVersion();\r
  72             String actionName = resourceAssignmentData.getActionName();\r
  73             String inputData = resourceAssignmentData.getInputData();\r
  74             SvcLogicContext svcLogicContext = resourceAssignmentData.getSvcLogicContext();\r
  75             List<String> templateNames = resourceAssignmentData.getTemplateNames();\r
  76 \r
  77             if (resourceAssignmentData.isReloadModel()) {\r
  78                 Map<String, String> context = new HashMap<>();\r
  79                 context.put(ConfigModelConstant.PROPERTY_ACTION_NAME, actionName);\r
  80                 context = configModelService.prepareContext(context, inputData, serviceTemplateName,\r
  81                         serviceTemplateVersion);\r
  82                 context.forEach((key, value) -> svcLogicContext.setAttribute(key, value));\r
  83                 logger.info("List of Resources provided in input: {}", svcLogicContext.toProperties());\r
  84             }\r
  85 \r
  86             Map<String, Object> componentContext = resourceAssignmentData.getContext();\r
  87 \r
  88             if (CollectionUtils.isNotEmpty(templateNames)) {\r
  89                 // Get the Resource Assignments for templates and Validate the mappings\r
  90                 ResourceModelService resourceModelService = new ResourceModelService(configModelService);\r
  91 \r
  92                 // Get the Resource Assignment\r
  93                 Map<String, List<ResourceAssignment>> templatesResourceAssignments =\r
  94                         resourceModelService.getTemplatesResourceAssignments(svcLogicContext, templateNames);\r
  95 \r
  96                 // Get the Template Contents\r
  97                 Map<String, String> templatesContents =\r
  98                         resourceModelService.getTemplatesContents(svcLogicContext, templateNames);\r
  99 \r
 100                 // Process each template\r
 101                 for (String templateName : templateNames) {\r
 102                     List<ResourceAssignment> resourceAssignments = templatesResourceAssignments.get(templateName);\r
 103                     String templateContent = templatesContents.get(templateName);\r
 104                     if (resourceAssignments != null) {\r
 105                         String templateData = null;\r
 106                         try {\r
 107                             // Populate the Dictionary\r
 108                             ResourceDictionaryService resourceDictionaryService =\r
 109                                     new ResourceDictionaryService(configRestAdaptorService);\r
 110                             Map<String, ResourceDefinition> dictionaries =\r
 111                                     resourceDictionaryService.getDataDictionaryDefinitions(resourceAssignments);\r
 112 \r
 113                             processResourceAssignments(resourceAssignmentData, svcLogicContext, componentContext,\r
 114                                     templateName, resourceAssignments, dictionaries);\r
 115 \r
 116                             logger.info("decrypting config data for templateName {}", templateName);\r
 117                             templateData =\r
 118                                     ResourceAssignmentUtils.generateResourceDataForAssignments(resourceAssignments);\r
 119                         } finally {\r
 120                             saveResourceMapping(resourceAssignmentData, templateName, resourceAssignments);\r
 121                         }\r
 122 \r
 123                         logger.info("generating config preview for templateName {}", templateName);\r
 124                         ConfigPreviewService configPreviewService = new ConfigPreviewService(configResourceService,\r
 125                                 configModelService, configGeneratorService);\r
 126                         String mashedData = configPreviewService.generatePreview(templateContent, templateData);\r
 127                         resourceAssignmentData.getTemplatesMashedContents().put(templateName, mashedData);\r
 128                         resourceAssignmentData.getTemplatesData().put(templateName, templateData);\r
 129 \r
 130                     } else {\r
 131                         // Do nothing for Mapping not found\r
 132                         logger.warn("No resource Assignment mappings to resolve for templateName {}", templateName);\r
 133                     }\r
 134                 }\r
 135             }\r
 136 \r
 137         } catch (Exception e) {\r
 138             throw new SvcLogicException(e.getMessage(), e);\r
 139         }\r
 140     }\r
 141 \r
 142     private void processResourceAssignments(ResourceAssignmentData resourceAssignmentData, SvcLogicContext ctx,\r
 143             Map<String, Object> componentContext, String templateName, List<ResourceAssignment> resourceAssignments,\r
 144             Map<String, ResourceDefinition> dictionaries) throws SvcLogicException {\r
 145 \r
 146         String recipeName = resourceAssignmentData.getActionName();\r
 147 \r
 148         ResourceAssignmentProcessor resourceAssignmentProcessor =\r
 149                 new ResourceAssignmentProcessor(resourceAssignments, ctx);\r
 150         List<List<ResourceAssignment>> sequenceBatchResourceAssignment = resourceAssignmentProcessor.process();\r
 151 \r
 152         logger.debug("Resource dictionary Info  ({})", dictionaries);\r
 153 \r
 154         if (sequenceBatchResourceAssignment != null) {\r
 155             componentContext.put(ConfigModelConstant.PROPERTY_ACTION_NAME, recipeName);\r
 156             componentContext.put(ConfigModelConstant.PROPERTY_TEMPLATE_NAME, templateName);\r
 157             componentContext.put(ConfigModelConstant.PROPERTY_DICTIONARIES, dictionaries);\r
 158             for (List<ResourceAssignment> batchResourceAssignment : sequenceBatchResourceAssignment) {\r
 159 \r
 160                 processBatchResourceAssignments(resourceAssignmentData, ctx, componentContext, batchResourceAssignment);\r
 161 \r
 162                 logger.debug("Batch Resource data status ({})", TransformationUtils.getJson(batchResourceAssignment));\r
 163             }\r
 164         }\r
 165     }\r
 166 \r
 167     private void processBatchResourceAssignments(ResourceAssignmentData resourceAssignmentData, SvcLogicContext ctx,\r
 168             Map<String, Object> componentContext, List<ResourceAssignment> batchResourceAssignment)\r
 169             throws SvcLogicException {\r
 170 \r
 171         if (CollectionUtils.isNotEmpty(batchResourceAssignment)) {\r
 172 \r
 173             ResourceAssignment batchFirstResourceAssignment = batchResourceAssignment.get(0);\r
 174             if (batchFirstResourceAssignment != null\r
 175                     && StringUtils.isNotBlank(batchFirstResourceAssignment.getDictionarySource())) {\r
 176                 String source = batchFirstResourceAssignment.getDictionarySource();\r
 177                 // Processing their Source\r
 178                 logger.info("Processing source ({})  with batch ({}) ", source, batchResourceAssignment);\r
 179                 componentContext.put(ConfigModelConstant.PROPERTY_RESOURCE_ASSIGNMENTS, batchResourceAssignment);\r
 180 \r
 181                 ProcessorFactory factory =\r
 182                         new ProcessorFactory(configResourceService, configRestAdaptorService, componentNodeService);\r
 183 \r
 184                 ComponentNode processor = factory.getInstance(source);\r
 185 \r
 186                 Map<String, String> inParams = new HashMap<>();\r
 187                 inParams.put(ConfigAssignmentConstants.INPUT_PARAM_REQUEST_ID, resourceAssignmentData.getRequestId());\r
 188                 inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_ID, resourceAssignmentData.getResourceId());\r
 189                 inParams.put(ConfigAssignmentConstants.INPUT_PARAM_RESOURCE_TYPE,\r
 190                         resourceAssignmentData.getResourceType());\r
 191                 inParams.put(ConfigAssignmentConstants.INPUT_PARAM_ACTION_NAME, resourceAssignmentData.getActionName());\r
 192                 inParams.put(ConfigAssignmentConstants.INPUT_PARAM_TEMPLATE_NAMES,\r
 193                         resourceAssignmentData.getTemplateNames().toString());\r
 194                 processor.process(inParams, ctx, componentContext);\r
 195             }\r
 196         }\r
 197     }\r
 198 \r
 199     private void saveResourceMapping(ResourceAssignmentData resourceAssignmentData, String templateName,\r
 200             List<ResourceAssignment> resourceAssignments) throws SvcLogicException {\r
 201         if (resourceAssignmentData != null && StringUtils.isNotBlank(templateName)) {\r
 202 \r
 203             ConfigAssignmentPersistService configAssignmentPersistService =\r
 204                     new ConfigAssignmentPersistService(configResourceService);\r
 205             configAssignmentPersistService.saveResourceMapping(resourceAssignmentData, templateName,\r
 206                     resourceAssignments);\r
 207         }\r
 208     }\r
 209 \r
 210     private void validateInputParams(ResourceAssignmentData resourceAssignmentData) throws SvcLogicException {\r
 211         if (resourceAssignmentData == null) {\r
 212             throw new SvcLogicException("Input parameters missing");\r
 213         }\r
 214 \r
 215         String requestId = resourceAssignmentData.getRequestId();\r
 216         if (StringUtils.isBlank(requestId)) {\r
 217             throw new SvcLogicException("Request id parameters missing");\r
 218         }\r
 219         String resourceId = resourceAssignmentData.getResourceId();\r
 220         if (StringUtils.isBlank(resourceId)) {\r
 221             throw new SvcLogicException("Resource id parameter is missing");\r
 222         }\r
 223         String resourceType = resourceAssignmentData.getResourceType();\r
 224         if (StringUtils.isBlank(resourceType)) {\r
 225             throw new SvcLogicException("Resource type parameter is missing");\r
 226         }\r
 227         String actionName = resourceAssignmentData.getActionName();\r
 228         if (StringUtils.isBlank(actionName)) {\r
 229             throw new SvcLogicException("Action name is parameter is missing");\r
 230         }\r
 231 \r
 232         List<String> templatesNames = resourceAssignmentData.getTemplateNames();\r
 233         if (CollectionUtils.isEmpty(templatesNames)) {\r
 234             throw new SvcLogicException("Template names parameter missing");\r
 235         }\r
 236     }\r
 237 \r
 238 }\r