1 files changed, 143 insertions, 0 deletions
diff --git a/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/client/MulticloudClient.java b/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/client/MulticloudClient.java
new file mode 100644
index 0000000..762f192
--- /dev/null
+++ b/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/client/MulticloudClient.java
@@ -0,0 +1,143 @@
+package org.onap.so.adapters.cnf.client;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.onap.so.adapters.cnf.MulticloudConfiguration;
+import org.onap.so.adapters.cnf.model.healthcheck.K8sRbInstanceHealthCheck;
+import org.onap.so.adapters.cnf.model.healthcheck.K8sRbInstanceHealthCheckSimple;
+import org.onap.so.adapters.cnf.model.statuscheck.K8sRbInstanceStatus;
+import org.onap.so.client.exception.BadResponseException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.springframework.http.HttpMethod.DELETE;
+import static org.springframework.http.HttpMethod.GET;
+import static org.springframework.http.HttpMethod.POST;
+
+@Component
+public class MulticloudClient {
+
+    private static final Logger log = LoggerFactory.getLogger(MulticloudClient.class);
+
+    private final RestTemplate restTemplate;
+    private final MulticloudConfiguration multicloudConfiguration;
+    private final ObjectMapper objectMapper;
+
+    public MulticloudClient(RestTemplate restTemplate, MulticloudConfiguration multicloudConfiguration) {
+        this.restTemplate = restTemplate;
+        this.multicloudConfiguration = multicloudConfiguration;
+        this.objectMapper = new ObjectMapper();
+    }
+
+    public K8sRbInstanceStatus getInstanceStatus(String instanceId) throws BadResponseException {
+        MulticloudApiUrl multicloudApiUrl = new MulticloudApiUrl(multicloudConfiguration);
+        multicloudApiUrl.setInstanceId(instanceId);
+        String endpoint = multicloudApiUrl.apiUrl() + "/status";
+        ResponseEntity<String> result = restTemplate.exchange(endpoint, GET, getHttpEntity(), String.class);
+        checkResponseStatusCode(result);
+        log.info("getInstanceStatus response status: {}", result.getStatusCode());
+        String body = result.getBody();
+        log.debug("getInstanceStatus response body: {}", body);
+
+        try {
+            return objectMapper.readValue(body, K8sRbInstanceStatus.class);
+        } catch (JsonProcessingException e) {
+            throw new IllegalStateException(e);
+        }
+    }
+
+    public K8sRbInstanceHealthCheckSimple startInstanceHealthCheck(String instanceId) throws BadResponseException {
+        MulticloudApiUrl multicloudApiUrl = new MulticloudApiUrl(multicloudConfiguration);
+        multicloudApiUrl.setInstanceId(instanceId);
+        String endpoint = multicloudApiUrl.apiUrl() + "/healthcheck";
+        ResponseEntity<String> result = restTemplate.exchange(endpoint, POST, getHttpEntity(), String.class);
+        checkResponseStatusCode(result);
+        log.info("startInstanceHealthCheck response status: {}", result.getStatusCode());
+        String body = result.getBody();
+        log.debug("startInstanceHealthCheck response body: {}", body);
+
+        try {
+            return objectMapper.readValue(body, K8sRbInstanceHealthCheckSimple.class);
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public K8sRbInstanceHealthCheck getInstanceHealthCheck(String instanceId, String healthCheckInstance) throws BadResponseException {
+        MulticloudApiUrl multicloudApiUrl = new MulticloudApiUrl(multicloudConfiguration);
+        multicloudApiUrl.setInstanceId(instanceId);
+        String endpoint = multicloudApiUrl.apiUrl() + "/healthcheck/" + healthCheckInstance;
+        ResponseEntity<String> result = restTemplate.exchange(endpoint, GET, getHttpEntity(), String.class);
+        checkResponseStatusCode(result);
+        log.info("getInstanceHealthCheck response status: {}", result.getStatusCode());
+        String body = result.getBody();
+        log.debug("getInstanceHealthCheck response body: {}", body);
+
+        try {
+            return objectMapper.readValue(body, K8sRbInstanceHealthCheck.class);
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public void deleteInstanceHealthCheck(String instanceId, String healthCheckInstance) throws BadResponseException {
+        MulticloudApiUrl multicloudApiUrl = new MulticloudApiUrl(multicloudConfiguration);
+        multicloudApiUrl.setInstanceId(instanceId);
+        String endpoint = multicloudApiUrl.apiUrl() + "/healthcheck/" + healthCheckInstance;
+        ResponseEntity<String> result = restTemplate.exchange(endpoint, DELETE, getHttpEntity(), String.class);
+        checkResponseStatusCode(result);
+        log.info("deleteInstanceHealthCheck response status: {}", result.getStatusCode());
+        String body = result.getBody();
+        log.debug("deleteInstanceHealthCheck response body: {}", body);
+
+        if (!result.getStatusCode().is2xxSuccessful()) {
+            throw new IllegalStateException("Delete response different than 2xx:" + result.getStatusCode());
+        }
+    }
+
+    private HttpEntity<?> getHttpEntity() {
+        HttpHeaders headers = new HttpHeaders();
+        List<MediaType> acceptableMediaTypes = new ArrayList<>();
+        acceptableMediaTypes.add(MediaType.APPLICATION_JSON);
+        headers.setAccept(acceptableMediaTypes);
+        headers.setContentType(MediaType.APPLICATION_JSON);
+
+        return new HttpEntity<>(headers);
+    }
+
+    private void checkResponseStatusCode(ResponseEntity<String> result) throws BadResponseException {
+        HttpStatus statusCode = result.getStatusCode();
+        if (!statusCode.is2xxSuccessful()) {
+            throw new BadResponseException("Multicloud response status error", String.valueOf(statusCode.value()));
+        }
+    }
+
+    private class MulticloudApiUrl {
+
+        private String instanceId;
+        private final MulticloudConfiguration multicloudConfiguration;
+
+        MulticloudApiUrl(MulticloudConfiguration multicloudConfiguration1) {
+            this.multicloudConfiguration = multicloudConfiguration1;
+        }
+
+        String apiUrl() {
+            String instanceUri = multicloudConfiguration.getMulticloudUrl() + "/v1/instance/";
+            return instanceId.equals("") ? instanceUri : instanceUri + instanceId;
+        }
+
+        void setInstanceId(String instanceId) {
+            this.instanceId = instanceId;
+        }
+    }
+}