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