feat: add compliance report module

Author: mjabascal10

backend/src/main/java/com/park/utmstack/util/chart_builder/elasticsearch_dsl/requests/RequestDsl.java

@@ -9,10 +9,12 @@
 import com.park.utmstack.service.elasticsearch.SearchUtil;
 import com.park.utmstack.util.TimezoneUtil;
 import com.park.utmstack.util.exceptions.UtmElasticsearchException;
+import com.park.utmstack.util.exceptions.UtmSerializationException;
 import org.opensearch.client.opensearch._types.SortOrder;
 import org.opensearch.client.opensearch._types.aggregations.*;
 import org.opensearch.client.opensearch.core.SearchRequest;
 import org.opensearch.client.opensearch.core.search.TrackHits;
+import org.springframework.data.domain.Pageable;
 import org.springframework.util.Assert;
 import org.springframework.util.CollectionUtils;
 
@@ -34,29 +36,48 @@ public RequestDsl(UtmVisualization visualization) {
     }
 
     public SearchRequest.Builder getSearchSourceBuilder() throws UtmElasticsearchException {
+        return getSearchSourceBuilder(null, 10000);
+    }
+
+    public SearchRequest.Builder getSearchSourceBuilder(Pageable pageable, int top) throws UtmElasticsearchException {
         final String ctx = CLASSNAME + ".getSearchSourceBuilder";
         try {
-            List<FilterType> filters = visualization.getFilterType();
-
-            if (CollectionUtils.isEmpty(filters))
-                filters = new ArrayList<>();
-
-            searchRequestBuilder.query(SearchUtil.toQuery(filters));
+            prepareSearchRequest();
 
-            if (visualization.getChartType() != ChartType.LIST_CHART &&
-                visualization.getChartType() != ChartType.TEXT_CHART) {
+            if (isAggregatedChart()) {
                 buildAggregation();
                 searchRequestBuilder.size(0);
                 searchRequestBuilder.trackTotalHits(TrackHits.of(t -> t.enabled(true)));
             } else {
-                searchRequestBuilder.size(10000);
+                applyPagination(pageable, top);
             }
             return searchRequestBuilder;
         } catch (Exception e) {
             throw new UtmElasticsearchException(ctx + ": " + e.getMessage());
         }
     }
 
+    private void prepareSearchRequest() throws UtmSerializationException {
+        List<FilterType> filters = visualization.getFilterType();
+        if (CollectionUtils.isEmpty(filters)) {
+            filters = new ArrayList<>();
+        }
+        searchRequestBuilder.query(SearchUtil.toQuery(filters));
+    }
+
+    private boolean isAggregatedChart() {
+        return visualization.getChartType() != ChartType.LIST_CHART &&
+                visualization.getChartType() != ChartType.TEXT_CHART;
+    }
+
+    private void applyPagination(Pageable pageable, int top) {
+        if (pageable != null && pageable.isPaged()) {
+            SearchUtil.applyPaginationAndSort(searchRequestBuilder, pageable, top);
+        } else {
+            searchRequestBuilder.size(10000);
+        }
+    }
+
     public SearchRequest.Builder getSearchSourceBuilderForCount() throws UtmElasticsearchException {
         final String ctx = CLASSNAME + ".getSearchSourceBuilderForCount";
         try {

backend/src/main/java/com/park/utmstack/web/rest/chart_builder/UtmVisualizationResource.java

@@ -280,7 +280,9 @@ public ResponseEntity<Void> bulkDelete(@RequestParam List<Long> ids) {
     }
 
     @PostMapping("/utm-visualizations/run")
-    public ResponseEntity<List<?>> run(@RequestBody UtmVisualization visualization) throws UtmChartBuilderException {
+    public ResponseEntity<List<?>> run(@RequestBody UtmVisualization visualization,
+                                       Pageable pageable,
+                                       @RequestParam(defaultValue = "200") int top) throws UtmChartBuilderException {
         final String ctx = CLASSNAME + ".run";
         try {
             Assert.notNull(visualization, "Param utmVisualization must not be null");
@@ -289,7 +291,7 @@ public ResponseEntity<List<?>> run(@RequestBody UtmVisualization visualization)
                 return ResponseEntity.ok(Collections.emptyList());
 
             RequestDsl requestQuery = new RequestDsl(visualization);
-            SearchResponse<ObjectNode> result = elasticsearchService.search(requestQuery.getSearchSourceBuilder().build(), ObjectNode.class);
+            SearchResponse<ObjectNode> result = elasticsearchService.search(requestQuery.getSearchSourceBuilder(pageable, 200).build(), ObjectNode.class);
             ResponseParser<?> responseParser = responseParserFactory.instance(visualization.getChartType());
             return ResponseEntity.ok().body(responseParser.parse(visualization, result));
         } catch (Exception e) {