From a4e9a23d74cc356ac87b79da39991d4b30f1dfab Mon Sep 17 00:00:00 2001
From: boufni95 <boufni95@gmail.com>
Date: Fri, 17 Jan 2025 17:33:41 +0000
Subject: [PATCH] fix metrics batch size

---
 src/services/main/paymentManager.ts         | 2 +-
 src/services/metrics/index.ts               | 3 ++-
 src/services/storage/metricsEventStorage.ts | 5 ++++-
 src/services/storage/paymentStorage.ts      | 2 +-
 4 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/services/main/paymentManager.ts b/src/services/main/paymentManager.ts
index 81acf2bc..4a18a2f8 100644
--- a/src/services/main/paymentManager.ts
+++ b/src/services/main/paymentManager.ts
@@ -690,7 +690,7 @@ export default class {
             throw new Error("user is banned, cannot retrieve operations")
         }
         const [outgoingInvoices, outgoingTransactions, incomingInvoices, incomingTransactions, incomingUserToUser, outgoingUserToUser] = await Promise.all([
-            this.storage.paymentStorage.GetUserInvoicePayments(userId, req.latestOutgoingInvoice, req.max_size),
+            this.storage.paymentStorage.GetUserInvoicePayments(userId, req.latestOutgoingInvoice, req.max_size), //
             this.storage.paymentStorage.GetUserTransactionPayments(userId, req.latestOutgoingTx, req.max_size),
             this.storage.paymentStorage.GetUserInvoicesFlaggedAsPaid(userId, req.latestIncomingInvoice, req.max_size),
             this.storage.paymentStorage.GetUserReceivingTransactions(userId, req.latestIncomingTx, req.max_size),
diff --git a/src/services/metrics/index.ts b/src/services/metrics/index.ts
index 307992f3..20abc735 100644
--- a/src/services/metrics/index.ts
+++ b/src/services/metrics/index.ts
@@ -70,7 +70,8 @@ export default class Handler {
     }
 
     async GetUsageMetrics(): Promise<Types.UsageMetrics> {
-        return this.storage.metricsEventStorage.LoadLatestMetrics()
+        const metrics = await this.storage.metricsEventStorage.LoadLatestMetrics()
+        return metrics
     }
 
     async GetErrorStats(): Promise<Types.ErrorStats> {
diff --git a/src/services/storage/metricsEventStorage.ts b/src/services/storage/metricsEventStorage.ts
index 11727613..f4b26a9d 100644
--- a/src/services/storage/metricsEventStorage.ts
+++ b/src/services/storage/metricsEventStorage.ts
@@ -107,7 +107,7 @@ export default class {
 
     }
 
-    LoadLatestMetrics = async (): Promise<Types.UsageMetrics> => {
+    LoadLatestMetrics = async (limit = 100): Promise<Types.UsageMetrics> => {
         this.persistMetrics()
         const metrics: Types.UsageMetrics = { apps: {} }
         this.foreachMetricMethodFile((app, method, tlvFiles) => {
@@ -120,6 +120,9 @@ export default class {
             if (!metrics.apps[app]) {
                 metrics.apps[app] = { app_metrics: {} }
             }
+            if (decoded.length > limit) {
+                decoded.splice(0, decoded.length - limit)
+            }
             metrics.apps[app].app_metrics[method] = {
                 base_64_tlvs: decoded.map(d => Buffer.from(d).toString('base64')),
                 current_chunk: latest,
diff --git a/src/services/storage/paymentStorage.ts b/src/services/storage/paymentStorage.ts
index 9e7755c3..2964b085 100644
--- a/src/services/storage/paymentStorage.ts
+++ b/src/services/storage/paymentStorage.ts
@@ -213,7 +213,7 @@ export default class {
                     user_id: userId
                 },
                 serial_id: MoreThanOrEqual(fromIndex),
-                paid_at_unix: MoreThan(0),
+                paid_at_unix: MoreThan(-1),
             },
             order: {
                 paid_at_unix: 'DESC'