From ef4a9ab66b478b83b616c2cbf4c5c81864724e60 Mon Sep 17 00:00:00 2001
From: Davidson Gomes <davidsongviolao@gmail.com>
Date: Fri, 12 Apr 2024 15:11:04 -0300
Subject: [PATCH] fix: retry messages

---
 .../services/whatsapp.baileys.service.ts      | 32 +++++++++----------
 1 file changed, 16 insertions(+), 16 deletions(-)

diff --git a/src/whatsapp/services/whatsapp.baileys.service.ts b/src/whatsapp/services/whatsapp.baileys.service.ts
index e4a2ce09..d38c6d8b 100644
--- a/src/whatsapp/services/whatsapp.baileys.service.ts
+++ b/src/whatsapp/services/whatsapp.baileys.service.ts
@@ -120,7 +120,7 @@ import { waMonitor } from '../whatsapp.module';
 import { CacheService } from './cache.service';
 import { WAStartupService } from './whatsapp.service';
 
-const retryCache = {};
+// const retryCache = {};
 
 export class BaileysStartupService extends WAStartupService {
   constructor(
@@ -1472,27 +1472,27 @@ export class BaileysStartupService extends WAStartupService {
         if (events['messages.upsert']) {
           this.logger.verbose('Listening event: messages.upsert');
           const payload = events['messages.upsert'];
-          if (payload.messages.find((a) => a?.messageStubType === 2)) {
-            const msg = payload.messages[0];
-            retryCache[msg.key.id] = msg;
-            return;
-          }
+          // if (payload.messages.find((a) => a?.messageStubType === 2)) {
+          //   const msg = payload.messages[0];
+          //   retryCache[msg.key.id] = msg;
+          //   return;
+          // }
           this.messageHandle['messages.upsert'](payload, database, settings);
         }
 
         if (events['messages.update']) {
           this.logger.verbose('Listening event: messages.update');
           const payload = events['messages.update'];
-          payload.forEach((message) => {
-            if (retryCache[message.key.id]) {
-              this.client.ev.emit('messages.upsert', {
-                messages: [message],
-                type: 'notify',
-              });
-              delete retryCache[message.key.id];
-              return;
-            }
-          });
+          // payload.forEach((message) => {
+          //   if (retryCache[message.key.id]) {
+          //     this.client.ev.emit('messages.upsert', {
+          //       messages: [message],
+          //       type: 'notify',
+          //     });
+          //     delete retryCache[message.key.id];
+          //     return;
+          //   }
+          // });
           this.messageHandle['messages.update'](payload, database, settings);
         }