fix metrics batch size

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),

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> {

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,

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'