From e7bb802b2895c5be72a7d3ff3ce36bd22544c56f Mon Sep 17 00:00:00 2001
From: manelcecs <manuelc.p.g@gmail.com>
Date: Fri, 8 Mar 2024 09:55:17 +0100
Subject: [PATCH] Fix: HPC-9451 total amount discrepancy

---
 .../search-flow-by-filters-strategy-impl.ts   | 51 ++++++++++++++-----
 1 file changed, 39 insertions(+), 12 deletions(-)

diff --git a/src/domain-services/flows/strategy/impl/search-flow-by-filters-strategy-impl.ts b/src/domain-services/flows/strategy/impl/search-flow-by-filters-strategy-impl.ts
index c5195a6c..09b0161d 100644
--- a/src/domain-services/flows/strategy/impl/search-flow-by-filters-strategy-impl.ts
+++ b/src/domain-services/flows/strategy/impl/search-flow-by-filters-strategy-impl.ts
@@ -231,21 +231,48 @@ export class SearchFlowByFiltersStrategy implements FlowSearchStrategy {
     );
 
     // Then we are going to slice the flows using the limit and offset
-    const reducedFlows: UniqueFlowEntity[] = sortedFlows.slice(
-      offset,
-      offset! + limit!
-    );
-
-    // Once the list of elements is reduced, we need to build the conditions
-    const searchConditions = this.buildConditions(reducedFlows, flowFilters);
+    let reducedFlows: UniqueFlowEntity[];
+    if (offset && limit) {
+      reducedFlows = sortedFlows.slice(offset, offset + limit);
+    } else {
+      reducedFlows = sortedFlows;
+    }
 
     const orderByForFlow = { column: 'updatedAt', order: 'DESC' };
 
-    const flows = await this.flowService.getFlows({
-      models,
-      conditions: searchConditions,
-      orderBy: orderByForFlow,
-    });
+    let flows: FlowEntity[] = [];
+    const chunkSize = 5000;
+    if (reducedFlows.length > chunkSize) {
+      // We need to paginate over the searchConditions
+      // Then collect the flows
+
+      // 1. Generate an array of arrays with the chunkSize
+      const chunkedFlows = [];
+      for (let i = 0; i < reducedFlows.length; i += chunkSize) {
+        chunkedFlows.push(reducedFlows.slice(i, i + chunkSize));
+      }
+
+      // 2. Iterate over the array of arrays to generate the searchConditions
+      // And collect the flows
+      for (const chunk of chunkedFlows) {
+        const chunkSearchConditions = this.buildConditions(chunk, flowFilters);
+        const flowsChunk = await this.flowService.getFlows({
+          models,
+          conditions: chunkSearchConditions,
+          orderBy: orderByForFlow,
+        });
+        flows = [...flows, ...flowsChunk];
+      }
+    } else {
+      // Once the list of elements is reduced, we need to build the conditions
+      const searchConditions = this.buildConditions(reducedFlows, flowFilters);
+
+      flows = await this.flowService.getFlows({
+        models,
+        conditions: searchConditions,
+        orderBy: orderByForFlow,
+      });
+    }
 
     return { flows, count };
   }