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("vnf_id"));
 202             basicInfoJson.put("vnfInstanceName", retJson.getString("vnf_name"));
 203             basicInfoJson.put("vnfInstanceDescription", "");
 204
 205             basicInfoJson.put(Constant.VNFDID, retJson.getString("vnfd_id"));
 206             basicInfoJson.put("vnfdPackageId", retJson.getString("vnfd_id"));
 207             basicInfoJson.put("version", "1.0");
 208             basicInfoJson.put("vnfProvider", "hw");
 209             basicInfoJson.put("vnfType", retJson.get("vnf_type"));
 210             basicInfoJson.put("vnfStatus", retJson.getString(Constant.STATUS));
 211
 212             vnfInfoJson.put("vnfInfo", basicInfoJson);
 213             vnfInfoJson.put(Constant.RETCODE, Constant.REST_SUCCESS);
 214             return vnfInfoJson;
 215         } catch(JSONException e) {
 216             LOG.error("function=getVnf, msg=JSONException occurs, e={}.", e);
 217             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 218             return restJson;
 219         } catch(IndexOutOfBoundsException e) {
 220             LOG.error("function=getVnf, msg=IndexOutOfBoundsException occurs, e={}.", e);
 221             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 222             return restJson;
 223         }
 224     }
 225
 226     @SuppressWarnings("unchecked")
 227     private JSONObject transferVnfBody(JSONObject vnfObject, JSONObject resObject, String vnfmId) {
 228         JSONObject restJson = new JSONObject();
 229         JSONObject vappIfno = new JSONObject();
 230         restJson.put("vnfd_id", resObject.getString(Constant.VNFDID));
 231         restJson.put("plan_id", resObject.getOrDefault("planId", ""));
 232         restJson.put("plan_name", resObject.getOrDefault("planName", ""));
 233         restJson.put("vapp_name", vnfObject.get("vnfInstanceName"));
 234         restJson.put("project_id", vnfmId);
 235         restJson.put("parameters", resObject.getJSONObject("parameters"));
 236         restJson.put("nfvo_id", "");
 237         restJson.put("location", "");
 238         restJson.put("vnfm_id", vnfmId);
 239         vappIfno.put("vapp_info", restJson);
 240         return vappIfno;
 241     }
 242
 243     /**
 244      * Provide function for get job
 245      * <br/>
 246      *
 247      * @param jobId
 248      * @param vnfmId
 249      * @return
 250      * @since VFC 1.0
 251      */
 252     public JSONObject getJob(String jobId, String vnfmId) {
 253         LOG.warn("function=getJob ,msg=enter to get a job, vnfId:{}", jobId);
 254         JSONObject restJson = new JSONObject();
 255         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 256         try {
 257             JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 258             if(vnfmObjcet.isNullObject()) {
 259                 LOG.error("function=getJob, msg=vnfm not exists, vnfmId: {}", vnfmId);
 260                 return restJson;
 261             }
 262
 263             restJson = (new VnfMgrVnfm()).getJob(vnfmObjcet, jobId);
 264
 265         } catch(JSONException e) {
 266             LOG.error("function=getJob, msg=JSONException occurs, e={}.", e);
 267             restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 268         }
 269         return restJson;
 270     }
 271
 272     /**
 273      * Provide function for save vnfInfo
 274      * <br/>
 275      *
 276      * @param vnfObject
 277      * @param resObject
 278      * @since VFC 1.0
 279      */
 280     public void saveVnfInfo(JSONObject vnfObject, JSONObject resObject) {
 281         LOG.warn("function=saveVnfInfo , vnfObject:{}", vnfObject);
 282         if(vnfObject.getInt(Constant.RETCODE) == Constant.REST_SUCCESS) {
 283             Vnfm info = new Vnfm();
 284             info.setId(vnfObject.getJSONObject("data").getString("vnfInstanceId"));
 285             info.setVersion(resObject.getString("vnfdVersion"));
 286             info.setVnfdId(resObject.getString(Constant.VNFDID));
 287             info.setVnfPackageId("");
 288             try {
 289                 vnfmDao.insertVnfm(info);
 290             } catch(Exception e) {
 291                 LOG.error("function=saveVnfInfo, msg=ServiceException occurs, e={}.", e);
 292             }
 293         }
 294     }
 295
 296     /**
 297      * <br>
 298      *
 299      * @param jsonObject
 300      * @param vnfInstanceId
 301      * @param vnfmId
 302      * @return
 303      * @since VFC 1.0
 304      */
 305     public JSONObject healVnf(JSONObject jsonObject, String vnfInstanceId, String vnfmId) {
 306         JSONObject restJson = new JSONObject();
 307         restJson.put(Constant.RETCODE, Constant.REST_FAIL);
 308
 309         if(jsonObject.isNullObject() || jsonObject.isEmpty()) {
 310             return restJson;
 311         }
 312
 313         JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 314         LOG.info("vnfm info:" + vnfmObjcet);
 315         if(vnfmObjcet.isNullObject()) {
 316             LOG.error("function=scaleVNF,can't find vnfm from db by vnfmId=" + vnfmId);
 317             return restJson;
 318         }
 319         restJson = (new VnfMgrVnfm()).healVnf(jsonObject, vnfmObjcet, vnfmId, vnfInstanceId);
 320         return restJson;
 321     }
 322
 323     public JSONObject getJobFromVnfm(String jobId, String vnfmId) {
 324         LOG.warn("function=getJobFromVnfm, jobId:{}, vnfmId:{}", jobId, vnfmId);
 325         JSONObject restJson = new JSONObject();
 326         JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 327         if(vnfmObjcet.isNullObject()) {
 328             LOG.error("function=getJobFromVnfm, msg=vnfm not exists, vnfmId: {}", vnfmId);
 329             return restJson;
 330         }
 331         restJson = (new VnfMgrVnfm()).getJobFromVnfm(vnfmObjcet, jobId);
 332         return restJson;
 333     }
 334
 335     public String transferToLcm(JSONObject restJson) {
 336         LOG.warn("function=transferToLcm, restJson: {}", restJson);
 337         JSONObject responseJson = new JSONObject();
 338         JSONObject jobInfoJson = new JSONObject();
 339         JSONObject jobInfo = restJson.getJSONObject("data").getJSONObject("job_info");
 340         jobInfoJson.put("jobId", jobInfo.getString("job_id"));
 341         responseJson.put("progress", jobInfo.getString("task_progress_rate"));
 342         responseJson.put("status", jobInfo.getString("task_status"));
 343         responseJson.put("errorCode", jobInfo.getString("error_code"));
 344         responseJson.put("responseId", jobInfo.getString("task_progress_rate"));
 345         jobInfoJson.put("responsedescriptor", responseJson);
 346         LOG.warn("function=getJobBody, jobInfoJson: {}", jobInfoJson);
 347         return jobInfoJson.toString();
 348     }
 349
 350     public JSONObject getVmsFromVnfm(String vnfmId, String vnfInstanceId) {
 351         JSONObject restJson = new JSONObject();
 352         JSONObject vnfmObjcet = VnfmUtil.getVnfmById(vnfmId);
 353         if(vnfmObjcet.isNullObject()) {
 354             LOG.error("function=getVmsFromVnfm, msg=vnfm not exists, vnfmId: {}", vnfmId);
 355             restJson.put("message", "vnfm not exists");
 356             return restJson;
 357         }
 358         String url = "";
 359         if(vnfInstanceId == null) {
 360             url = "/v2/vapps/instances/query/vms";
 361         } else {
 362             url = String.format("/v2/vapps/instances/%s/vms", vnfInstanceId);
 363         }
 364         restJson = ResultRequestUtil.call(vnfmObjcet, url, Constant.GET, null, Constant.CERTIFICATE);
 365         LOG.info("function=getVmsFromVnfm, restJson: {}", restJson);
 366         return restJson;
 367     }
 368 }