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 toPath = String.format("/home/uui/%s.csar", uuid);
  84         try {
  85             downloadFile(toscaModelPath, toPath);
  86             return extractTemplate(toPath);
  87         }  catch (IOException e) {
  88             throw new SDCCatalogException("download csar file failed!", e);
  89         } catch (JToscaException e) {
  90             throw new SDCCatalogException("parse csar file failed!", e);
  91         }
  92     }
  93
  94     protected void downloadFile(String toscaModelPath, String toPath) throws IOException {
  95         try {
  96             String msbUrl = RestfulServices.getMsbAddress();
  97             String templateUrl = String.format("http://%s/%s", msbUrl, toscaModelPath);
  98             ResponseBody body = sdcCatalog.downloadCsar(templateUrl).execute().body();
  99             Files.write(body.bytes(),new File(toPath));
 100         } catch (IOException e) {
 101             logger.error(String.format("Download %s failed!", toscaModelPath));
 102             throw e;
 103         }
 104     }
 105
 106     private ServiceTemplateInput extractTemplate(String toPath) throws JToscaException, IOException {
 107         ToscaTemplate tosca = translateToToscaTemplate(toPath);
 108         ServiceTemplateInput serviceTemplateInput = fetchServiceTemplateInput(tosca);
 109         for (NodeTemplate nodeTemplate : tosca.getNodeTemplates()) {
 110             String nodeUUID = nodeTemplate.getMetaData().getValue("UUID");
 111             SDCServiceTemplate template = sdcCatalog.getService(nodeUUID).execute().body();
 112             String toscaModelURL = template.getToscaModelURL();
 113             if (toscaModelURL == null) {
 114                 continue;
 115             }
 116             ServiceTemplateInput nodeService = fetchServiceTemplate(nodeUUID, toscaModelURL);
 117             serviceTemplateInput.addNestedTemplate(nodeService);
 118         }
 119         return serviceTemplateInput;
 120     }
 121
 122 //    private List<ServiceTemplateInput> extractInputs(String toPath, List<ServiceTemplateInput> serviceTemplateInputs) throws JToscaException, IOException {
 123 //        ToscaTemplate tosca = translateToToscaTemplate(toPath);
 124 //        ServiceTemplateInput serviceTemplateInput = fetchServiceTemplateInput(tosca);
 125 //        serviceTemplateInputs.add(serviceTemplateInput);
 126 //        for (NodeTemplate nodeTemplate : tosca.getNodeTemplates()) {
 127 //            String nodeUUID = nodeTemplate.getMetaData().getValue("UUID");
 128 //            SDCServiceTemplate template = sdcCatalog.getService(nodeUUID).execute().body();
 129 //            String toscaModelURL = template.getToscaModelURL();
 130 //            if (toscaModelURL == null) {
 131 //                continue;
 132 //            }
 133 //            String savePath = String.format("temp/%s.csar", nodeUUID);
 134 //            downloadFile(toscaModelURL, savePath);
 135 //            extractInputs(savePath, serviceTemplateInputs);
 136 //        }
 137 //        return serviceTemplateInputs;
 138 //    }
 139
 140     protected ToscaTemplate translateToToscaTemplate(String toPath) throws JToscaException {
 141         return new ToscaTemplate(toPath,null,true,null,true);
 142     }
 143
 144     private static ServiceTemplateInput fetchServiceTemplateInput(ToscaTemplate tosca) {
 145         String invariantUUID = tosca.getMetaData().getValue("invariantUUID");
 146         String uuid = tosca.getMetaData().getValue("UUID");
 147         String name = tosca.getMetaData().getValue("name");
 148         String type = tosca.getMetaData().getValue("type");
 149         String version = tosca.getMetaData().getValue("version");
 150         if (version == null) {
 151             version = "";
 152         }
 153         String description = tosca.getMetaData().getValue("description");
 154         String category = tosca.getMetaData().getValue("category");
 155         String subcategory = tosca.getMetaData().getValue("subcategory");
 156         if(subcategory == null) {
 157             subcategory = "";
 158         }
 159         List<TemplateInput> templateInputs = new ArrayList<>();
 160         for(Input input : tosca.getInputs()) {
 161             templateInputs.add(new TemplateInput(
 162                     input.getName(),
 163                     input.getType(),
 164                     input.getDescription(),
 165                     String.valueOf(input.isRequired()),
 166                     String.valueOf(input.getDefault())
 167             ));
 168         }
 169         return new ServiceTemplateInput(
 170                 invariantUUID,
 171                 uuid,
 172                 name,
 173                 type,
 174                 version,
 175                 description,
 176                 category,
 177                 subcategory,
 178                 templateInputs);
 179     }
 180
 181     @Override
 182     public List<VimInfo> listVim() {
 183         try {
 184             return aaiService.listVimInfo().execute().body();
 185         } catch (IOException e) {
 186             logger.error("Visit AAI occur exception");
 187             throw new AAIException("AAI is not available.", e);
 188         }
 189     }
 190 }