huawei/vnfmadapter/VnfmadapterService/service/src/main/java/org/onap/vfc/nfvo/vnfm/svnfm/vnfmadapter/service/process/VnfMgr.java

   1 /*
   2  * Copyright 2016-2017 Huawei Technologies Co., Ltd.
   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
  17 package org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.process;
  18
  19 import java.util.Map;
  20 import java.util.concurrent.ConcurrentHashMap;
  21
  22 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.ResultRequestUtil;
  23 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.VnfmUtil;
  24 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.adapter.impl.AdapterResourceManager;
  25 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
  26 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.csm.vnf.VnfMgrVnfm;
  27 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.dao.inf.VnfmDao;
  28 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.entity.Vnfm;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 import net.sf.json.JSONException;
  33 import net.sf.json.JSONObject;
  34
  35 /**
  36  * Provide function for instantiate or terminate VNF
  37  * <br/>
  38  *
  39  * @author
  40  * @version VFC 1.0 Aug 24, 2016
  41  */
  42 public class VnfMgr {
  43
  44     private static final Logger LOG = LoggerFactory.getLogger(VnfMgr.class);
  45
  46     private VnfmDao vnfmDao;
  47
  48     public void setVnfmDao(VnfmDao vnfmDao) {
  49         this.vnfmDao = vnfmDao;
  50     }
  51
  52     /**
  53      * Scale vnf
  54      *
  55      * @param vnfObject
  56      *            {
  57      *            "vnfInstanceId":"5",
  58      *            "type":"SCALE_OUT",
  59      *            "aspectId":"101",
  60      *            "numberOfSteps":"1",
  61      *            "additionalParam":{}
  62      *            }
  63      * @param vnfmId
  64      * @param vnfInstanceId
  65      * @return
  66      */
  67     public JSONObject scaleVNF(JSONObject vnfObject, String vnfmId, String vnfInstanceId) {
  68         JSONObject restJson = new JSONObject();
  69         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
  70         try {
  71
  72             if(vnfObject.isNullObject() || vnfObject.isEmpty()) {
  73                 return restJson;
  74             }
  75
  76             JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
  77             LOG.info("vnfm info:" + vnfmObjcet);
  78             if(vnfmObjcet.isNullObject()) {
  79                 LOG.error("function=scaleVNF,can't find vnfm from db by vnfmId=" + vnfmId);
  80                 return restJson;
  81             }
  82             restJson = (new VnfMgrVnfm()).scaleVnf(vnfObject, vnfmObjcet, vnfmId, vnfInstanceId);
  83         } catch(JSONException e) {
  84             LOG.error("function=scaleVNF, msg=JSONException occurs, e={}.", e);
  85         }
  86
  87         return restJson;
  88     }
  89
  90     /**
  91      * Provide function for instantiate VNF
  92      * <br/>
  93      *
  94      * @param vnfObject
  95      * @param vnfmId
  96      * @return
  97      * @since VFC 1.0
  98      */
  99     public JSONObject addVnf(JSONObject vnfObject, String vnfmId) {
 100         JSONObject restJson = new JSONObject();
 101         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 102         try {
 103
 104             if(vnfObject.isNullObject() || vnfObject.isEmpty()) {
 105                 return restJson;
 106             }
 107
 108             JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 109
 110             if(vnfmObjcet.isNullObject()) {
 111                 return restJson;
 112             }
 113
 114             Map<String, String> conMap = new ConcurrentHashMap<>(Constant.DEFAULT_COLLECTION_SIZE);
 115             conMap.put("csarid", vnfObject.getString("vnfPackageId"));
 116             conMap.put("vnfmid", vnfmId);
 117             conMap.put("vnfDescriptorId", vnfObject.getString("vnfDescriptorId"));
 118
 119             JSONObject resObjcet = (new AdapterResourceManager()).uploadVNFPackage(null, conMap);
 120
 121             if(resObjcet.getInt(Constant.RETCODE) == Constant.REST_FAIL) {
 122                 return restJson;
 123             }
 124
 125             JSONObject csmBody = transferVnfBody(vnfObject, resObjcet, vnfmId);
 126             restJson = (new VnfMgrVnfm()).createVnf(csmBody, vnfmObjcet);
 127             saveVnfInfo(restJson, resObjcet);
 128         } catch(JSONException e) {
 129             LOG.error("function=addVnf, msg=JSONException occurs, e={}.", e);
 130         }
 131
 132         return restJson;
 133     }
 134
 135     /**
 136      * Provide function for terminate VNF
 137      * <br/>
 138      *
 139      * @param vnfId
 140      * @param vnfmId
 141      * @param vnfObject
 142      * @return
 143      * @since VFC 1.0
 144      */
 145     public JSONObject deleteVnf(String vnfId, String vnfmId, JSONObject vnfObject) {
 146         LOG.warn("function=deleteVnf ,msg=enter to delete a vnf, vnfId:{}, vnfmId:{}", vnfId, vnfmId);
 147         JSONObject restJson = new JSONObject();
 148         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 149         try {
 150             JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 151             if(vnfmObjcet.isNullObject()) {
 152                 LOG.error("function=deleteVnf, msg=vnfm not exists, vnfmId: {}", vnfmId);
 153                 return restJson;
 154             }
 155
 156             restJson = (new VnfMgrVnfm()).removeVnf(vnfmObjcet, vnfId, vnfObject);
 157         } catch(JSONException e) {
 158             LOG.error("function=deleteVnf, msg=JSONException occurs, e={}.", e);
 159         }
 160         return restJson;
 161     }
 162
 163     /**
 164      * Provide function for get VNF
 165      * <br/>
 166      *
 167      * @param vnfId
 168      * @param vnfmId
 169      * @return
 170      * @since VFC 1.0
 171      */
 172     public JSONObject getVnf(String vnfId, String vnfmId) {
 173         LOG.warn("function=getVnf ,msg=enter to get a vnf, vnfId:{}, vnfmId:{}", vnfId, vnfmId);
 174         JSONObject restJson = new JSONObject();
 175         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 176         try {
 177             JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 178             if(vnfmObjcet.isNullObject()) {
 179                 LOG.error("function=getVnf, msg=vnfm not exists, vnfmId: {}", vnfmId);
 180                 return restJson;
 181             }
 182
 183             restJson = (new VnfMgrVnfm()).getVnf(vnfmObjcet, vnfId);
 184
 185             return restJson.getInt(Constant.RETCODE) == Constant.REST_FAIL ? restJson : getVnfBody(restJson);
 186
 187         } catch(JSONException e) {
 188             LOG.error("function=getVnf, msg=JSONException occurs, e={}.", e);
 189             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 190         }
 191         return restJson;
 192     }
 193
 194     private JSONObject getVnfBody(JSONObject restJson) {
 195         try {
 196             JSONObject vnfInfoJson = new JSONObject();
 197             JSONObject basicInfoJson = new JSONObject();
 198
 199             JSONObject retJson = restJson.getJSONArray("data").getJSONObject(0);
 200
 201             basicInfoJson.put("vnfInstanceId", retJson.getString("id"));
 202             basicInfoJson.put("vnfInstanceName", retJson.getString("vapp_name"));
 203             basicInfoJson.put("vnfInstanceDescription", "vFW");
 204
 205             Vnfm vnfm = vnfmDao.getVnfmById(retJson.getString("id"));
 206             basicInfoJson.put(Constant.VNFDID, vnfm == null ? "" : vnfm.getVnfdId());
 207             basicInfoJson.put("vnfdPackageId", vnfm == null ? "" : vnfm.getVnfPackageId());
 208             basicInfoJson.put("version", vnfm == null ? "" : vnfm.getVersion());
 209             basicInfoJson.put("vnfProvider", "hw");
 210             basicInfoJson.put("vnfType", retJson.get("vapp_type"));
 211             basicInfoJson.put("vnfStatus", retJson.getString(Constant.STATUS));
 212
 213             vnfInfoJson.put("vnfInfo", basicInfoJson);
 214             vnfInfoJson.put(Constant.RETCODE, Constant.REST_SUCCESS);
 215             return vnfInfoJson;
 216         } catch(JSONException e) {
 217             LOG.error("function=getVnf, msg=JSONException occurs, e={}.", e);
 218             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 219             return restJson;
 220         } catch(IndexOutOfBoundsException e) {
 221             LOG.error("function=getVnf, msg=IndexOutOfBoundsException occurs, e={}.", e);
 222             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 223             return restJson;
 224         }
 225     }
 226
 227     @SuppressWarnings("unchecked")
 228     private JSONObject transferVnfBody(JSONObject vnfObject, JSONObject resObject, String vnfmId) {
 229         JSONObject restJson = new JSONObject();
 230         JSONObject vappIfno = new JSONObject();
 231         restJson.put("vnfd_id", resObject.getString(Constant.VNFDID));
 232         restJson.put("plan_id", resObject.getOrDefault("planId", ""));
 233         restJson.put("plan_name", resObject.getOrDefault("planName", ""));
 234         restJson.put("vapp_name", vnfObject.get("vnfInstanceName"));
 235         restJson.put("project_id", vnfmId);
 236         restJson.put("parameters", resObject.getJSONObject("parameters"));
 237         restJson.put("nfvo_id", "");
 238         restJson.put("location", "");
 239         restJson.put("vnfm_id", vnfmId);
 240         vappIfno.put("vapp_info", restJson);
 241         return vappIfno;
 242     }
 243
 244     /**
 245      * Provide function for get job
 246      * <br/>
 247      *
 248      * @param jobId
 249      * @param vnfmId
 250      * @return
 251      * @since VFC 1.0
 252      */
 253     public JSONObject getJob(String jobId, String vnfmId) {
 254         LOG.warn("function=getJob ,msg=enter to get a job, vnfId:{}", jobId);
 255         JSONObject restJson = new JSONObject();
 256         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 257         try {
 258             JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 259             if(vnfmObjcet.isNullObject()) {
 260                 LOG.error("function=getJob, msg=vnfm not exists, vnfmId: {}", vnfmId);
 261                 return restJson;
 262             }
 263
 264             restJson = (new VnfMgrVnfm()).getJob(vnfmObjcet, jobId);
 265
 266         } catch(JSONException e) {
 267             LOG.error("function=getJob, msg=JSONException occurs, e={}.", e);
 268             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 269         }
 270         return restJson;
 271     }
 272
 273     /**
 274      * Provide function for save vnfInfo
 275      * <br/>
 276      *
 277      * @param vnfObject
 278      * @param resObject
 279      * @since VFC 1.0
 280      */
 281     public void saveVnfInfo(JSONObject vnfObject, JSONObject resObject) {
 282         LOG.warn("function=saveVnfInfo , vnfObject:{}", vnfObject);
 283         if(vnfObject.getInt(Constant.RETCODE) == Constant.REST_SUCCESS) {
 284             Vnfm info = new Vnfm();
 285             info.setId(vnfObject.getJSONObject("data").getString("vnfInstanceId"));
 286             info.setVersion(resObject.getString("vnfdVersion"));
 287             info.setVnfdId(resObject.getString(Constant.VNFDID));
 288             info.setVnfPackageId("");
 289             try {
 290                 vnfmDao.insertVnfm(info);
 291             } catch(Exception e) {
 292                 LOG.error("function=saveVnfInfo, msg=ServiceException occurs, e={}.", e);
 293             }
 294         }
 295     }
 296
 297     /**
 298      * <br>
 299      *
 300      * @param jsonObject
 301      * @param vnfInstanceId
 302      * @param vnfmId
 303      * @return
 304      * @since VFC 1.0
 305      */
 306     public JSONObject healVnf(JSONObject jsonObject, String vnfInstanceId, String vnfmId) {
 307         JSONObject restJson = new JSONObject();
 308         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 309
 310         if(jsonObject.isNullObject() || jsonObject.isEmpty()) {
 311             return restJson;
 312         }
 313
 314         JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 315         LOG.info("vnfm info:" + vnfmObjcet);
 316         if(vnfmObjcet.isNullObject()) {
 317             LOG.error("function=scaleVNF,can't find vnfm from db by vnfmId=" + vnfmId);
 318             return restJson;
 319         }
 320         restJson = (new VnfMgrVnfm()).healVnf(jsonObject, vnfmObjcet, vnfmId, vnfInstanceId);
 321         return restJson;
 322     }
 323
 324     public JSONObject getJobFromVnfm(String jobId, String vnfmId) {
 325         LOG.warn("function=getJobFromVnfm, jobId:{}, vnfmId:{}", jobId, vnfmId);
 326         JSONObject restJson = new JSONObject();
 327         JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 328         if(vnfmObjcet.isNullObject()) {
 329             LOG.error("function=getJobFromVnfm, msg=vnfm not exists, vnfmId: {}", vnfmId);
 330             return restJson;
 331         }
 332         restJson = (new VnfMgrVnfm()).getJobFromVnfm(vnfmObjcet, jobId);
 333         return restJson;
 334     }
 335
 336     public String transferToLcm(JSONObject restJson) {
 337         LOG.warn("function=transferToLcm, restJson: {}", restJson);
 338         JSONObject responseJson = new JSONObject();
 339         JSONObject jobInfoJson = new JSONObject();
 340         JSONObject jobInfo = restJson.getJSONObject("data").getJSONObject("job_info");
 341         jobInfoJson.put("jobId", jobInfo.getString("job_id"));
 342         responseJson.put("progress", jobInfo.getString("task_progress_rate"));
 343         responseJson.put("status", jobInfo.getString("task_status"));
 344         responseJson.put("errorCode", jobInfo.getString("error_code"));
 345         responseJson.put("responseId", jobInfo.getString("task_progress_rate"));
 346         jobInfoJson.put("responsedescriptor", responseJson);
 347         LOG.warn("function=getJobBody, jobInfoJson: {}", jobInfoJson);
 348         return jobInfoJson.toString();
 349     }
 350
 351     public JSONObject getVmsFromVnfm(String vnfmId, String vnfInstanceId) {
 352         JSONObject restJson = new JSONObject();
 353         JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 354         if(vnfmObjcet.isNullObject()) {
 355             LOG.error("function=getVmsFromVnfm, msg=vnfm not exists, vnfmId: {}", vnfmId);
 356             restJson.put("message", "vnfm not exists");
 357             return restJson;
 358         }
 359         String url = "";
 360         if(vnfInstanceId == null) {
 361             url = "/v2/vapps/instances/query/vms";
 362         } else {
 363             url = String.format("/v2/vapps/instances/%s/vms", vnfInstanceId);
 364         }
 365         restJson = ResultRequestUtil.call(vnfmObjcet, url, Constant.GET, null, Constant.CERTIFICATE);
 366         LOG.info("function=getVmsFromVnfm, restJson: {}", restJson);
 367         return restJson;
 368     }
 369 }