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 com.fasterxml.jackson.core.JsonProcessingException;
  24 import com.fasterxml.jackson.core.type.TypeReference;
  25 import com.fasterxml.jackson.databind.ObjectMapper;
  26 import org.apache.http.Header;
  27 import org.apache.http.HttpStatus;
  28 import org.apache.http.message.BasicHeader;
  29 import org.onap.aai.domain.yang.ServiceInstance;
  30 import org.onap.so.adapters.nssmf.entity.NssmfInfo;
  31 import org.onap.so.adapters.nssmf.entity.RestResponse;
  32 import org.onap.so.adapters.nssmf.enums.ActionType;
  33 import org.onap.so.adapters.nssmf.enums.JobStatus;
  34 import org.onap.so.adapters.nssmf.exceptions.ApplicationException;
  35 import org.onap.so.adapters.nssmf.util.NssmfAdapterUtil;
  36 import org.onap.so.beans.nsmf.*;
  37 import org.onap.so.db.request.beans.ResourceOperationStatus;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40 import java.io.InputStream;
  41 import java.util.HashMap;
  42 import java.util.List;
  43 import java.util.Map;
  44 import static java.lang.String.valueOf;
  45 import static org.onap.so.adapters.nssmf.enums.JobStatus.*;
  46 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.StatusDesc.QUERY_JOB_STATUS_FAILED;
  47 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.StatusDesc.QUERY_JOB_STATUS_SUCCESS;
  48 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.marshal;
  49 import static org.onap.so.adapters.nssmf.util.NssmfAdapterUtil.unMarshal;
  50
  51 public abstract class ExternalNssmfManager extends BaseNssmfManager {
  52
  53     private static final Logger logger = LoggerFactory.getLogger(ExternalNssmfManager.class);
  54
  55     @Override
  56     protected String wrapAllocateReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException {
  57         return doWrapExtAllocateReqBody(nbiRequest);
  58     }
  59
  60     protected abstract String doWrapExtAllocateReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException;
  61
  62     @Override
  63     protected String wrapModifyReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException {
  64         return doWrapModifyReqBody(nbiRequest);
  65     }
  66
  67     protected abstract String doWrapModifyReqBody(NssmfAdapterNBIRequest nbiRequest) throws ApplicationException;
  68
  69     @Override
  70     protected String wrapDeAllocateReqBody(DeAllocateNssi deAllocateNssi) throws ApplicationException {
  71         return doWrapDeAllocateReqBody(deAllocateNssi);
  72     }
  73
  74     protected abstract String doWrapDeAllocateReqBody(DeAllocateNssi deAllocateNssi) throws ApplicationException;
  75
  76     @Override
  77     protected void afterQueryJobStatus(ResourceOperationStatus status) {
  78         logger.info("afterQueryJobStatus = " + status);
  79         if (Integer.parseInt(status.getProgress()) == 100) {
  80             logger.info("after query finished = " + status);
  81             ActionType jobOperType = ActionType.valueOf(status.getOperType());
  82
  83             if (ActionType.ALLOCATE.equals(jobOperType)) {
  84                 ServiceInstance nssiInstance = restUtil.getServiceInstance(serviceInfo);
  85                 if (nssiInstance == null) {
  86                     nssiInstance = new ServiceInstance();
  87                 }
  88
  89                 nssiInstance.setServiceInstanceId(serviceInfo.getNssiId());
  90                 nssiInstance.setServiceInstanceName(serviceInfo.getNssiName());
  91                 nssiInstance.setServiceType(serviceInfo.getSST());
  92
  93                 nssiInstance.setOrchestrationStatus(initStatus);
  94                 nssiInstance.setModelInvariantId(serviceInfo.getServiceInvariantUuid());
  95                 nssiInstance.setModelVersionId(serviceInfo.getServiceUuid());
  96                 nssiInstance.setServiceInstanceLocationId(serviceInfo.getPLMNIdList());
  97                 nssiInstance.setEnvironmentContext(esrInfo.getNetworkType().getNetworkType());
  98                 nssiInstance.setServiceRole("nssi");
  99
 100                 restUtil.createServiceInstance(nssiInstance, serviceInfo);
 101             } else if (ActionType.DEALLOCATE.equals(jobOperType)) {
 102                 // TODO
 103                 restUtil.deleteServiceInstance(serviceInfo);
 104             }
 105         }
 106     }
 107
 108     @Override
 109     protected String wrapActDeActReqBody(ActDeActNssi actDeActNssi) throws ApplicationException {
 110         return marshal(actDeActNssi);
 111     }
 112
 113     @Override
 114     protected RestResponse doQueryJobStatus(ResourceOperationStatus status) throws ApplicationException {
 115         return doResponseStatus(status);
 116     }
 117
 118     private RestResponse doResponseStatus(ResourceOperationStatus status) throws ApplicationException {
 119         RestResponse restResponse = sendRequest(null);
 120         JobStatusResponse jobStatusResponse = unMarshal(restResponse.getResponseContent(), JobStatusResponse.class);
 121
 122         ResponseDescriptor rspDesc = jobStatusResponse.getResponseDescriptor();
 123
 124         logger.info("status = {}", status);
 125         rspDesc.setNssiId(status.getResourceInstanceID());
 126
 127         jobStatusResponse.setResponseDescriptor(rspDesc);
 128         restResponse.setResponseContent(marshal(jobStatusResponse));
 129         updateRequestDbJobStatus(rspDesc, status, restResponse);
 130         return restResponse;
 131     }
 132
 133     @Override
 134     protected String wrapReqBody(Object object) throws ApplicationException {
 135         return marshal(object);
 136     }
 137
 138     @Override
 139     protected RestResponse sendRequest(String content) throws ApplicationException {
 140         return sendExternalRequest(content);
 141     }
 142
 143     @Override
 144     protected String getApiVersion() {
 145         return "v1";
 146     }
 147
 148
 149     // external
 150     protected RestResponse sendExternalRequest(String content) throws ApplicationException {
 151         NssmfInfo nssmfInfo = restUtil.getNssmfHost(esrInfo);
 152         Header header = new BasicHeader("X-Auth-Token", restUtil.getToken(nssmfInfo));
 153         String nssmfUrl = nssmfInfo.getUrl() + this.nssmfUrl;
 154         return restUtil.send(nssmfUrl, this.httpMethod, content, header);
 155     }
 156
 157     protected void updateRequestDbJobStatus(ResponseDescriptor rspDesc, ResourceOperationStatus status,
 158             RestResponse rsp) throws ApplicationException {
 159         status.setProgress(Integer.toString(rspDesc.getProgress()));
 160         switch (fromString(rspDesc.getStatus())) {
 161             case STARTED:
 162                 updateDbStatus(status, rsp.getStatus(), STARTED, QUERY_JOB_STATUS_SUCCESS);
 163                 break;
 164             case PROCESSING:
 165                 updateDbStatus(status, rsp.getStatus(), PROCESSING, QUERY_JOB_STATUS_SUCCESS);
 166                 break;
 167             case FINISHED:
 168                 if (rspDesc.getProgress() == 100) {
 169                     updateDbStatus(status, rsp.getStatus(), FINISHED, QUERY_JOB_STATUS_SUCCESS);
 170                 }
 171                 break;
 172             case ERROR:
 173                 updateDbStatus(status, rsp.getStatus(), ERROR, QUERY_JOB_STATUS_FAILED);
 174                 throw new ApplicationException(500, QUERY_JOB_STATUS_FAILED);
 175             default:
 176                 throw new ApplicationException(500, QUERY_JOB_STATUS_FAILED);
 177         }
 178     }
 179
 180     protected void updateDbStatus(ResourceOperationStatus status, int rspStatus, JobStatus jobStatus,
 181             String description) {
 182         status.setErrorCode(valueOf(rspStatus));
 183         status.setStatus(jobStatus.toString());
 184         status.setStatusDescription(description);
 185         repository.save(status);
 186     }
 187
 188     @Override
 189     protected RestResponse doQuerySubnetCapability(QuerySubnetCapability req) throws ApplicationException {
 190
 191         ObjectMapper oMapper = new ObjectMapper();
 192         InputStream inputStream = TypeReference.class.getResourceAsStream("/subnetCapability.json");
 193         Map subnetCapability = new HashMap<>();
 194         try {
 195             subnetCapability = oMapper.readValue(inputStream, Map.class);
 196         } catch (Exception e) {
 197             logger.debug("Exception while reading subnet capability value from json", e);
 198         }
 199         Map<String, Object> responseMap = new HashMap<>();
 200         List<String> subnetTypes = req.getSubnetTypes();
 201         for (String value : subnetTypes) {
 202             if (subnetCapability.containsKey(value)) {
 203                 responseMap.put(value, subnetCapability.get(value));
 204             }
 205         }
 206         String response = null;
 207         try {
 208             response = oMapper.writeValueAsString(responseMap);
 209         } catch (JsonProcessingException e) {
 210             logger.debug("Exception while converting subnet capability object to String {}", e.getMessage());
 211         }
 212
 213         RestResponse rsp = new RestResponse();
 214         rsp.setStatus(HttpStatus.SC_OK);
 215         rsp.setResponseContent(response);
 216         return rsp;
 217     }
 218
 219     /**
 220      * after request, if response code is 2XX, continue handle, else return
 221      */
 222     @Override
 223     protected void afterRequest() throws ApplicationException {
 224         if (valueOf(restResponse.getStatus()).startsWith("2")) {
 225             doAfterRequest();
 226         }
 227     }
 228
 229
 230     protected void doAfterRequest() throws ApplicationException {
 231         //
 232         NssiResponse response = unMarshal(restResponse.getResponseContent(), NssiResponse.class);
 233         ResourceOperationStatus status =
 234                 new ResourceOperationStatus(serviceInfo.getNsiId(), response.getJobId(), serviceInfo.getServiceUuid());
 235         status.setResourceInstanceID(response.getNssiId());
 236         status.setOperType(actionType.toString());
 237         status.setProgress("0");
 238
 239         response.setStatus(STARTED.toString());
 240         restResponse.setResponseContent(marshal(response));
 241         updateDbStatus(status, restResponse.getStatus(), STARTED, NssmfAdapterUtil.getStatusDesc(actionType));
 242     }
 243 }