esr-mgr/src/main/java/org/onap/aai/esr/wrapper/VimManagerWrapper.java

   1 /**
   2  * Copyright 2017-2018 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.aai.esr.wrapper;
  17
  18 import java.util.ArrayList;
  19 import java.util.List;
  20 import javax.ws.rs.core.Response;
  21 import org.onap.aai.esr.entity.aai.CloudRegionDetail;
  22 import org.onap.aai.esr.entity.aai.CloudRegionList;
  23 import org.onap.aai.esr.entity.aai.ComplexList;
  24 import org.onap.aai.esr.entity.aai.EsrSystemInfo;
  25 import org.onap.aai.esr.entity.aai.Relationship;
  26 import org.onap.aai.esr.entity.aai.RelationshipData;
  27 import org.onap.aai.esr.entity.rest.VimRegisterInfo;
  28 import org.onap.aai.esr.entity.rest.VimRegisterResponse;
  29 import org.onap.aai.esr.exception.ExceptionUtil;
  30 import org.onap.aai.esr.exception.ExtsysException;
  31 import org.onap.aai.esr.externalservice.aai.CloudRegionProxy;
  32 import org.onap.aai.esr.externalservice.cloud.Tenant;
  33 import org.onap.aai.esr.externalservice.cloud.VimManagerProxy;
  34 import org.onap.aai.esr.util.ExtsysUtil;
  35 import org.onap.aai.esr.util.VimManagerUtil;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38 import com.google.gson.Gson;
  39
  40 public class VimManagerWrapper {
  41
  42     private static VimManagerWrapper vimManagerWrapper;
  43     private static final Logger LOG = LoggerFactory.getLogger(VimManagerWrapper.class);
  44
  45     private static VimManagerUtil vimManagerUtil = new VimManagerUtil();
  46
  47     private static CloudRegionProxy cloudRegionProxy = new CloudRegionProxy();
  48
  49     private static ExtsysUtil extsysUtil = new ExtsysUtil();
  50
  51     /**
  52      * get VimManagerWrapper instance.
  53      *
  54      * @return vim manager wrapper instance
  55      */
  56     public static VimManagerWrapper getInstance() {
  57         if (vimManagerWrapper == null) {
  58             vimManagerWrapper = new VimManagerWrapper(cloudRegionProxy);
  59         }
  60         return vimManagerWrapper;
  61     }
  62
  63     public VimManagerWrapper(CloudRegionProxy cloudRegionProxy) {
  64         VimManagerWrapper.cloudRegionProxy = cloudRegionProxy;
  65     }
  66
  67     public Response registerVim(VimRegisterInfo vimRegisterInfo) {
  68         LOG.info("Start register VIM, input VIM info is: " + extsysUtil.objectToString(vimRegisterInfo));
  69         VimRegisterResponse result = new VimRegisterResponse();
  70         CloudRegionDetail cloudRegion = vimManagerUtil.vimRegisterInfo2CloudRegion(vimRegisterInfo);
  71         String cloudOwner = vimRegisterInfo.getCloudOwner();
  72         String cloudRegionId = vimRegisterInfo.getCloudRegionId();
  73         String physicalLocationId = vimRegisterInfo.getPhysicalLocationId();
  74         //TODO query complex by complex id to get complex name. and put the name to vimRegisterInfo.complexName
  75         try {
  76             cloudRegionProxy.registerVim(cloudOwner, cloudRegionId, cloudRegion);
  77             result.setCloudOwner(cloudOwner);
  78             result.setCloudRegionId(cloudRegionId);
  79             createRelationship(cloudOwner, cloudRegionId, physicalLocationId);
  80             updateVimWithMultiCloud(cloudRegion, cloudOwner, cloudRegionId);
  81             return Response.ok(result).build();
  82         } catch (ExtsysException error) {
  83             LOG.error("Register VIM failed !", error);
  84             throw ExceptionUtil.buildExceptionResponse(error.getMessage());
  85         }
  86     }
  87
  88     private void updateVimWithMultiCloud(CloudRegionDetail cloudRegion, String cloudOwner, String cloudRegionId) {
  89         Tenant tenant = new Tenant();
  90         tenant.setDefaultTenant(cloudRegion.getEsrSystemInfoList().getEsrSystemInfo().get(0).getDefaultTenant());
  91         try {
  92             VimManagerProxy.updateVim(cloudOwner, cloudRegionId, tenant);
  93         } catch (ExtsysException e) {
  94             LOG.error("Update VIM by Multi-cloud failed !", e);
  95         }
  96     }
  97
  98     private void createRelationship(String cloudOwner, String cloudRegionId, String physicalLocationId) {
  99         Relationship relationship = new Relationship();
 100         RelationshipData relationshipData = new RelationshipData();
 101         List<RelationshipData> relationshipDatas = new ArrayList<>();
 102         String relatedLink = "/aai/v11/cloud-infrastructure/complexes/complex/" + physicalLocationId;
 103         relationship.setRelatedTo("complex");
 104         relationship.setRelatedLink(relatedLink);
 105         relationshipData.setRelationshipKey("complex.physical-location-id");
 106         relationshipData.setRelationshipValue(physicalLocationId);
 107         relationshipDatas.add(relationshipData);
 108         relationship.setRelationshipData(relationshipDatas);
 109         try {
 110             cloudRegionProxy.createCloudRegionRelationShip(cloudOwner, cloudRegionId, relationship);
 111         } catch (ExtsysException e) {
 112             LOG.error("Create relationship between cloudRegion and complex failed !", e);
 113         }
 114     }
 115
 116     public Response updateVim(String cloudOwner, String cloudRegionId, VimRegisterInfo vimRegisterInfo) {
 117         LOG.info("Start update VIM, input VIM info is: " + extsysUtil.objectToString(vimRegisterInfo));
 118         VimRegisterResponse result = new VimRegisterResponse();
 119
 120         CloudRegionDetail cloudRegionDetail = getVimUpdateInfo(vimRegisterInfo);
 121         try {
 122             cloudRegionProxy.registerVim(cloudOwner, cloudRegionId, cloudRegionDetail);
 123             result.setCloudOwner(cloudOwner);
 124             result.setCloudRegionId(cloudRegionId);
 125             return Response.ok(result).build();
 126         } catch (ExtsysException e) {
 127             LOG.error("Update VIM failed !", e);
 128             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
 129         }
 130     }
 131
 132     public Response queryVimListDetails() {
 133         List<VimRegisterInfo> vimRegisterInfos = new ArrayList<>();
 134         CloudRegionList cloudRegionList = new CloudRegionList();
 135         try {
 136             String aaiVimList = cloudRegionProxy.qureyVimList();
 137             cloudRegionList = new Gson().fromJson(aaiVimList, CloudRegionList.class);
 138             vimRegisterInfos = getVimDetailList(cloudRegionList);
 139             return Response.ok(vimRegisterInfos).build();
 140         } catch (ExtsysException error) {
 141             LOG.error("Query vim list details failed !", error);
 142             return Response.ok(vimRegisterInfos).build();
 143         }
 144
 145     }
 146
 147     public Response queryVimById(String cloudOwner, String cloudRegionId) {
 148         VimRegisterInfo vim = new VimRegisterInfo();
 149         CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 150         try {
 151             String cloudRegionstr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 152             LOG.info("Response from AAI by query VIM: " + cloudRegionstr);
 153             cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
 154             vim = vimManagerUtil.cloudRegion2VimRegisterInfo(cloudRegionDetail);
 155             return Response.ok(vim).build();
 156         } catch (ExtsysException e) {
 157             LOG.error("Query vim details by ID failed !", e);
 158             return Response.ok(vim).build();
 159         }
 160
 161     }
 162
 163     private List<VimRegisterInfo> getVimDetailList(CloudRegionList cloudRegionList) {
 164         List<VimRegisterInfo> vimRegisterInfos = new ArrayList<>();
 165         int cloudRegionNum = cloudRegionList.getCloudRegion().size();
 166         for (int i = 0; i < cloudRegionNum; i++) {
 167             String cloudOwner = cloudRegionList.getCloudRegion().get(i).getCloudOwner();
 168             String cloudRegionId = cloudRegionList.getCloudRegion().get(i).getCloudRegionId();
 169             VimRegisterInfo vimRegisterInfo = getVimDetail(cloudOwner, cloudRegionId);
 170             vimRegisterInfos.add(vimRegisterInfo);
 171         }
 172         return vimRegisterInfos;
 173     }
 174
 175     private VimRegisterInfo getVimDetail(String cloudOwner, String cloudRegionId) {
 176         CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 177         VimRegisterInfo registeredVimInfo = new VimRegisterInfo();
 178         try {
 179             String cloudRegionstr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 180             cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
 181             registeredVimInfo = vimManagerUtil.cloudRegion2VimRegisterInfo(cloudRegionDetail);
 182         } catch (ExtsysException error) {
 183             LOG.error("query VIM detail failed ! cloud-owner = " + cloudOwner + ", cloud-region-id = " + cloudRegionId,
 184                     error);
 185         }
 186         return registeredVimInfo;
 187     }
 188
 189     private CloudRegionDetail getOriginalCloudRegion(String cloudOwner, String cloudRegionId) {
 190         CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 191         try {
 192             String cloudRegionstr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 193             cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
 194             return cloudRegionDetail;
 195         } catch (ExtsysException error) {
 196             LOG.error("query VIM detail failed ! cloud-owner = " + cloudOwner + ", cloud-region-id = " + cloudRegionId,
 197                     error);
 198             return null;
 199         }
 200     }
 201
 202     private CloudRegionDetail getVimUpdateInfo(VimRegisterInfo vimRegisterInfo) {
 203         String cloudOwner = vimRegisterInfo.getCloudOwner();
 204         String cloudRegionId = vimRegisterInfo.getCloudRegionId();
 205         CloudRegionDetail originalCloudRegionDetail = getOriginalCloudRegion(cloudOwner, cloudRegionId);
 206         String resourceVersion = originalCloudRegionDetail.getResourceVersion();
 207         CloudRegionDetail cloudRegionDetail = vimManagerUtil.vimRegisterInfo2CloudRegion(vimRegisterInfo);
 208         if (resourceVersion != null) {
 209             cloudRegionDetail.setResourceVersion(resourceVersion);
 210             EsrSystemInfo originalSystemInfo = originalCloudRegionDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0);
 211             cloudRegionDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0)
 212                     .setEsrSystemInfoId(originalSystemInfo.getEsrSystemInfoId());
 213             cloudRegionDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0)
 214                     .setResouceVersion(originalSystemInfo.getResouceVersion());
 215         }
 216         return cloudRegionDetail;
 217     }
 218
 219     public Response delVim(String cloudOwner, String cloudRegionId) {
 220         CloudRegionDetail cloudRegionDetail = queryCloudRegionDetail(cloudOwner, cloudRegionId);
 221         String resourceVersion = cloudRegionDetail.getResourceVersion();
 222         try {
 223             cloudRegionProxy.deleteVim(cloudOwner, cloudRegionId, resourceVersion);
 224             return Response.noContent().build();
 225         } catch (ExtsysException e) {
 226             LOG.error("Delete cloud region from A&AI failed! cloud-owner = " + cloudOwner + ", cloud-region-id = "
 227                     + cloudRegionId + "resouce-version:" + resourceVersion, e);
 228             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
 229         }
 230     }
 231
 232     private CloudRegionDetail queryCloudRegionDetail(String cloudOwner, String cloudRegionId) {
 233         CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 234         try {
 235             String cloudRegionStr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 236             LOG.info("Response from AAI by query cloud region: " + cloudRegionStr);
 237             cloudRegionDetail = new Gson().fromJson(cloudRegionStr, CloudRegionDetail.class);
 238         } catch (ExtsysException e) {
 239             LOG.error("Query EMS detail failed! cloud-owner = " + cloudOwner + ", cloud-region-id = " + cloudRegionId,
 240                     e);
 241             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
 242         }
 243         return cloudRegionDetail;
 244     }
 245
 246     public Response queryComplexes() {
 247         ComplexList complexList = new ComplexList();
 248         List<String> physicalLocationIdList = new ArrayList<>();
 249         try {
 250             String complexesString = cloudRegionProxy.qureyComplexes();
 251             LOG.info("The complex query result is: " + complexesString);
 252             complexList = new Gson().fromJson(complexesString, ComplexList.class);
 253             for (int i=0; i<complexList.getComplex().size(); i++) {
 254                 physicalLocationIdList.add(complexList.getComplex().get(i).getPhysicalLocationId());
 255             }
 256         } catch (ExtsysException e) {
 257             LOG.error("Query vim details by ID failed !", e);
 258         }
 259         return Response.ok(physicalLocationIdList).build();
 260     }
 261 }