gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.sdc.be.components.distribution.engine.rest;
   2
   3 import com.google.common.annotations.VisibleForTesting;
   4 import com.google.gson.Gson;
   5 import org.apache.http.entity.ContentType;
   6 import org.apache.http.entity.StringEntity;
   7 import org.eclipse.jetty.util.URIUtil;
   8 import org.openecomp.sdc.be.components.distribution.engine.DistributionStatusNotificationEnum;
   9 import org.openecomp.sdc.be.config.ConfigurationManager;
  10 import org.openecomp.sdc.common.http.client.api.*;
  11 import org.openecomp.sdc.common.http.config.BasicAuthorization;
  12 import org.openecomp.sdc.common.http.config.ExternalServiceConfig;
  13 import org.openecomp.sdc.common.http.config.HttpClientConfig;
  14 import org.openecomp.sdc.common.log.wrappers.Logger;
  15 import org.springframework.stereotype.Component;
  16
  17 import java.util.Properties;
  18
  19 @Component
  20 public class MSORestClient {
  21
  22     private static final Logger logger = Logger.getLogger(MSORestClient.class.getName());
  23     private static final Gson gson = new Gson();
  24     @VisibleForTesting
  25     static final String DISTRIBUTIONS_RESOURCE_CONFIG_PARAM = "distributions";
  26
  27     private ExternalServiceConfig serviceConfig = ConfigurationManager.getConfigurationManager().getDistributionEngineConfiguration().getMsoConfig();
  28
  29     public MSORestClient() {
  30         HttpClientConfig httpClientConfig = serviceConfig.getHttpClientConfig();
  31         int numOfRetries = httpClientConfig.getNumOfRetries();
  32         if ( numOfRetries > 0 ) {
  33             httpClientConfig.setRetryHandler(RetryHandlers.getDefault(numOfRetries));
  34         }
  35     }
  36
  37     public HttpResponse<String> notifyDistributionComplete(String distributionId, DistributionStatusNotificationEnum distributionStatusEnum, String errReason) {
  38         try {
  39             return doNotifyDistributionComplete(distributionId, distributionStatusEnum, errReason);
  40         }
  41         catch(HttpExecuteException e) {
  42             logger.debug("The request to mso failed with exception ", e);
  43             return Responses.INTERNAL_SERVER_ERROR;
  44         }
  45     }
  46
  47     private HttpResponse<String> doNotifyDistributionComplete(String distributionId, DistributionStatusNotificationEnum distributionStatusEnum, String errReason) throws HttpExecuteException {
  48         StringEntity entity = new StringEntity(gson.toJson(new DistributionStatusRequest(distributionStatusEnum.name(), errReason)), ContentType.APPLICATION_JSON);
  49         HttpResponse<String> response = HttpRequest.patch(buildMsoDistributionUrl(distributionId), buildReqHeader(), entity, serviceConfig.getHttpClientConfig());
  50         logger.info("response from mso - status code: {}, status description: {}, response: {}, ", response.getStatusCode(), response.getDescription(), response.getResponse());
  51         return response;
  52     }
  53
  54     private Properties buildReqHeader() {
  55         Properties properties = new Properties();
  56         BasicAuthorization basicAuth = serviceConfig.getHttpClientConfig().getBasicAuthorization();
  57         RestUtils.addBasicAuthHeader(properties, basicAuth.getUserName(), basicAuth.getPassword());
  58         return properties;
  59     }
  60
  61     private String buildMsoDistributionUrl(String distributionId) {
  62         String msoBaseUrl = serviceConfig.getHttpRequestConfig().getServerRootUrl();
  63         String distributionsPath = serviceConfig.getHttpRequestConfig().getResourceNamespaces().get(DISTRIBUTIONS_RESOURCE_CONFIG_PARAM);
  64         String distributionsApiPath = distributionsPath + URIUtil.SLASH + distributionId;
  65         return msoBaseUrl + distributionsApiPath;
  66     }
  67
  68 }