1 package org.openecomp.sdc.be.components.distribution.engine.rest;
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.slf4j.Logger;
15 import org.slf4j.LoggerFactory;
16 import org.springframework.stereotype.Component;
18 import java.util.Properties;
21 public class MSORestClient {
23 private static final Logger LOGGER = LoggerFactory.getLogger(MSORestClient.class);
24 private static final Gson gson = new Gson();
26 static final String DISTRIBUTIONS_RESOURCE_CONFIG_PARAM = "distributions";
28 private ExternalServiceConfig serviceConfig = ConfigurationManager.getConfigurationManager().getDistributionEngineConfiguration().getMsoConfig();
30 public MSORestClient() {
31 HttpClientConfig httpClientConfig = serviceConfig.getHttpClientConfig();
32 int numOfRetries = httpClientConfig.getNumOfRetries();
33 if ( numOfRetries > 0 ) {
34 httpClientConfig.setRetryHandler(RetryHandlers.getDefault(numOfRetries));
38 public HttpResponse<String> notifyDistributionComplete(String distributionId, DistributionStatusNotificationEnum distributionStatusEnum, String errReason) {
40 return doNotifyDistributionComplete(distributionId, distributionStatusEnum, errReason);
42 catch(HttpExecuteException e) {
43 LOGGER.debug("The request to mso failed with exception ", e);
44 return Responses.INTERNAL_SERVER_ERROR;
48 private HttpResponse<String> doNotifyDistributionComplete(String distributionId, DistributionStatusNotificationEnum distributionStatusEnum, String errReason) throws HttpExecuteException {
49 StringEntity entity = new StringEntity(gson.toJson(new DistributionStatusRequest(distributionStatusEnum.name(), errReason)), ContentType.APPLICATION_JSON);
50 HttpResponse<String> response = HttpRequest.patch(buildMsoDistributionUrl(distributionId), buildReqHeader(), entity, serviceConfig.getHttpClientConfig());
51 LOGGER.info("response from mso - status code: {}, status description: {}, response: {}, ", response.getStatusCode(), response.getDescription(), response.getResponse());
55 private Properties buildReqHeader() {
56 Properties properties = new Properties();
57 BasicAuthorization basicAuth = serviceConfig.getHttpClientConfig().getBasicAuthorization();
58 RestUtils.addBasicAuthHeader(properties, basicAuth.getUserName(), basicAuth.getPassword());
62 private String buildMsoDistributionUrl(String distributionId) {
63 String msoBaseUrl = serviceConfig.getHttpRequestConfig().getServerRootUrl();
64 String distributionsPath = serviceConfig.getHttpRequestConfig().getResourceNamespaces().get(DISTRIBUTIONS_RESOURCE_CONFIG_PARAM);
65 String distributionsApiPath = distributionsPath + URIUtil.SLASH + distributionId;
66 return msoBaseUrl + distributionsApiPath;