gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  # Copyright (c) 2020, CMCC Technologies Co., Ltd.
   6  #
   7  # Licensed under the Apache License, Version 2.0 (the "License")
   8  # you may not use this file except in compliance with the License.
   9  # You may obtain a copy of the License at
  10  #
  11  #       http://www.apache.org/licenses/LICENSE-2.0
  12  #
  13  # Unless required by applicable law or agreed to in writing, software
  14  # distributed under the License is distributed on an "AS IS" BASIS,
  15  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  # See the License for the specific language governing permissions and
  17  # limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.so.adapters.nssmf.manager.impl;
  22
  23 import org.apache.http.Header;
  24 import org.apache.http.message.BasicHeader;
  25 import org.onap.aai.domain.yang.ServiceInstance;
  26 import org.onap.so.adapters.nssmf.entity.NssmfInfo;
  27 import org.onap.so.adapters.nssmf.entity.RestResponse;
  28 import org.onap.so.adapters.nssmf.enums.JobStatus;
  29 import org.onap.so.adapters.nssmf.exceptions.ApplicationException;
  30 import org.onap.so.adapters.nssmf.util.NssmfAdapterUtil;
  31 import org.onap.so.beans.nsmf.*;
  32 import org.onap.so.db.request.beans.ResourceOperationStatus;
  33 import org.slf4j.Logger;
  34 import org.slf4j.LoggerFactory;
  35 import static java.lang.String.valueOf;
  36 import static org.onap.so.adapters.nssmf.enums.JobStatus.*;
  37 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.StatusDesc.*;
  38 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.marshal;
  39 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.unMarshal;
  40
  41 public abstract class ExternalNssmfManager extends BaseNssmfManager {
  42
  43     private static final Logger logger = LoggerFactory.getLogger(ExternalNssmfManager.class);
  44
  45     @Override
  46     protected String wrapAllocateReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException {
  47         return doWrapExtAllocateReqBody(nbiRequest);
  48     }
  49
  50     protected abstract String doWrapExtAllocateReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException;
  51
  52     @Override
  53     protected String wrapModifyReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException {
  54         return doWrapModifyReqBody(nbiRequest);
  55     }
  56
  57     protected abstract String doWrapModifyReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException;
  58
  59     @Override
  60     protected String wrapDeAllocateReqBody(DeAllocateNssi deAllocateNssi) throws ApplicationException {
  61         return doWrapDeAllocateReqBody(deAllocateNssi);
  62     }
  63
  64     protected abstract String doWrapDeAllocateReqBody(DeAllocateNssi deAllocateNssi) throws ApplicationException;
  65
  66     @Override
  67     protected void afterQueryJobStatus(ResourceOperationStatus status) {
  68         if (Integer.parseInt(status.getProgress()) == 100) {
  69
  70             ServiceInstance nssiInstance = new ServiceInstance();
  71             nssiInstance.setServiceInstanceId(serviceInfo.getNssiId());
  72             nssiInstance.setServiceInstanceName(serviceInfo.getNssiName());
  73             nssiInstance.setServiceType(serviceInfo.getSST());
  74
  75             nssiInstance.setOrchestrationStatus(initStatus);
  76             nssiInstance.setModelInvariantId(serviceInfo.getServiceInvariantUuid());
  77             nssiInstance.setModelVersionId(serviceInfo.getServiceUuid());
  78             nssiInstance.setServiceInstanceLocationId(serviceInfo.getPLMNIdList());
  79             nssiInstance.setEnvironmentContext(esrInfo.getNetworkType().getNetworkType());
  80             nssiInstance.setServiceRole("nssi");
  81
  82             restUtil.createServiceInstance(nssiInstance, serviceInfo);
  83         }
  84     }
  85
  86
  87
  88     @Override
  89     protected String wrapActDeActReqBody(ActDeActNssi actDeActNssi) throws ApplicationException {
  90         return marshal(actDeActNssi);
  91     }
  92
  93     protected RestResponse doQueryJobStatus(ResourceOperationStatus status) throws ApplicationException {
  94         return doResponseStatus(status);
  95     }
  96
  97     private RestResponse doResponseStatus(ResourceOperationStatus status) throws ApplicationException {
  98         RestResponse restResponse = sendRequest(null);
  99         ResponseDescriptor rspDesc =
 100                 unMarshal(restResponse.getResponseContent(), JobStatusResponse.class).getResponseDescriptor();
 101         updateRequestDbJobStatus(rspDesc, status, restResponse);
 102         return restResponse;
 103     }
 104
 105     @Override
 106     protected String wrapReqBody(Object object) throws ApplicationException {
 107         return marshal(object);
 108     }
 109
 110     @Override
 111     protected RestResponse sendRequest(String content) throws ApplicationException {
 112         return sendExternalRequest(content);
 113     }
 114
 115     protected void createStatus(JobStatus jobStatus) throws ApplicationException {
 116         if (valueOf(restResponse.getStatus()).startsWith("2")) {
 117             logger.info("save segment and operaton info -> begin");
 118             NssiResponse response = unMarshal(restResponse.getResponseContent(), NssiResponse.class);
 119             ResourceOperationStatus status = new ResourceOperationStatus(serviceInfo.getNsiId(), response.getJobId(),
 120                     serviceInfo.getServiceUuid());
 121             status.setResourceInstanceID(response.getNssiId());
 122
 123             updateDbStatus(status, restResponse.getStatus(), jobStatus, NssmfAdapterUtil.getStatusDesc(actionType));
 124             logger.info("save segment and operaton info -> end");
 125         }
 126     }
 127
 128     @Override
 129     protected String getApiVersion() {
 130         return "v1";
 131     }
 132
 133
 134     // external
 135     protected RestResponse sendExternalRequest(String content) throws ApplicationException {
 136         NssmfInfo nssmfInfo = restUtil.getNssmfHost(esrInfo);
 137         Header header = new BasicHeader("X-Auth-Token", restUtil.getToken(nssmfInfo));
 138         String nssmfUrl = nssmfInfo.getUrl() + this.nssmfUrl;
 139         return restUtil.send(nssmfUrl, this.httpMethod, content, header);
 140     }
 141
 142     private void updateRequestDbJobStatus(ResponseDescriptor rspDesc, ResourceOperationStatus status, RestResponse rsp)
 143             throws ApplicationException {
 144
 145         switch (fromString(rspDesc.getStatus())) {
 146             case STARTED:
 147                 updateDbStatus(status, rsp.getStatus(), STARTED, QUERY_JOB_STATUS_SUCCESS);
 148                 break;
 149             case PROCESSING:
 150                 updateDbStatus(status, rsp.getStatus(), PROCESSING, QUERY_JOB_STATUS_SUCCESS);
 151                 break;
 152             case FINISHED:
 153                 if (rspDesc.getProgress() == 100) {
 154                     updateDbStatus(status, rsp.getStatus(), FINISHED, QUERY_JOB_STATUS_SUCCESS);
 155                 }
 156                 break;
 157             case ERROR:
 158                 updateDbStatus(status, rsp.getStatus(), ERROR, QUERY_JOB_STATUS_FAILED);
 159                 throw new ApplicationException(500, QUERY_JOB_STATUS_FAILED);
 160         }
 161     }
 162
 163     protected void updateDbStatus(ResourceOperationStatus status, int rspStatus, JobStatus jobStatus,
 164             String description) {
 165         status.setErrorCode(valueOf(rspStatus));
 166         status.setStatus(jobStatus.toString());
 167         status.setStatusDescription(description);
 168         logger.info("Updating DB status");
 169         repository.save(status);
 170         logger.info("Updating successful");
 171     }
 172
 173     @Override
 174     protected RestResponse doQuerySubnetCapability(String req) throws ApplicationException {
 175         RestResponse response = new RestResponse();
 176         response.setStatus(200);
 177         response.setResponseContent(null);
 178         return response;
 179     }
 180
 181     /**
 182      * after request, if response code is 2XX, continue handle, else return
 183      */
 184     @Override
 185     protected void afterRequest() throws ApplicationException {
 186         if (valueOf(restResponse.getStatus()).startsWith("2")) {
 187             doAfterRequest();
 188         }
 189     }
 190
 191
 192     protected void doAfterRequest() throws ApplicationException {
 193         //
 194         NssiResponse response = unMarshal(restResponse.getResponseContent(), NssiResponse.class);
 195         ResourceOperationStatus status =
 196                 new ResourceOperationStatus(serviceInfo.getNsiId(), response.getJobId(), serviceInfo.getServiceUuid());
 197         status.setResourceInstanceID(response.getNssiId());
 198
 199         updateDbStatus(status, restResponse.getStatus(), STARTED, NssmfAdapterUtil.getStatusDesc(actionType));
 200     }
 201 }