server/src/main/java/org/onap/usecaseui/server/service/lcm/impl/DefaultServiceTemplateService.java

   1 /**
   2  * Copyright 2016-2017 ZTE Corporation.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onap.usecaseui.server.service.lcm.impl;
  17
  18 import com.google.common.io.Files;
  19 import okhttp3.ResponseBody;
  20 import org.onap.usecaseui.server.bean.lcm.ServiceTemplateInput;
  21 import org.onap.usecaseui.server.bean.lcm.TemplateInput;
  22 import org.onap.usecaseui.server.service.lcm.ServiceTemplateService;
  23 import org.onap.usecaseui.server.service.lcm.domain.aai.AAIService;
  24 import org.onap.usecaseui.server.service.lcm.domain.aai.bean.VimInfo;
  25 import org.onap.usecaseui.server.service.lcm.domain.aai.exceptions.AAIException;
  26 import org.onap.usecaseui.server.service.lcm.domain.sdc.SDCCatalogService;
  27 import org.onap.usecaseui.server.service.lcm.domain.sdc.bean.SDCServiceTemplate;
  28 import org.onap.usecaseui.server.service.lcm.domain.sdc.exceptions.SDCCatalogException;
  29 import org.onap.usecaseui.server.util.RestfulServices;
  30 import org.openecomp.sdc.toscaparser.api.NodeTemplate;
  31 import org.openecomp.sdc.toscaparser.api.ToscaTemplate;
  32 import org.openecomp.sdc.toscaparser.api.common.JToscaException;
  33 import org.openecomp.sdc.toscaparser.api.parameters.Input;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36 import org.springframework.context.annotation.EnableAspectJAutoProxy;
  37 import org.springframework.stereotype.Service;
  38
  39 import java.io.File;
  40 import java.io.IOException;
  41 import java.util.ArrayList;
  42 import java.util.List;
  43
  44 import static org.onap.usecaseui.server.service.lcm.domain.sdc.consts.SDCConsts.CATEGORY_E2E_SERVICE;
  45 import static org.onap.usecaseui.server.service.lcm.domain.sdc.consts.SDCConsts.DISTRIBUTION_STATUS_DISTRIBUTED;
  46
  47 @Service("ServiceTemplateService")
  48 @org.springframework.context.annotation.Configuration
  49 @EnableAspectJAutoProxy
  50 public class DefaultServiceTemplateService implements ServiceTemplateService {
  51
  52     private static final Logger logger = LoggerFactory.getLogger(DefaultServiceTemplateService.class);
  53
  54     private SDCCatalogService sdcCatalog;
  55
  56     private AAIService aaiService;
  57
  58     public DefaultServiceTemplateService() {
  59         this(RestfulServices.create(SDCCatalogService.class), RestfulServices.create(AAIService.class));
  60     }
  61
  62     public DefaultServiceTemplateService(SDCCatalogService sdcCatalog, AAIService aaiService) {
  63         this.sdcCatalog = sdcCatalog;
  64         this.aaiService = aaiService;
  65     }
  66
  67     @Override
  68     public List<SDCServiceTemplate> listDistributedServiceTemplate() {
  69         try {
  70             return this.sdcCatalog.listServices(CATEGORY_E2E_SERVICE, DISTRIBUTION_STATUS_DISTRIBUTED).execute().body();
  71         } catch (IOException e) {
  72             logger.error("Visit SDC Catalog occur exception");
  73             throw new SDCCatalogException("SDC Catalog is not available.", e);
  74         }
  75     }
  76
  77     @Override
  78     public ServiceTemplateInput fetchServiceTemplateInput(String uuid, String toscaModelPath) {
  79         return fetchServiceTemplate(uuid, toscaModelPath);
  80     }
  81
  82     private ServiceTemplateInput fetchServiceTemplate(String uuid, String toscaModelPath) {
  83         String rootPath = "http://localhost";// get from msb
  84         String templateUrl = String.format("%s/%s", rootPath, toscaModelPath);
  85
  86         String toPath = String.format("temp/%s.csar", uuid);
  87         try {
  88             downloadFile(templateUrl, toPath);
  89             return extractTemplate(toPath);
  90         }  catch (IOException e) {
  91             throw new SDCCatalogException("download csar file failed!", e);
  92         } catch (JToscaException e) {
  93             throw new SDCCatalogException("parse csar file failed!", e);
  94         }
  95     }
  96
  97     protected void downloadFile(String templateUrl, String toPath) throws IOException {
  98         try {
  99             ResponseBody body = sdcCatalog.downloadCsar(templateUrl).execute().body();
 100             Files.write(body.bytes(),new File(toPath));
 101         } catch (IOException e) {
 102             logger.error(String.format("Download %s failed!", templateUrl));
 103             throw e;
 104         }
 105     }
 106
 107     private ServiceTemplateInput extractTemplate(String toPath) throws JToscaException, IOException {
 108         ToscaTemplate tosca = translateToToscaTemplate(toPath);
 109         ServiceTemplateInput serviceTemplateInput = fetchServiceTemplateInput(tosca);
 110         for (NodeTemplate nodeTemplate : tosca.getNodeTemplates()) {
 111             String nodeUUID = nodeTemplate.getMetaData().getValue("UUID");
 112             SDCServiceTemplate template = sdcCatalog.getService(nodeUUID).execute().body();
 113             String toscaModelURL = template.getToscaModelURL();
 114             if (toscaModelURL == null) {
 115                 continue;
 116             }
 117             ServiceTemplateInput nodeService = fetchServiceTemplate(nodeUUID, toscaModelURL);
 118             serviceTemplateInput.addNestedTemplate(nodeService);
 119         }
 120         return serviceTemplateInput;
 121     }
 122
 123 //    private List<ServiceTemplateInput> extractInputs(String toPath, List<ServiceTemplateInput> serviceTemplateInputs) throws JToscaException, IOException {
 124 //        ToscaTemplate tosca = translateToToscaTemplate(toPath);
 125 //        ServiceTemplateInput serviceTemplateInput = fetchServiceTemplateInput(tosca);
 126 //        serviceTemplateInputs.add(serviceTemplateInput);
 127 //        for (NodeTemplate nodeTemplate : tosca.getNodeTemplates()) {
 128 //            String nodeUUID = nodeTemplate.getMetaData().getValue("UUID");
 129 //            SDCServiceTemplate template = sdcCatalog.getService(nodeUUID).execute().body();
 130 //            String toscaModelURL = template.getToscaModelURL();
 131 //            if (toscaModelURL == null) {
 132 //                continue;
 133 //            }
 134 //            String savePath = String.format("temp/%s.csar", nodeUUID);
 135 //            downloadFile(toscaModelURL, savePath);
 136 //            extractInputs(savePath, serviceTemplateInputs);
 137 //        }
 138 //        return serviceTemplateInputs;
 139 //    }
 140
 141     protected ToscaTemplate translateToToscaTemplate(String toPath) throws JToscaException {
 142         return new ToscaTemplate(toPath,null,true,null,true);
 143     }
 144
 145     private static ServiceTemplateInput fetchServiceTemplateInput(ToscaTemplate tosca) {
 146         String invariantUUID = tosca.getMetaData().getValue("invariantUUID");
 147         String uuid = tosca.getMetaData().getValue("UUID");
 148         String name = tosca.getMetaData().getValue("name");
 149         String type = tosca.getMetaData().getValue("type");
 150         String version = tosca.getMetaData().getValue("version");
 151         if (version == null) {
 152             version = "";
 153         }
 154         String description = tosca.getMetaData().getValue("description");
 155         String category = tosca.getMetaData().getValue("category");
 156         String subcategory = tosca.getMetaData().getValue("subcategory");
 157         if(subcategory == null) {
 158             subcategory = "";
 159         }
 160         List<TemplateInput> templateInputs = new ArrayList<>();
 161         for(Input input : tosca.getInputs()) {
 162             templateInputs.add(new TemplateInput(
 163                     input.getName(),
 164                     input.getType(),
 165                     input.getDescription(),
 166                     String.valueOf(input.isRequired()),
 167                     String.valueOf(input.getDefault())
 168             ));
 169         }
 170         return new ServiceTemplateInput(
 171                 invariantUUID,
 172                 uuid,
 173                 name,
 174                 type,
 175                 version,
 176                 description,
 177                 category,
 178                 subcategory,
 179                 templateInputs);
 180     }
 181
 182     @Override
 183     public List<VimInfo> listVim() {
 184         try {
 185             return aaiService.listVimInfo().execute().body();
 186         } catch (IOException e) {
 187             logger.error("Visit AAI occur exception");
 188             throw new AAIException("AAI is not available.", e);
 189         }
 190     }
 191 }