Use generated PAP interface for Swagger

[policy/pap.git] / main / src / main / java / org / onap / policy / pap / main / rest / StatisticsRestControllerV1.java

diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/StatisticsRestControllerV1.java b/main/src/main/java/org/onap/policy/pap/main/rest/StatisticsRestControllerV1.java
index e864586..03ac3ba 100644 (file)
--- a/main/src/main/java/org/onap/policy/pap/main/rest/StatisticsRestControllerV1.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/StatisticsRestControllerV1.java
@@ -1,7 +1,8 @@
 /*-
  * ============LICENSE_START=======================================================
- *  Copyright (C) 2019 Nordix Foundation.
- *  Modifications Copyright (C) 2019 AT&T Intellectual Property.
+ *  Copyright (C) 2019-2023 Nordix Foundation.
+ *  Modifications Copyright (C) 2019, 2021 AT&T Intellectual Property.
+ *  Modifications Copyright (C) 2021-2022 Bell Canada. 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.
@@ -21,30 +22,120 @@
 
 package org.onap.policy.pap.main.rest;
 
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiResponse;
-import io.swagger.annotations.ApiResponses;
-import io.swagger.annotations.Authorization;
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.core.Response;
+import java.time.Instant;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import lombok.RequiredArgsConstructor;
+import org.onap.policy.models.pdp.concepts.PdpStatistics;
+import org.onap.policy.pap.main.service.PdpStatisticsService;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RestController;
 
 /**
  * Class to provide REST endpoints for PAP component statistics.
  *
  * @author Ram Krishna Verma (ram.krishna.verma@est.tech)
  */
-public class StatisticsRestControllerV1 extends PapRestControllerV1 {
-
-    @GET
-    @Path("statistics")
-    @ApiOperation(value = "Fetch current statistics",
-                    notes = "Returns current statistics of the Policy Administration component",
-                    response = StatisticsReport.class, authorizations = @Authorization(value = AUTHORIZATION_TYPE))
-    @ApiResponses(value = {@ApiResponse(code = AUTHENTICATION_ERROR_CODE, message = AUTHENTICATION_ERROR_MESSAGE),
-                    @ApiResponse(code = AUTHORIZATION_ERROR_CODE, message = AUTHORIZATION_ERROR_MESSAGE),
-                    @ApiResponse(code = SERVER_ERROR_CODE, message = SERVER_ERROR_MESSAGE)})
-    public Response statistics() {
-        return Response.status(Response.Status.OK).entity(new StatisticsProvider().fetchCurrentStatistics()).build();
+@RestController
+@RequiredArgsConstructor
+public class StatisticsRestControllerV1 extends PapRestControllerV1
+    implements StatisticsRestControllerV1Api {
+
+    private final PdpStatisticsService pdpStatisticsService;
+
+    /**
+     * get statistics of PAP.
+     *
+     *
+     * @return a response
+     */
+    @Override
+    public ResponseEntity<StatisticsReport> statistics(UUID requestId) {
+        return addLoggingHeaders(addVersionControlHeaders(ResponseEntity.ok()), requestId)
+            .body(pdpStatisticsService.fetchCurrentStatistics());
+    }
+
+    /**
+     * get all statistics of PDP groups.
+     *
+     * @return a response
+     */
+    @Override
+    public ResponseEntity<Map<String, Map<String, List<PdpStatistics>>>> pdpStatistics(
+            UUID requestId,
+            Integer recordCount,
+            Long startTime,
+            Long endTime) {
+        return addLoggingHeaders(addVersionControlHeaders(ResponseEntity.ok()), requestId).body(pdpStatisticsService
+            .fetchDatabaseStatistics(recordCount.intValue(), convertEpochtoInstant(startTime),
+                    convertEpochtoInstant(endTime)));
+    }
+
+
+    /**
+     * get all statistics of a PDP group.
+     *
+     * @param groupName name of the PDP group
+     * @return a response
+     */
+    @Override
+    public ResponseEntity<Map<String, Map<String, List<PdpStatistics>>>> pdpGroupStatistics(
+            String groupName,
+            UUID requestId,
+            Integer recordCount,
+            Long startTime,
+            Long endTime) {
+        return addLoggingHeaders(addVersionControlHeaders(ResponseEntity.ok()), requestId)
+            .body(pdpStatisticsService.fetchDatabaseStatistics(groupName, recordCount.intValue(),
+                    convertEpochtoInstant(startTime), convertEpochtoInstant(endTime)));
     }
+
+    /**
+     * get all statistics of sub PDP group.
+     *
+     * @param groupName name of the PDP group
+     * @param subType type of the sub PDP group
+     * @return a response
+     */
+    @Override
+    public ResponseEntity<Map<String, Map<String, List<PdpStatistics>>>> pdpSubGroupStatistics(
+            String groupName,
+            String subType,
+            UUID requestId,
+            Integer recordCount,
+            Long startTime,
+            Long endTime) {
+        return addLoggingHeaders(addVersionControlHeaders(ResponseEntity.ok()), requestId)
+            .body(pdpStatisticsService.fetchDatabaseStatistics(groupName, subType, recordCount.intValue(),
+                convertEpochtoInstant(startTime), convertEpochtoInstant(endTime)));
+    }
+
+    /**
+     * get all statistics of one PDP.
+     *
+     * @param groupName name of the PDP group
+     * @param subType type of the sub PDP group
+     * @param pdpName the name of the PDP
+     * @param recordCount the count of the query response, optional, default return all statistics stored
+     * @return a response
+     */
+    @Override
+    public ResponseEntity<Map<String, Map<String, List<PdpStatistics>>>> pdpInstanceStatistics(
+            String groupName,
+            String subType,
+            String pdpName,
+            UUID requestId,
+            Integer recordCount,
+            Long startTime,
+            Long endTime) {
+        return addLoggingHeaders(addVersionControlHeaders(ResponseEntity.ok()), requestId)
+            .body(pdpStatisticsService.fetchDatabaseStatistics(groupName, subType, pdpName, recordCount.intValue(),
+                convertEpochtoInstant(startTime), convertEpochtoInstant(endTime)));
+    }
+
+    private Instant convertEpochtoInstant(Long epochSecond) {
+        return (epochSecond == null ? null : Instant.ofEpochSecond(epochSecond));
+    }
+
 }