From bec00a4cbab2a96b31af4c6cb952605355b523a8 Mon Sep 17 00:00:00 2001
From: Sai Nikhil <nikhil@openobserve.ai>
Date: Mon, 9 Sep 2024 19:29:12 +0530
Subject: [PATCH] fix: Pagination partition fix (#4494)

1.fixed pagination partition for histogram mode

<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit


- **New Features**
  - Enhanced calculation of partition totals for improved accuracy.
- Introduced conditional control for histogram data generation based on
user settings.

- **Bug Fixes**
- Adjusted logic to ensure correct handling of partition totals across
data sets.

<!-- end of auto-generated comment: release notes by coderabbit.ai -->
---
 web/src/composables/useLogs.ts | 39 +++++++++++++++++++++++++++-------
 1 file changed, 31 insertions(+), 8 deletions(-)

diff --git a/web/src/composables/useLogs.ts b/web/src/composables/useLogs.ts
index 0676f6dbe9..e9a8f29dee 100644
--- a/web/src/composables/useLogs.ts
+++ b/web/src/composables/useLogs.ts
@@ -1380,8 +1380,8 @@ const useLogs = () => {
                   Math.max(parseInt(currentValue.zo_sql_num, 10), 0),
                 0,
               );
-            partitionDetail.partitionTotal[0] =
-              searchObj.data.queryResults.total;
+            // partitionDetail.partitionTotal[currentPage] =
+            //   searchObj.data.queryResults.total;
           }
         } else {
           searchObj.data.queryResults.total =
@@ -1710,17 +1710,40 @@ const useLogs = () => {
               }
 
               await generateHistogramSkeleton();
-
-              for (const partition of partitions) {
+              let index = 0;
+              for (const partition  of partitions) {
                 searchObj.data.histogramQuery.query.start_time = partition[0];
                 searchObj.data.histogramQuery.query.end_time = partition[1];
                 await getHistogramQueryData(searchObj.data.histogramQuery);
-                if (partitions.length > 1) {
-                  setTimeout(async () => {
+       
+               if (partitions.length > 1) {
+                  // setTimeout(async () => {
                     await generateHistogramData();
                     refreshPartitionPagination(true);
-                  }, 100);
+                  // }, 100);
+                
                 }
+                if(index == 0){
+                  searchObj.data.queryResults.partitionDetail.partitionTotal[index] = searchObj.data.queryResults.aggs.reduce(
+                    (accumulator: number, currentValue: any) =>
+                      accumulator +
+                      Math.max(parseInt(currentValue.zo_sql_num, 10), 0),
+                    0,
+                  );
+
+                }
+                else{
+
+                const previousTotal = searchObj.data.queryResults.partitionDetail.partitionTotal
+                .slice(0, index) // Get all elements before the current index
+                .reduce((acc : any, val : any) => acc + val, 0); // Sum them
+              
+              // Subtract the previous total from queryResults.total
+              const result = searchObj.data.queryResults.total - previousTotal;
+              // Assign the result to the current index in partitionTotal
+              searchObj.data.queryResults.partitionDetail.partitionTotal[index] = result;    
+                }
+                index++;
               }
               searchObj.loadingHistogram = false;
             }
@@ -1748,7 +1771,7 @@ const useLogs = () => {
           if (
             queryReq.query.from == 0 &&
             searchObj.data.queryResults.hits.length > 0 &&
-            !aggFlag
+            !aggFlag && !searchObj.meta.showHistogram
           ) {
             setTimeout(async () => {
               searchObjDebug["pagecountStartTime"] = performance.now();