NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-12-09 01:49:37 -06:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix: streamline message handling logic and improve cache management in BaileysStartupService

Browse Source
This commit is contained in:
Vitordotpy 2025-11-28 21:14:19 -03:00
parent 92c2ace7bc
commit bee309cd28
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts
View File

@ -1148,12 +1148,7 @@ export class BaileysStartupService extends ChannelStartupService {
}
}
if (
(type !== 'notify' && type !== 'append') ||
editedMessage ||
received.message?.pollUpdateMessage ||
!received?.message
) {
if ((type !== 'notify' && type !== 'append') || editedMessage || !received?.message) {
continue;
}
@ -1447,18 +1442,18 @@ export class BaileysStartupService extends ChannelStartupService {
continue;
}
if (update.message !== null && update.status === undefined) continue;
if (update.message === null && update.status === undefined) continue;
const updateKey = `${this.instance.id}_${key.id}_${update.status}`;
const cached = await this.baileysCache.get(updateKey);
if (cached) {
if (cached && update.messageTimestamp == cached.messageTimestamp) {
this.logger.info(`Update Message duplicated ignored [avoid deadlock]: ${updateKey}`);
continue;
}
await this.baileysCache.set(updateKey, true, 30 * 60);
await this.baileysCache.set(updateKey, update.messageTimestamp, 30 * 60);
if (status[update.status] === 'READ' && key.fromMe) {
if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED && this.localChatwoot?.enabled) {
@ -1489,7 +1484,7 @@ export class BaileysStartupService extends ChannelStartupService {
remoteJid: key?.remoteJid,
fromMe: key.fromMe,
participant: key?.participant,
status: status[update.status] ?? 'DELETED',
status: status[update.status] ?? 'SERVER_ACK',
pollUpdates,
instanceId: this.instanceId,
};