From d45b7af3b69c8926f776f5b3c62a7ef0e710306a Mon Sep 17 00:00:00 2001 From: Davidson Gomes Date: Sat, 27 Apr 2024 13:11:33 -0300 Subject: [PATCH] fix: recovering messages --- src/api/services/whatsapp/whatsapp.baileys.service.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/api/services/whatsapp/whatsapp.baileys.service.ts b/src/api/services/whatsapp/whatsapp.baileys.service.ts index d8d856a1..9821d9ae 100644 --- a/src/api/services/whatsapp/whatsapp.baileys.service.ts +++ b/src/api/services/whatsapp/whatsapp.baileys.service.ts @@ -148,17 +148,17 @@ export class BaileysStartupService extends WAStartupService { public mobile: boolean; private async recoveringMessages() { + this.logger.info('Recovering messages lost'); const cacheConf = this.configService.get('CACHE'); if ((cacheConf?.REDIS?.ENABLED && cacheConf?.REDIS?.URI !== '') || cacheConf?.LOCAL?.ENABLED) { setInterval(async () => { - this.logger.info('Recovering messages'); this.messagesLostCache.keys().then((keys) => { keys.forEach(async (key) => { const message = await this.messagesLostCache.get(key.split(':')[2]); if (message.messageStubParameters && message.messageStubParameters[0] === 'Message absent from node') { - this.logger.verbose('Message absent from node, retrying to send, key: ' + key.split(':')[2]); + this.logger.info('Message absent from node, retrying to send, key: ' + key.split(':')[2]); await this.client.sendMessageAck(JSON.parse(message.messageStubParameters[1], BufferJSON.reviver)); } });