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;
33 import com.att.eelf.configuration.EELFLogger;
34 import com.google.common.collect.ImmutableMap;
35 import io.joshworks.restclient.http.HttpResponse;
36 import io.vavr.control.Try;
37 import java.io.IOException;
38 import java.io.InputStream;
39 import java.nio.file.Files;
40 import java.nio.file.Path;
41 import java.nio.file.StandardCopyOption;
42 import java.util.Collections;
44 import java.util.UUID;
45 import javax.ws.rs.ProcessingException;
46 import javax.ws.rs.client.ResponseProcessingException;
47 import org.onap.portalsdk.core.util.SystemProperties;
48 import org.onap.vid.aai.ExceptionWithRequestInfo;
49 import org.onap.vid.aai.HttpResponseWithRequestInfo;
50 import org.onap.vid.asdc.AsdcCatalogException;
51 import org.onap.vid.asdc.AsdcClient;
52 import org.onap.vid.asdc.beans.Service;
53 import org.onap.vid.client.SyncRestClientInterface;
54 import org.onap.vid.model.ModelConstants;
55 import org.onap.vid.properties.VidProperties;
56 import org.onap.vid.utils.Logging;
57 import org.springframework.http.HttpMethod;
59 public class SdcRestClient implements AsdcClient {
61 private String baseUrl;
64 private static final EELFLogger LOGGER = Logging.getRequestsLogger("sdc");
66 private SyncRestClientInterface syncRestClient;
67 private Logging loggingService;
70 public SdcRestClient(String baseUrl, String auth, SyncRestClientInterface client, Logging loggingService) {
71 this.syncRestClient = client;
73 this.baseUrl = baseUrl;
74 this.path = VidProperties.getPropertyWithDefault(ModelConstants.ASDC_SVC_API_PATH, ModelConstants.DEFAULT_ASDC_SVC_API_PATH);
75 this.loggingService = loggingService;
80 public Service getService(UUID uuid) throws AsdcCatalogException {
81 String finalUrl = String.format(METADATA_URL_TEMPLATE, baseUrl, path, uuid);
82 loggingService.logRequest(LOGGER, HttpMethod.GET, finalUrl);
85 .of(() -> syncRestClient.get(finalUrl, prepareHeaders(auth, APPLICATION_JSON), Collections.emptyMap(), Service.class))
86 .getOrElseThrow(AsdcCatalogException::new)
92 public Path getServiceToscaModel(UUID uuid) throws AsdcCatalogException {
94 HttpResponseWithRequestInfo<InputStream> responseWithRequestInfo = getServiceInputStream(uuid, false);
96 if (responseWithRequestInfo.getResponse().getStatus()>399) {
97 loggingService.logRequest(LOGGER, HttpMethod.GET,
98 responseWithRequestInfo.getRequestUrl(), responseWithRequestInfo.getResponse());
100 String body = extractRawAsString(responseWithRequestInfo.getResponse());
101 throw new AsdcCatalogException(String.format("Http bad status code: %s, body: %s",
102 responseWithRequestInfo.getResponse().getStatus(),
106 final InputStream csarInputStream = responseWithRequestInfo.getResponse().getBody();
107 Path toscaFilePath = createTmpFile(csarInputStream);
108 LOGGER.debug("Received {} {} . Tosca file was saved at: {}",
109 responseWithRequestInfo.getRequestHttpMethod().name(),
110 responseWithRequestInfo.getRequestUrl(),
111 toscaFilePath.toAbsolutePath());
112 return toscaFilePath;
113 } catch (ResponseProcessingException e) {
114 //Couldn't convert response to Java type
115 throw new AsdcCatalogException("ASDC response could not be processed", e);
116 } catch (ProcessingException e) {
117 //IO problems during request
118 throw new AsdcCatalogException("Failed to get a response from ASDC service. Cause: " + e.getMessage(), e);
119 } catch (RuntimeException e) {
120 throw new AsdcCatalogException(e);
125 public HttpResponseWithRequestInfo<InputStream> getServiceInputStream(UUID serviceUuid, boolean warpException) {
126 String finalUrl = String.format(TOSCA_MODEL_URL_TEMPLATE, baseUrl, path, serviceUuid);
127 loggingService.logRequest(LOGGER, HttpMethod.GET, finalUrl);
129 HttpResponse<InputStream> httpResponse = syncRestClient.getStream(finalUrl, prepareHeaders(auth, APPLICATION_OCTET_STREAM), Collections.emptyMap());
130 return new HttpResponseWithRequestInfo<>(httpResponse, finalUrl, HttpMethod.GET);
132 catch (RuntimeException exception) {
133 throw warpException ? new ExceptionWithRequestInfo(HttpMethod.GET, finalUrl, exception) : exception;
139 public HttpResponse<String> checkSDCConnectivity() {
140 String finalUrl = baseUrl + URIS.HEALTH_CHECK_ENDPOINT;
142 return syncRestClient
143 .get(finalUrl, prepareHeaders(auth, APPLICATION_JSON), Collections.emptyMap(), String.class);
147 public String getBaseUrl() {
151 private Map<String, String> prepareHeaders(String auth, String contentType) {
152 return ImmutableMap.of(
153 X_ECOMP_INSTANCE_ID, SystemProperties.getProperty(APP_DISPLAY_NAME),
155 CONTENT_TYPE, contentType
159 private Path createTmpFile(InputStream csarInputStream) throws AsdcCatalogException {
161 .of(() -> tryToCreateTmpFile(csarInputStream))
162 .getOrElseThrow(throwable -> new AsdcCatalogException("Caught IOException while creating CSAR", throwable));
165 private Path tryToCreateTmpFile(InputStream csarInputStream) throws IOException {
166 Path csarFile = Files.createTempFile("csar", ".zip");
167 Files.copy(csarInputStream, csarFile, StandardCopyOption.REPLACE_EXISTING);
169 LOGGER.debug("Tosca file was saved at: {} ", csarFile.toAbsolutePath());