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

   1 /**
   2  * Copyright 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.aai.esr.wrapper;
  17
  18 import java.util.ArrayList;
  19
  20 import javax.ws.rs.core.Response;
  21
  22 import org.onap.aai.esr.entity.aai.CloudRegionDetail;
  23 import org.onap.aai.esr.entity.aai.CloudRegionList;
  24 import org.onap.aai.esr.entity.rest.VimRegisterInfo;
  25 import org.onap.aai.esr.entity.rest.VimRegisterResponse;
  26 import org.onap.aai.esr.externalservice.aai.CloudRegionProxy;
  27 import org.onap.aai.esr.util.ExtsysUtil;
  28 import org.onap.aai.esr.util.VimManagerUtil;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 import com.google.gson.Gson;
  33
  34
  35 public class VimManagerWrapper {
  36
  37   private static VimManagerWrapper vimManagerWrapper;
  38   private static final Logger LOG = LoggerFactory.getLogger(VimManagerWrapper.class);
  39
  40   /**
  41    * get VimManagerWrapper instance.
  42    * @return vim manager wrapper instance
  43    */
  44   public static VimManagerWrapper getInstance() {
  45     if (vimManagerWrapper == null) {
  46       vimManagerWrapper = new VimManagerWrapper();
  47     }
  48     return vimManagerWrapper;
  49
  50   }
  51
  52   public Response registerVim(VimRegisterInfo vimRegisterInfo) {
  53     LOG.info("Start register VIM, input VIM info is: " + ExtsysUtil.objectToString(vimRegisterInfo));
  54     CloudRegionDetail cloudRegion = new CloudRegionDetail();
  55     VimRegisterResponse result = new VimRegisterResponse();
  56     cloudRegion = VimManagerUtil.vimRegisterInfo2CloudRegion(vimRegisterInfo);
  57     String cloudOwner = vimRegisterInfo.getCloudOwner();
  58     String cloudRegionId = vimRegisterInfo.getCloudRegionId();
  59     try {
  60       CloudRegionProxy.registerVim(cloudOwner, cloudRegionId, cloudRegion);
  61       result.setCloudOwner(cloudOwner);
  62       result.setCloudRegionId(cloudRegionId);
  63       return Response.ok(result).build();
  64     } catch (Exception e) {
  65       LOG.error("Register VIM failed !" + e.getMessage());
  66       return Response.serverError().build();
  67     }
  68   }
  69
  70   public Response updateVim(VimRegisterInfo vimRegisterInfo) {
  71     LOG.info("Start update VIM, input VIM info is: " + ExtsysUtil.objectToString(vimRegisterInfo));
  72     String cloudOwner = vimRegisterInfo.getCloudOwner();
  73     String cloudRegionId = vimRegisterInfo.getCloudRegionId();
  74     String resourceVersion = getResourceVersion(cloudOwner, cloudRegionId);
  75     CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
  76     VimRegisterResponse result = new VimRegisterResponse();
  77     cloudRegionDetail = VimManagerUtil.vimRegisterInfo2CloudRegion(vimRegisterInfo);
  78     cloudRegionDetail.setResouceVersion(resourceVersion);
  79
  80     try {
  81       CloudRegionProxy.registerVim(cloudOwner, cloudRegionId, cloudRegionDetail);
  82       result.setCloudOwner(cloudOwner);
  83       result.setCloudRegionId(cloudRegionId);
  84       return Response.ok(result).build();
  85     } catch (Exception e) {
  86       e.printStackTrace();
  87       LOG.error("Update VIM failed !" + e.getMessage());
  88       return Response.serverError().build();
  89     }
  90   }
  91
  92   public Response queryVimListDetails() {
  93     ArrayList<VimRegisterInfo> vimRegisterInfos = new ArrayList<VimRegisterInfo>();
  94     CloudRegionList cloudRegionList = new CloudRegionList();
  95     try {
  96       String aaiVimList = CloudRegionProxy.qureyVimList();
  97       cloudRegionList = new Gson().fromJson(aaiVimList, CloudRegionList.class);
  98       vimRegisterInfos = getVimDetailList(cloudRegionList);
  99       return Response.ok(vimRegisterInfos).build();
 100     } catch (Exception error) {
 101       LOG.error("Query vim list details failed !" + error.getMessage());
 102       return Response.serverError().build();
 103     }
 104
 105   }
 106
 107   public Response queryVimById(String cloudOwner, String cloudRegionId) {
 108     VimRegisterInfo vim = new VimRegisterInfo();
 109     CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 110     try {
 111       String cloudRegionstr = CloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 112       LOG.info("Response from AAI by query VIM: " + cloudRegionstr);
 113       cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
 114       vim = VimManagerUtil.cloudRegion2VimRegisterInfo(cloudRegionDetail);
 115       return Response.ok(vim).build();
 116     } catch (Exception e) {
 117       e.printStackTrace();
 118       return Response.serverError().build();
 119     }
 120
 121   }
 122
 123   private ArrayList<VimRegisterInfo> getVimDetailList(CloudRegionList cloudRegionList) {
 124     ArrayList<VimRegisterInfo> vimRegisterInfos = new ArrayList<VimRegisterInfo>();
 125     VimRegisterInfo vimRegisterInfo = new VimRegisterInfo();
 126     int cloudRegionNum = cloudRegionList.getCloudRegion().size();
 127     for (int i=0; i<cloudRegionNum; i++) {
 128       String cloudOwner = cloudRegionList.getCloudRegion().get(i).getCloudOwner();
 129       String cloudRegionId = cloudRegionList.getCloudRegion().get(i).getCloudRegionId();
 130       vimRegisterInfo = getVimDetail(cloudOwner, cloudRegionId);
 131       vimRegisterInfos.add(vimRegisterInfo);
 132     }
 133     return vimRegisterInfos;
 134   }
 135
 136   private VimRegisterInfo getVimDetail(String cloudOwner, String cloudRegionId) {
 137     CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 138     VimRegisterInfo registeredVimInfo = new VimRegisterInfo();
 139     try {
 140       String cloudRegionstr = CloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 141       cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
 142       registeredVimInfo = VimManagerUtil.cloudRegion2VimRegisterInfo(cloudRegionDetail);
 143     } catch (Exception error) {
 144       LOG.error("query VIM detail failed ! cloud-owner = " + cloudOwner +", cloud-region-id = "+ cloudRegionId + error.getMessage());
 145     }
 146     return registeredVimInfo;
 147   }
 148
 149   private String getResourceVersion(String cloudOwner, String cloudRegionId) {
 150     CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
 151     try {
 152       String cloudRegionstr = CloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
 153       cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
 154       return cloudRegionDetail.getResouceVersion();
 155     } catch (Exception error) {
 156       LOG.error("query VIM detail failed ! cloud-owner = " + cloudOwner +", cloud-region-id = "+ cloudRegionId + error.getMessage());
 157       return null;
 158     }
 159   }
 160
 161   public Response delVim(String vimId) {
 162     //TODO
 163     return Response.noContent().build();
 164   }
 165 }