From db32afe741b54b72d36831f8aa2e862b20fdcd96 Mon Sep 17 00:00:00 2001
From: Emily <adharaultimasheireen@gmail.com>
Date: Tue, 17 Sep 2024 13:39:56 +0200
Subject: [PATCH] better processed logs

---
 shared/services/RedisStreamService.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/shared/services/RedisStreamService.ts b/shared/services/RedisStreamService.ts
index 11013d4..47f7cb2 100644
--- a/shared/services/RedisStreamService.ts
+++ b/shared/services/RedisStreamService.ts
@@ -50,8 +50,10 @@ export class RedisStreamService {
     static async startReadingLoop(options: ReadingLoopOptions, processFunction: (content: Record<string, string>) => Promise<any>) {
 
         setInterval(() => {
-            console.log('Processed:', (RedisStreamService.processed / 30).toFixed(), '/s');
-            RedisStreamService.processed = 0;
+            if (RedisStreamService.processed > 0) {
+                console.log('Processed:', (RedisStreamService.processed / 30).toFixed(2), '/s');
+                RedisStreamService.processed = 0;
+            }
         }, 30_000)
 
         try {