gerrit.onap Code Review - ccsdk/features.git/blob

   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.ArrayList;\r
  21 import java.util.HashMap;\r
  22 import java.util.List;\r
  23 import java.util.Map;\r
  24 import org.apache.commons.lang3.StringUtils;\r
  25 import org.onap.ccsdk.features.model.data.ResourceAssignment;\r
  26 import org.onap.ccsdk.features.model.data.dict.ResourceDefinition;\r
  27 import org.onap.ccsdk.features.model.domain.ResourceDictionary;\r
  28 import org.onap.ccsdk.features.model.utils.TransformationUtils;\r
  29 import org.onap.ccsdk.features.rest.adaptor.ConfigRestAdaptorConstants;\r
  30 import org.onap.ccsdk.features.rest.adaptor.ConfigRestAdaptorException;\r
  31 import org.onap.ccsdk.features.rest.adaptor.service.ConfigRestAdaptorService;\r
  32 import org.onap.ccsdk.sli.core.sli.SvcLogicException;\r
  33 import com.att.eelf.configuration.EELFLogger;\r
  34 import com.att.eelf.configuration.EELFManager;\r
  35 \r
  36 public class ResourceDictionaryService {\r
  37 \r
  38     private static EELFLogger logger = EELFManager.getInstance().getLogger(ResourceDictionaryService.class);\r
  39     private ConfigRestAdaptorService configRestAdaptorService;\r
  40 \r
  41     public ResourceDictionaryService(ConfigRestAdaptorService configRestAdaptorService) {\r
  42         this.configRestAdaptorService = configRestAdaptorService;\r
  43     }\r
  44 \r
  45     @SuppressWarnings("squid:S3776")\r
  46     public Map<String, ResourceDefinition> getDataDictionaryDefinitions(List<ResourceAssignment> resourceAssignments)\r
  47             throws SvcLogicException {\r
  48         try {\r
  49             Map<String, ResourceDefinition> dictionaries = new HashMap<>();\r
  50             if (resourceAssignments != null) {\r
  51                 List<String> names = new ArrayList<>();\r
  52                 for (ResourceAssignment resourceAssignment : resourceAssignments) {\r
  53                     if (resourceAssignment != null && StringUtils.isNotBlank(resourceAssignment.getDictionaryName())) {\r
  54                         if (!names.contains(resourceAssignment.getDictionaryName())) {\r
  55                             names.add(resourceAssignment.getDictionaryName());\r
  56                         }\r
  57                         if (resourceAssignment.getDependencies() != null\r
  58                                 && !resourceAssignment.getDependencies().isEmpty()) {\r
  59                             List<String> dependencieNames = resourceAssignment.getDependencies();\r
  60                             for (String dependencieName : dependencieNames) {\r
  61                                 if (StringUtils.isNotBlank(dependencieName) && !names.contains(dependencieName)) {\r
  62                                     names.add(dependencieName);\r
  63                                 }\r
  64                             }\r
  65                         }\r
  66                     }\r
  67                 }\r
  68                 queryResourceDictionaryDefinitions(dictionaries, names);\r
  69             }\r
  70             return dictionaries;\r
  71         } catch (Exception e) {\r
  72             throw new SvcLogicException("Failed in getting resource data dictionary : " + e.getMessage());\r
  73         }\r
  74 \r
  75     }\r
  76 \r
  77     @SuppressWarnings("squid:S3776")\r
  78     private void queryResourceDictionaryDefinitions(Map<String, ResourceDefinition> dictionaries, List<String> names)\r
  79             throws SvcLogicException, ConfigRestAdaptorException {\r
  80         logger.info("Getting resource dictionary definition for the names ({})", names);\r
  81         if (!names.isEmpty()) {\r
  82 \r
  83             String dictionaryContents = configRestAdaptorService.postResource(\r
  84                     ConfigRestAdaptorConstants.SELECTOR_MODEL_SERVICE, "dictionary/by-names", names, String.class);\r
  85 \r
  86             if (StringUtils.isNotBlank(dictionaryContents)) {\r
  87                 List<ResourceDictionary> dataDictionaries =\r
  88                         TransformationUtils.getListfromJson(dictionaryContents, ResourceDictionary.class);\r
  89                 if (dataDictionaries != null) {\r
  90                     for (ResourceDictionary dataDictionary : dataDictionaries) {\r
  91                         if (dataDictionary != null && StringUtils.isNotBlank(dataDictionary.getName())\r
  92                                 && dataDictionary.getDefinition() != null) {\r
  93                             ResourceDefinition resourceDefinition = TransformationUtils\r
  94                                     .treeToValue(dataDictionary.getDefinition(), ResourceDefinition.class);\r
  95                             if (resourceDefinition != null && StringUtils.isNotBlank(resourceDefinition.getName())) {\r
  96                                 dictionaries.put(resourceDefinition.getName(), resourceDefinition);\r
  97                             } else {\r
  98                                 throw new SvcLogicException(\r
  99                                         "Failed in getting resource data dictionary definition for : "\r
 100                                                 + dataDictionary.getName());\r
 101                             }\r
 102                         }\r
 103                     }\r
 104                 }\r
 105             } else {\r
 106                 logger.warn("No resource dictionary definition found for the names ({})", names);\r
 107             }\r
 108         }\r
 109     }\r
 110 }\r