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 static java.lang.String.valueOf;
  34 import static org.onap.so.adapters.nssmf.enums.JobStatus.*;
  35 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.StatusDesc.*;
  36 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.marshal;
  37 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.unMarshal;
  38
  39 public abstract class ExternalNssmfManager extends BaseNssmfManager {
  40
  41     @Override
  42     protected String wrapAllocateReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException {
  43         return doWrapExtAllocateReqBody(nbiRequest);
  44     }
  45
  46     protected abstract String doWrapExtAllocateReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException;
  47
  48     @Override
  49     protected String wrapModifyReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException {
  50         return doWrapModifyReqBody(nbiRequest);
  51     }
  52
  53     protected abstract String doWrapModifyReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException;
  54
  55     @Override
  56     protected String wrapDeAllocateReqBody(DeAllocateNssi deAllocateNssi) throws ApplicationException {
  57         return doWrapDeAllocateReqBody(deAllocateNssi);
  58     }
  59
  60     protected abstract String doWrapDeAllocateReqBody(DeAllocateNssi deAllocateNssi) throws ApplicationException;
  61
  62     @Override
  63     protected void afterQueryJobStatus(ResourceOperationStatus status) {
  64         if (Integer.parseInt(status.getProgress()) == 100) {
  65
  66             ServiceInstance nssiInstance = new ServiceInstance();
  67             nssiInstance.setServiceInstanceId(serviceInfo.getNssiId());
  68             nssiInstance.setServiceInstanceName(serviceInfo.getNssiName());
  69             nssiInstance.setServiceType(serviceInfo.getSST());
  70
  71             nssiInstance.setOrchestrationStatus(initStatus);
  72             nssiInstance.setModelInvariantId(serviceInfo.getServiceInvariantUuid());
  73             nssiInstance.setModelVersionId(serviceInfo.getServiceUuid());
  74             nssiInstance.setServiceInstanceLocationId(serviceInfo.getPLMNIdList());
  75             nssiInstance.setEnvironmentContext(esrInfo.getNetworkType().getNetworkType());
  76             nssiInstance.setServiceRole("nssi");
  77
  78             restUtil.createServiceInstance(nssiInstance, serviceInfo);
  79         }
  80     }
  81
  82
  83
  84     @Override
  85     protected String wrapActDeActReqBody(ActDeActNssi actDeActNssi) throws ApplicationException {
  86         return marshal(actDeActNssi);
  87     }
  88
  89     protected RestResponse doQueryJobStatus(ResourceOperationStatus status) throws ApplicationException {
  90         return doResponseStatus(status);
  91     }
  92
  93     private RestResponse doResponseStatus(ResourceOperationStatus status) throws ApplicationException {
  94         RestResponse restResponse = sendRequest(null);
  95         JobStatusResponse jobStatusResponse = unMarshal(restResponse.getResponseContent(), JobStatusResponse.class);
  96
  97         ResponseDescriptor rspDesc = jobStatusResponse.getResponseDescriptor();
  98         rspDesc.setNssiId(status.getResourceInstanceID());
  99
 100         jobStatusResponse.setResponseDescriptor(rspDesc);
 101         restResponse.setResponseContent(marshal(jobStatusResponse));
 102         updateRequestDbJobStatus(rspDesc, status, restResponse);
 103         return restResponse;
 104     }
 105
 106     @Override
 107     protected String wrapReqBody(Object object) throws ApplicationException {
 108         return marshal(object);
 109     }
 110
 111     @Override
 112     protected RestResponse sendRequest(String content) throws ApplicationException {
 113         return sendExternalRequest(content);
 114     }
 115
 116     @Override
 117     protected String getApiVersion() {
 118         return "v1";
 119     }
 120
 121
 122     // external
 123     protected RestResponse sendExternalRequest(String content) throws ApplicationException {
 124         NssmfInfo nssmfInfo = restUtil.getNssmfHost(esrInfo);
 125         Header header = new BasicHeader("X-Auth-Token", restUtil.getToken(nssmfInfo));
 126         String nssmfUrl = nssmfInfo.getUrl() + this.nssmfUrl;
 127         return restUtil.send(nssmfUrl, this.httpMethod, content, header);
 128     }
 129
 130     private void updateRequestDbJobStatus(ResponseDescriptor rspDesc, ResourceOperationStatus status, RestResponse rsp)
 131             throws ApplicationException {
 132
 133         switch (fromString(rspDesc.getStatus())) {
 134             case STARTED:
 135                 updateDbStatus(status, rsp.getStatus(), STARTED, QUERY_JOB_STATUS_SUCCESS);
 136                 break;
 137             case PROCESSING:
 138                 updateDbStatus(status, rsp.getStatus(), PROCESSING, QUERY_JOB_STATUS_SUCCESS);
 139                 break;
 140             case FINISHED:
 141                 if (rspDesc.getProgress() == 100) {
 142                     updateDbStatus(status, rsp.getStatus(), FINISHED, QUERY_JOB_STATUS_SUCCESS);
 143                 }
 144                 break;
 145             case ERROR:
 146                 updateDbStatus(status, rsp.getStatus(), ERROR, QUERY_JOB_STATUS_FAILED);
 147                 throw new ApplicationException(500, QUERY_JOB_STATUS_FAILED);
 148         }
 149     }
 150
 151     protected void updateDbStatus(ResourceOperationStatus status, int rspStatus, JobStatus jobStatus,
 152             String description) {
 153         status.setErrorCode(valueOf(rspStatus));
 154         status.setStatus(jobStatus.toString());
 155         status.setStatusDescription(description);
 156         repository.save(status);
 157     }
 158
 159     @Override
 160     protected RestResponse doQuerySubnetCapability(String req) throws ApplicationException {
 161         RestResponse response = new RestResponse();
 162         response.setStatus(200);
 163         response.setResponseContent(null);
 164         return response;
 165     }
 166
 167     /**
 168      * after request, if response code is 2XX, continue handle, else return
 169      */
 170     @Override
 171     protected void afterRequest() throws ApplicationException {
 172         if (valueOf(restResponse.getStatus()).startsWith("2")) {
 173             doAfterRequest();
 174         }
 175     }
 176
 177
 178     protected void doAfterRequest() throws ApplicationException {
 179         //
 180         NssiResponse response = unMarshal(restResponse.getResponseContent(), NssiResponse.class);
 181         ResourceOperationStatus status =
 182                 new ResourceOperationStatus(serviceInfo.getNsiId(), response.getJobId(), serviceInfo.getServiceUuid());
 183         status.setResourceInstanceID(response.getNssiId());
 184
 185         updateDbStatus(status, restResponse.getStatus(), STARTED, NssmfAdapterUtil.getStatusDesc(actionType));
 186     }
 187 }