2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018 - 2019 Nokia. All rights reserved.
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.vid.asdc.rest;
23 import static javax.ws.rs.core.MediaType.APPLICATION_JSON;
24 import static javax.ws.rs.core.MediaType.APPLICATION_OCTET_STREAM;
25 import static org.onap.portalsdk.core.util.SystemProperties.APP_DISPLAY_NAME;
26 import static org.onap.vid.asdc.AsdcClient.URIS.METADATA_URL_TEMPLATE;
27 import static org.onap.vid.asdc.AsdcClient.URIS.TOSCA_MODEL_URL_TEMPLATE;
28 import static org.onap.vid.client.SyncRestClientInterface.HEADERS.AUTHORIZATION;
29 import static org.onap.vid.client.SyncRestClientInterface.HEADERS.CONTENT_TYPE;
30 import static org.onap.vid.client.SyncRestClientInterface.HEADERS.X_ECOMP_INSTANCE_ID;
31 import static org.onap.vid.client.UnirestPatchKt.extractRawAsString;
32 import static org.onap.vid.utils.Logging.REQUEST_ID_HEADER_KEY;
34 import com.att.eelf.configuration.EELFLogger;
35 import com.google.common.collect.ImmutableMap;
36 import io.joshworks.restclient.http.HttpResponse;
37 import io.vavr.control.Try;
38 import java.io.IOException;
39 import java.io.InputStream;
40 import java.nio.file.Files;
41 import java.nio.file.Path;
42 import java.nio.file.StandardCopyOption;
43 import java.util.Collections;
45 import java.util.UUID;
46 import javax.ws.rs.ProcessingException;
47 import javax.ws.rs.client.ResponseProcessingException;
48 import org.onap.portalsdk.core.util.SystemProperties;
49 import org.onap.vid.aai.ExceptionWithRequestInfo;
50 import org.onap.vid.aai.HttpResponseWithRequestInfo;
51 import org.onap.vid.asdc.AsdcCatalogException;
52 import org.onap.vid.asdc.AsdcClient;
53 import org.onap.vid.asdc.beans.Service;
54 import org.onap.vid.client.SyncRestClientInterface;
55 import org.onap.vid.model.ModelConstants;
56 import org.onap.vid.properties.VidProperties;
57 import org.onap.vid.utils.Logging;
58 import org.springframework.http.HttpMethod;
60 public class SdcRestClient implements AsdcClient {
62 private String baseUrl;
65 private static final EELFLogger LOGGER = Logging.getRequestsLogger("sdc");
67 private SyncRestClientInterface syncRestClient;
68 private Logging loggingService;
71 public SdcRestClient(String baseUrl, String auth, SyncRestClientInterface client, Logging loggingService) {
72 this.syncRestClient = client;
74 this.baseUrl = baseUrl;
75 this.path = VidProperties.getPropertyWithDefault(ModelConstants.ASDC_SVC_API_PATH, ModelConstants.DEFAULT_ASDC_SVC_API_PATH);
76 this.loggingService = loggingService;
81 public Service getService(UUID uuid) throws AsdcCatalogException {
82 String finalUrl = String.format(METADATA_URL_TEMPLATE, baseUrl, path, uuid);
83 loggingService.logRequest(LOGGER, HttpMethod.GET, finalUrl);
86 .of(() -> syncRestClient.get(finalUrl, prepareHeaders(auth, APPLICATION_JSON), Collections.emptyMap(), Service.class))
87 .getOrElseThrow(AsdcCatalogException::new)
93 public Path getServiceToscaModel(UUID uuid) throws AsdcCatalogException {
95 HttpResponseWithRequestInfo<InputStream> responseWithRequestInfo = getServiceInputStream(uuid, false);
97 if (responseWithRequestInfo.getResponse().getStatus()>399) {
98 loggingService.logRequest(LOGGER, HttpMethod.GET,
99 responseWithRequestInfo.getRequestUrl(), responseWithRequestInfo.getResponse());
101 String body = extractRawAsString(responseWithRequestInfo.getResponse());
102 throw new AsdcCatalogException(String.format("Http bad status code: %s, body: %s",
103 responseWithRequestInfo.getResponse().getStatus(),
107 final InputStream csarInputStream = responseWithRequestInfo.getResponse().getBody();
108 Path toscaFilePath = createTmpFile(csarInputStream);
109 LOGGER.debug("Received {} {} . Tosca file was saved at: {}",
110 responseWithRequestInfo.getRequestHttpMethod().name(),
111 responseWithRequestInfo.getRequestUrl(),
112 toscaFilePath.toAbsolutePath());
113 return toscaFilePath;
114 } catch (ResponseProcessingException e) {
115 //Couldn't convert response to Java type
116 throw new AsdcCatalogException("ASDC response could not be processed", e);
117 } catch (ProcessingException e) {
118 //IO problems during request
119 throw new AsdcCatalogException("Failed to get a response from ASDC service. Cause: " + e.getMessage(), e);
120 } catch (RuntimeException e) {
121 throw new AsdcCatalogException(e);
126 public HttpResponseWithRequestInfo<InputStream> getServiceInputStream(UUID serviceUuid, boolean warpException) {
127 String finalUrl = String.format(TOSCA_MODEL_URL_TEMPLATE, baseUrl, path, serviceUuid);
128 loggingService.logRequest(LOGGER, HttpMethod.GET, finalUrl);
130 HttpResponse<InputStream> httpResponse = syncRestClient.getStream(finalUrl, prepareHeaders(auth, APPLICATION_OCTET_STREAM), Collections.emptyMap());
131 return new HttpResponseWithRequestInfo<>(httpResponse, finalUrl, HttpMethod.GET);
133 catch (RuntimeException exception) {
134 throw warpException ? new ExceptionWithRequestInfo(HttpMethod.GET, finalUrl, exception) : exception;
140 public HttpResponse<String> checkSDCConnectivity() {
141 String finalUrl = baseUrl + URIS.HEALTH_CHECK_ENDPOINT;
143 return syncRestClient
144 .get(finalUrl, prepareHeaders(auth, APPLICATION_JSON), Collections.emptyMap(), String.class);
148 public String getBaseUrl() {
152 private Map<String, String> prepareHeaders(String auth, String contentType) {
153 return ImmutableMap.of(
154 X_ECOMP_INSTANCE_ID, SystemProperties.getProperty(APP_DISPLAY_NAME),
156 REQUEST_ID_HEADER_KEY, Logging.extractOrGenerateRequestId(),
157 CONTENT_TYPE, contentType
161 private Path createTmpFile(InputStream csarInputStream) throws AsdcCatalogException {
163 .of(() -> tryToCreateTmpFile(csarInputStream))
164 .getOrElseThrow(throwable -> new AsdcCatalogException("Caught IOException while creating CSAR", throwable));
167 private Path tryToCreateTmpFile(InputStream csarInputStream) throws IOException {
168 Path csarFile = Files.createTempFile("csar", ".zip");
169 Files.copy(csarInputStream, csarFile, StandardCopyOption.REPLACE_EXISTING);
171 LOGGER.debug("Tosca file was saved at: {} ", csarFile.toAbsolutePath());