2 * Copyright 2017-2018 ZTE Corporation.
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
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
16 package org.onap.aai.esr.wrapper;
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.rest.VimRegisterInfo;
26 import org.onap.aai.esr.entity.rest.VimRegisterResponse;
27 import org.onap.aai.esr.exception.ExceptionUtil;
28 import org.onap.aai.esr.exception.ExtsysException;
29 import org.onap.aai.esr.externalservice.aai.CloudRegionProxy;
30 import org.onap.aai.esr.externalservice.cloud.Tenant;
31 import org.onap.aai.esr.externalservice.cloud.VimManagerProxy;
32 import org.onap.aai.esr.util.ExtsysUtil;
33 import org.onap.aai.esr.util.VimManagerUtil;
34 import org.slf4j.Logger;
35 import org.slf4j.LoggerFactory;
36 import com.google.gson.Gson;
38 public class VimManagerWrapper {
40 private static VimManagerWrapper vimManagerWrapper;
41 private static final Logger LOG = LoggerFactory.getLogger(VimManagerWrapper.class);
43 private static VimManagerUtil vimManagerUtil = new VimManagerUtil();
45 private static CloudRegionProxy cloudRegionProxy = new CloudRegionProxy();
47 private static ExtsysUtil extsysUtil = new ExtsysUtil();
50 * get VimManagerWrapper instance.
52 * @return vim manager wrapper instance
54 public static VimManagerWrapper getInstance() {
55 if (vimManagerWrapper == null) {
56 vimManagerWrapper = new VimManagerWrapper(cloudRegionProxy);
58 return vimManagerWrapper;
61 public VimManagerWrapper(CloudRegionProxy cloudRegionProxy) {
62 VimManagerWrapper.cloudRegionProxy = cloudRegionProxy;
65 public Response registerVim(VimRegisterInfo vimRegisterInfo) {
66 LOG.info("Start register VIM, input VIM info is: " + extsysUtil.objectToString(vimRegisterInfo));
67 VimRegisterResponse result = new VimRegisterResponse();
68 CloudRegionDetail cloudRegion = vimManagerUtil.vimRegisterInfo2CloudRegion(vimRegisterInfo);
69 String cloudOwner = vimRegisterInfo.getCloudOwner();
70 String cloudRegionId = vimRegisterInfo.getCloudRegionId();
72 cloudRegionProxy.registerVim(cloudOwner, cloudRegionId, cloudRegion);
73 result.setCloudOwner(cloudOwner);
74 result.setCloudRegionId(cloudRegionId);
75 Tenant tenant = new Tenant();
76 tenant.setDefaultTenant(cloudRegion.getEsrSystemInfoList().getEsrSystemInfo().get(0).getDefaultTenant());
78 VimManagerProxy.updateVim(cloudOwner, cloudRegionId, tenant);
79 } catch (ExtsysException e) {
80 LOG.error("Update VIM by Multi-cloud failed !", e);
82 return Response.ok(result).build();
83 } catch (ExtsysException error) {
84 LOG.error("Register VIM failed !", error);
85 throw ExceptionUtil.buildExceptionResponse(error.getMessage());
89 public Response updateVim(String cloudOwner, String cloudRegionId, VimRegisterInfo vimRegisterInfo) {
90 LOG.info("Start update VIM, input VIM info is: " + extsysUtil.objectToString(vimRegisterInfo));
91 VimRegisterResponse result = new VimRegisterResponse();
93 CloudRegionDetail cloudRegionDetail = getVimUpdateInfo(vimRegisterInfo);
95 cloudRegionProxy.registerVim(cloudOwner, cloudRegionId, cloudRegionDetail);
96 result.setCloudOwner(cloudOwner);
97 result.setCloudRegionId(cloudRegionId);
98 return Response.ok(result).build();
99 } catch (ExtsysException e) {
100 LOG.error("Update VIM failed !", e);
101 throw ExceptionUtil.buildExceptionResponse(e.getMessage());
105 public Response queryVimListDetails() {
106 List<VimRegisterInfo> vimRegisterInfos = new ArrayList<>();
107 CloudRegionList cloudRegionList = new CloudRegionList();
109 String aaiVimList = cloudRegionProxy.qureyVimList();
110 cloudRegionList = new Gson().fromJson(aaiVimList, CloudRegionList.class);
111 vimRegisterInfos = getVimDetailList(cloudRegionList);
112 return Response.ok(vimRegisterInfos).build();
113 } catch (ExtsysException error) {
114 LOG.error("Query vim list details failed !", error);
115 return Response.ok(vimRegisterInfos).build();
120 public Response queryVimById(String cloudOwner, String cloudRegionId) {
121 VimRegisterInfo vim = new VimRegisterInfo();
122 CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
124 String cloudRegionstr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
125 LOG.info("Response from AAI by query VIM: " + cloudRegionstr);
126 cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
127 vim = vimManagerUtil.cloudRegion2VimRegisterInfo(cloudRegionDetail);
128 return Response.ok(vim).build();
129 } catch (ExtsysException e) {
130 LOG.error("Query vim details by ID failed !", e);
131 return Response.ok(vim).build();
136 private List<VimRegisterInfo> getVimDetailList(CloudRegionList cloudRegionList) {
137 List<VimRegisterInfo> vimRegisterInfos = new ArrayList<>();
138 int cloudRegionNum = cloudRegionList.getCloudRegion().size();
139 for (int i = 0; i < cloudRegionNum; i++) {
140 String cloudOwner = cloudRegionList.getCloudRegion().get(i).getCloudOwner();
141 String cloudRegionId = cloudRegionList.getCloudRegion().get(i).getCloudRegionId();
142 VimRegisterInfo vimRegisterInfo = getVimDetail(cloudOwner, cloudRegionId);
143 vimRegisterInfos.add(vimRegisterInfo);
145 return vimRegisterInfos;
148 private VimRegisterInfo getVimDetail(String cloudOwner, String cloudRegionId) {
149 CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
150 VimRegisterInfo registeredVimInfo = new VimRegisterInfo();
152 String cloudRegionstr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
153 cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
154 registeredVimInfo = vimManagerUtil.cloudRegion2VimRegisterInfo(cloudRegionDetail);
155 } catch (ExtsysException error) {
156 LOG.error("query VIM detail failed ! cloud-owner = " + cloudOwner + ", cloud-region-id = " + cloudRegionId,
159 return registeredVimInfo;
162 private CloudRegionDetail getOriginalCloudRegion(String cloudOwner, String cloudRegionId) {
163 CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
165 String cloudRegionstr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
166 cloudRegionDetail = new Gson().fromJson(cloudRegionstr, CloudRegionDetail.class);
167 return cloudRegionDetail;
168 } catch (ExtsysException error) {
169 LOG.error("query VIM detail failed ! cloud-owner = " + cloudOwner + ", cloud-region-id = " + cloudRegionId,
175 private CloudRegionDetail getVimUpdateInfo(VimRegisterInfo vimRegisterInfo) {
176 String cloudOwner = vimRegisterInfo.getCloudOwner();
177 String cloudRegionId = vimRegisterInfo.getCloudRegionId();
178 CloudRegionDetail originalCloudRegionDetail = getOriginalCloudRegion(cloudOwner, cloudRegionId);
179 String resourceVersion = originalCloudRegionDetail.getResourceVersion();
180 CloudRegionDetail cloudRegionDetail = vimManagerUtil.vimRegisterInfo2CloudRegion(vimRegisterInfo);
181 if (resourceVersion != null) {
182 cloudRegionDetail.setResourceVersion(resourceVersion);
183 EsrSystemInfo originalSystemInfo = originalCloudRegionDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0);
184 cloudRegionDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0)
185 .setEsrSystemInfoId(originalSystemInfo.getEsrSystemInfoId());
186 cloudRegionDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0)
187 .setResouceVersion(originalSystemInfo.getResouceVersion());
189 return cloudRegionDetail;
192 public Response delVim(String cloudOwner, String cloudRegionId) {
193 CloudRegionDetail cloudRegionDetail = queryCloudRegionDetail(cloudOwner, cloudRegionId);
194 String resourceVersion = cloudRegionDetail.getResourceVersion();
196 cloudRegionProxy.deleteVim(cloudOwner, cloudRegionId, resourceVersion);
197 return Response.noContent().build();
198 } catch (ExtsysException e) {
199 LOG.error("Delete cloud region from A&AI failed! cloud-owner = " + cloudOwner + ", cloud-region-id = "
200 + cloudRegionId + "resouce-version:" + resourceVersion, e);
201 throw ExceptionUtil.buildExceptionResponse(e.getMessage());
205 private CloudRegionDetail queryCloudRegionDetail(String cloudOwner, String cloudRegionId) {
206 CloudRegionDetail cloudRegionDetail = new CloudRegionDetail();
208 String cloudRegionStr = cloudRegionProxy.queryVimDetail(cloudOwner, cloudRegionId);
209 LOG.info("Response from AAI by query cloud region: " + cloudRegionStr);
210 cloudRegionDetail = new Gson().fromJson(cloudRegionStr, CloudRegionDetail.class);
211 } catch (ExtsysException e) {
212 LOG.error("Query EMS detail failed! cloud-owner = " + cloudOwner + ", cloud-region-id = " + cloudRegionId,
214 throw ExceptionUtil.buildExceptionResponse(e.getMessage());
216 return cloudRegionDetail;
219 public Response queryComplexes() {
220 ComplexList complexList = new ComplexList();
221 List<String> complexId = new ArrayList<>();
223 String complexesString = cloudRegionProxy.qureyComplexes();
224 LOG.info("The complex query result is: " + complexesString);
225 complexList = new Gson().fromJson(complexesString, ComplexList.class);
226 for (int i=0; i<complexList.getComplex().size(); i++) {
227 complexId.add(complexList.getComplex().get(i).getPhysicalLocationId());
229 } catch (ExtsysException e) {
230 LOG.error("Query vim details by ID failed !", e);
232 return Response.ok(complexId).build();