Monitoring API - write framework adapters

Change-Id: Iaba9c4ef6022d01c1f572055316700a3a4dfa8f2
Issue-ID: DCAEGEN2-1589
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>

2 files changed, 115 insertions, 0 deletions

diff --git a/standardization/moher-api/server-adapters/spring-webflux/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/adapters/springwebflux/HealthController.java b/standardization/moher-api/server-adapters/spring-webflux/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/adapters/springwebflux/HealthController.java
new file mode 100644
index 00000000..1f9eb4b0
--- /dev/null
+++ b/standardization/moher-api/server-adapters/spring-webflux/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/adapters/springwebflux/HealthController.java
@@ -0,0 +1,72 @@
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+
+package org.onap.dcaegen2.services.sdk.standardization.moher.adapters.springwebflux;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import org.onap.dcaegen2.services.sdk.standardization.moher.health.api.AliveMessage;
+import org.onap.dcaegen2.services.sdk.standardization.moher.health.api.GsonAdaptersHealth;
+import org.onap.dcaegen2.services.sdk.standardization.moher.health.api.Health;
+import org.onap.dcaegen2.services.sdk.standardization.moher.health.api.HealthProvider;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping(value = "/health", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+public class HealthController {
+    private final Gson gson;
+    private final HealthProvider healthProvider;
+
+    public static HealthController create(HealthProvider healthProvider) {
+        GsonBuilder gson = new GsonBuilder();
+        gson.registerTypeAdapterFactory(new GsonAdaptersHealth());
+        return new HealthController(gson.create(), healthProvider);
+    }
+
+    public HealthController(Gson gson, HealthProvider healthProvider) {
+        this.gson = gson;
+        this.healthProvider = healthProvider;
+    }
+
+    @GetMapping("/ready")
+    public Mono<ResponseEntity<String>> readinessCheck() {
+        return healthProvider.currentHealth()
+                .map(health -> responseStatusForHealth(health)
+                        .contentType(MediaType.APPLICATION_JSON_UTF8)
+                        .body(gson.toJson(health)));
+    }
+
+    @GetMapping("/alive")
+    public Mono<String> livenessCheck() {
+        return Mono.just(AliveMessage.ALIVE_MESSAGE_JSON);
+    }
+
+    private ResponseEntity.BodyBuilder responseStatusForHealth(Health health) {
+        return health.healthy()
+                ? ResponseEntity.ok()
+                : ResponseEntity.status(HttpStatus.SERVICE_UNAVAILABLE);
+    }
+}
diff --git a/standardization/moher-api/server-adapters/spring-webflux/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/adapters/springwebflux/MetricsController.java b/standardization/moher-api/server-adapters/spring-webflux/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/adapters/springwebflux/MetricsController.java
new file mode 100644
index 00000000..4ce4fd12
--- /dev/null
+++ b/standardization/moher-api/server-adapters/spring-webflux/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/adapters/springwebflux/MetricsController.java
@@ -0,0 +1,43 @@
+/*
+ * ============LICENSE_START====================================
+ * DCAEGEN2-SERVICES-SDK
+ * =========================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * =========================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=====================================
+ */
+
+package org.onap.dcaegen2.services.sdk.standardization.moher.adapters.springwebflux;
+
+import org.onap.dcaegen2.services.sdk.standardization.moher.metrics.api.Metrics;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping(value = "/metrics", produces = MediaType.TEXT_PLAIN_VALUE)
+public class MetricsController {
+    private final Metrics metrics;
+
+    public MetricsController(Metrics metrics) {
+        this.metrics = metrics;
+    }
+
+    @GetMapping
+    public Mono<String> prometheusMetrics() {
+        return metrics.collect();
+    }
+}