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

   1 /**
   2  * Copyright 2019  Verizon. All Rights Reserved.
   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.EsrSystemInfo;
  22 import org.onap.aai.esr.entity.aai.EsrNfvoDetail;
  23 import org.onap.aai.esr.entity.aai.EsrNfvoList;
  24 import org.onap.aai.esr.entity.rest.CommonRegisterResponse;
  25 import org.onap.aai.esr.entity.rest.NfvoRegisterInfo;
  26 import org.onap.aai.esr.exception.ExceptionUtil;
  27 import org.onap.aai.esr.exception.ExtsysException;
  28 import org.onap.aai.esr.externalservice.aai.ExternalSystemProxy;
  29 import org.onap.aai.esr.util.NfvoManagerUtil;
  30 import org.slf4j.Logger;
  31 import org.slf4j.LoggerFactory;
  32 import com.google.gson.Gson;
  33
  34 public class NfvoManagerWrapper {
  35     private static NfvoManagerWrapper NfvoManagerWrapper;
  36     private static final Logger LOG = LoggerFactory.getLogger(NfvoManagerWrapper.class);
  37
  38     private static NfvoManagerUtil nfvoManagerUtil = new NfvoManagerUtil();
  39     private static ExternalSystemProxy externalSystemProxy = new ExternalSystemProxy();
  40
  41     /**
  42      * get NfvoManagerWrapper instance.
  43      *
  44      * @return nfvo manager wrapper instance
  45      */
  46     public static NfvoManagerWrapper getInstance() {
  47         if (NfvoManagerWrapper == null) {
  48             NfvoManagerWrapper = new NfvoManagerWrapper(externalSystemProxy);
  49         }
  50         return NfvoManagerWrapper;
  51     }
  52
  53     public NfvoManagerWrapper(ExternalSystemProxy externalSystemProxy){
  54         NfvoManagerWrapper.externalSystemProxy = externalSystemProxy;
  55     }
  56
  57     public Response registerNfvo(NfvoRegisterInfo nfvo) {
  58         CommonRegisterResponse result = new CommonRegisterResponse();
  59         EsrNfvoDetail esrNfvoDetail = nfvoManagerUtil.nfvoRegisterInfo2EsrNfvo(nfvo);
  60         String nfvoId = esrNfvoDetail.getNfvoId();
  61         try {
  62             externalSystemProxy.registerNfvo(nfvoId, esrNfvoDetail);
  63             result.setId(nfvoId);
  64             return Response.ok(result).build();
  65         } catch (ExtsysException e) {
  66             LOG.error("Register NFVO failed !", e);
  67             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
  68         }
  69     }
  70
  71     public Response updateNfvo(NfvoRegisterInfo nfvo, String nfvoId) {
  72         CommonRegisterResponse result = new CommonRegisterResponse();
  73         EsrNfvoDetail originalEsrNfvoDetail = queryEsrNfvoDetail(nfvoId);
  74         EsrNfvoDetail esrNfvoDetail = nfvoManagerUtil.nfvoRegisterInfo2EsrNfvo(nfvo);
  75         String resourceVersion = getResourceVersion(nfvoId);
  76         esrNfvoDetail.setResourceVersion(resourceVersion);
  77         esrNfvoDetail.setNfvoId(nfvoId);
  78         EsrSystemInfo originalEsrSystemInfo = originalEsrNfvoDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0);
  79         esrNfvoDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0)
  80                 .setEsrSystemInfoId(originalEsrSystemInfo.getEsrSystemInfoId());
  81         esrNfvoDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0)
  82                 .setResouceVersion(originalEsrSystemInfo.getResouceVersion());
  83         try {
  84             externalSystemProxy.registerNfvo(nfvoId, esrNfvoDetail);
  85             result.setId(nfvoId);
  86             return Response.ok(result).build();
  87         } catch (ExtsysException e) {
  88             LOG.error("Update NFVO failed !", e);
  89             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
  90         }
  91     }
  92
  93     public Response queryNfvoList() {
  94         List<NfvoRegisterInfo> nfvoList = new ArrayList<>();
  95         EsrNfvoList esrNfvo = new EsrNfvoList();
  96         try {
  97             String esrNfvoStr = externalSystemProxy.queryNfvoList();
  98             esrNfvo = new Gson().fromJson(esrNfvoStr, EsrNfvoList.class);
  99             LOG.info("Response from AAI by query NFVO list: " + esrNfvo);
 100             nfvoList = getNfvoDetailList(esrNfvo);
 101             return Response.ok(nfvoList).build();
 102         } catch (ExtsysException e) {
 103             LOG.error("Query NFVO list failed !", e);
 104             return Response.ok(nfvoList).build();
 105         }
 106     }
 107
 108     public Response queryNfvoById(String nfvoId) {
 109         NfvoRegisterInfo nfvo = queryNfvoDetail(nfvoId);
 110         if (nfvo != null) {
 111             return Response.ok(nfvo).build();
 112         } else {
 113             return Response.ok(nfvo).build();
 114         }
 115     }
 116
 117     public Response delNfvo(String nfvoId) {
 118         String resourceVersion = getResourceVersion(nfvoId);
 119         try {
 120             externalSystemProxy.deleteNfvo(nfvoId, resourceVersion);
 121             return Response.noContent().build();
 122         } catch (ExtsysException e) {
 123             LOG.error("Delete NFVO from A&AI failed! NFVO ID: " + nfvoId + "resouce-version:" + resourceVersion, e);
 124             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
 125         }
 126     }
 127
 128     private NfvoRegisterInfo queryNfvoDetail(String nfvoId) {
 129         NfvoRegisterInfo nfvo = new NfvoRegisterInfo();
 130         EsrNfvoDetail esrNfvoDetail = new EsrNfvoDetail();
 131         try {
 132             String esrNfvostr = externalSystemProxy.queryNfvoDetail(nfvoId);
 133             LOG.info("Response from AAI by query NFVO: " + esrNfvostr);
 134             esrNfvoDetail = new Gson().fromJson(esrNfvostr, EsrNfvoDetail.class);
 135             nfvo = nfvoManagerUtil.esrNfvo2NfvoRegisterInfo(esrNfvoDetail);
 136         } catch (ExtsysException e) {
 137             LOG.error("Query NFVO detail failed! NFVO ID: " + nfvoId, e);
 138         }
 139         return nfvo;
 140     }
 141
 142     private List<NfvoRegisterInfo> getNfvoDetailList(EsrNfvoList esrNfvo) {
 143         List<NfvoRegisterInfo> nfvoInfoList = new ArrayList<>();
 144         for (int i = 0; i < esrNfvo.getEsrNfvo().size(); i++) {
 145             String nfvoId = esrNfvo.getEsrNfvo().get(i).getNfvoId();
 146             NfvoRegisterInfo nfvoInfo = queryNfvoDetail(nfvoId);
 147             if (nfvoInfo != null) {
 148                 nfvoInfoList.add(nfvoInfo);
 149             }
 150         }
 151         return nfvoInfoList;
 152     }
 153
 154     private String getResourceVersion(String nfvoId) {
 155         String resourceVersion = null;
 156         EsrNfvoDetail esrNfvoDetail = queryEsrNfvoDetail(nfvoId);
 157         if (esrNfvoDetail != null && esrNfvoDetail.getResourceVersion() != null) {
 158             resourceVersion = esrNfvoDetail.getResourceVersion();
 159         }
 160         return resourceVersion;
 161     }
 162
 163     private EsrNfvoDetail queryEsrNfvoDetail(String nfvoId) {
 164         EsrNfvoDetail esrNfvoDetail = new EsrNfvoDetail();
 165         try {
 166             String esrNfvostr = externalSystemProxy.queryNfvoDetail(nfvoId);
 167             LOG.info("Response from AAI by query NFVO: " + esrNfvostr);
 168             esrNfvoDetail = new Gson().fromJson(esrNfvostr, EsrNfvoDetail.class);
 169         } catch (ExtsysException e) {
 170             LOG.error("Query NFVO detail failed! NFVO ID: " + nfvoId, e);
 171             throw ExceptionUtil.buildExceptionResponse(e.getMessage());
 172         }
 173         return esrNfvoDetail;
 174     }
 175 }