CsarInstaller introduction

This class is introduced to decode/deploy the dcae blueprint from SDC
and save it to database. This is done based on json templates. Some unit
tests added

Issue-ID: CLAMP-81
Change-Id: I3fac5f7ef41d77aa244414407111b9cb602b50bd
Signed-off-by: Determe, Sebastien (sd378r) <sd378r@intl.att.com>

2 files changed, 180 insertions, 0 deletions

diff --git a/src/main/java/org/onap/clamp/clds/sdc/controller/installer/CsarInstaller.java b/src/main/java/org/onap/clamp/clds/sdc/controller/installer/CsarInstaller.java
new file mode 100644
index 00000000..739fc06d
--- /dev/null
+++ b/src/main/java/org/onap/clamp/clds/sdc/controller/installer/CsarInstaller.java
@@ -0,0 +1,33 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP CLAMP
+ * ================================================================================
+ * Copyright (C) 2018 AT&T Intellectual Property. All rights
+ *                             reserved.
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END============================================
+ * ===================================================================
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ */
+
+package org.onap.clamp.clds.sdc.controller.installer;
+
+import org.onap.clamp.clds.exception.sdc.controller.SdcArtifactInstallerException;
+
+public interface CsarInstaller {
+
+    boolean isCsarAlreadyDeployed(CsarHandler csar) throws SdcArtifactInstallerException;
+
+    public void installTheCsar(CsarHandler csar) throws SdcArtifactInstallerException;
+}
diff --git a/src/main/java/org/onap/clamp/clds/sdc/controller/installer/CsarInstallerImpl.java b/src/main/java/org/onap/clamp/clds/sdc/controller/installer/CsarInstallerImpl.java
new file mode 100644
index 00000000..c56eed51
--- /dev/null
+++ b/src/main/java/org/onap/clamp/clds/sdc/controller/installer/CsarInstallerImpl.java
@@ -0,0 +1,147 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP CLAMP
+ * ================================================================================
+ * Copyright (C) 2018 AT&T Intellectual Property. All rights
+ *                             reserved.
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END============================================
+ * ===================================================================
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ */
+
+package org.onap.clamp.clds.sdc.controller.installer;
+
+import com.att.aft.dme2.internal.apache.commons.io.IOUtils;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.PostConstruct;
+
+import org.onap.clamp.clds.config.ClampProperties;
+import org.onap.clamp.clds.config.sdc.BlueprintParserFilesConfiguration;
+import org.onap.clamp.clds.config.sdc.BlueprintParserMappingConfiguration;
+import org.onap.clamp.clds.dao.CldsDao;
+import org.onap.clamp.clds.exception.sdc.controller.SdcArtifactInstallerException;
+import org.onap.clamp.clds.model.CldsModel;
+import org.onap.clamp.clds.model.CldsTemplate;
+import org.onap.clamp.clds.service.CldsService;
+import org.onap.clamp.clds.service.CldsTemplateService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.ApplicationContext;
+import org.springframework.stereotype.Component;
+import org.yaml.snakeyaml.Yaml;
+
+@Component
+public class CsarInstallerImpl implements CsarInstaller {
+
+    private static final EELFLogger logger = EELFManager.getInstance().getLogger(CsarInstallerImpl.class);
+    private Map<String, BlueprintParserFilesConfiguration> bpmnMapping = new HashMap<>();
+    public static final String TEMPLATE_NAME_SUFFIX = "-template-dcae-designer";
+    public static final String MODEL_NAME_SUFFIX = "-model-dcae-designer";
+    /**
+     * The file name that will be loaded by Spring.
+     */
+    @Value("${clamp.config.sdc.blueprint.parser.mapping:'classpath:/clds/blueprint-parser-mapping.json'}")
+    protected String blueprintMappingFile;
+    @Autowired
+    protected ApplicationContext appContext;
+    @Autowired
+    private CldsDao cldsDao;
+    @Autowired
+    private ClampProperties refProp;
+    @Autowired
+    CldsTemplateService cldsTemplateService;
+    @Autowired
+    CldsService cldsService;
+
+    @PostConstruct
+    public void loadConfiguration() throws IOException {
+        BlueprintParserMappingConfiguration
+                .createFromJson(appContext.getResource(blueprintMappingFile).getInputStream()).stream()
+                .forEach(e -> bpmnMapping.put(e.getBlueprintKey(), e.getFiles()));
+    }
+
+    @Override
+    public boolean isCsarAlreadyDeployed(CsarHandler csar) throws SdcArtifactInstallerException {
+        return false;
+    }
+
+    @Override
+    public void installTheCsar(CsarHandler csar) throws SdcArtifactInstallerException {
+        try {
+            BlueprintParserFilesConfiguration configFiles = this.searchForRightMapping(csar);
+            createFakeCldsModel(csar, configFiles, createFakeCldsTemplate(csar, configFiles));
+        } catch (IOException e) {
+            throw new SdcArtifactInstallerException("Exception caught during the Csar installation in database", e);
+        }
+    }
+
+    private BlueprintParserFilesConfiguration searchForRightMapping(CsarHandler csar)
+            throws SdcArtifactInstallerException {
+        List<BlueprintParserFilesConfiguration> listConfig = new ArrayList<>();
+        Yaml yaml = new Yaml();
+        Map<String, Object> templateNodes = ((Map<String, Object>) ((Map<String, Object>) yaml
+                .load(csar.getDcaeBlueprint())).get("node_templates"));
+        bpmnMapping.entrySet().forEach(e -> {
+            if (templateNodes.keySet().stream().anyMatch(t -> t.contains(e.getKey()))) {
+                listConfig.add(e.getValue());
+            }
+        });
+        if (listConfig.size() > 1) {
+            throw new SdcArtifactInstallerException(
+                    "The code does not currently support multiple MicroServices in the blueprint");
+        } else if (listConfig.isEmpty()) {
+            throw new SdcArtifactInstallerException("There is no recognized MicroService found in the blueprint");
+        }
+        return listConfig.get(0);
+    }
+
+    private String createTemplateName(CsarHandler csar) {
+        return csar.getSdcCsarHelper().getServiceMetadata().getValue("name") + TEMPLATE_NAME_SUFFIX;
+    }
+
+    private String createModelName(CsarHandler csar) {
+        return csar.getSdcCsarHelper().getServiceMetadata().getValue("name") + MODEL_NAME_SUFFIX;
+    }
+
+    private CldsTemplate createFakeCldsTemplate(CsarHandler csar, BlueprintParserFilesConfiguration configFiles)
+            throws IOException, SdcArtifactInstallerException {
+        CldsTemplate template = new CldsTemplate();
+        template.setBpmnId("Sdc-Generated");
+        template.setBpmnText(
+                IOUtils.toString(appContext.getResource(configFiles.getBpmnXmlFilePath()).getInputStream()));
+        // ((ObjectNode)refProp.getJsonTemplate(CldsService.GLOBAL_PROPERTIES_KEY));
+        template.setPropText(csar.getDcaeBlueprint());
+        template.setImageText(
+                IOUtils.toString(appContext.getResource(configFiles.getSvgXmlFilePath()).getInputStream()));
+        return cldsTemplateService.putTemplate(createTemplateName(csar), template);
+    }
+
+    private CldsModel createFakeCldsModel(CsarHandler csar, BlueprintParserFilesConfiguration configFiles,
+            CldsTemplate cldsTemplate) {
+        CldsModel cldsModel = new CldsModel();
+        cldsModel.setBlueprintText(csar.getDcaeBlueprint());
+        cldsModel.setTemplateName(cldsTemplate.getName());
+        // cldsModel.set
+        return cldsService.putModel(createModelName(csar), cldsModel);
+    }
+}