NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-25 18:08:40 -06:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix: retry messages

Browse Source
This commit is contained in:
Davidson Gomes 2024-04-12 15:11:04 -03:00
parent 86e978faad
commit ef4a9ab66b
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/whatsapp/services/whatsapp.baileys.service.ts
View File

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