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

fix: Fix the problem when disconnecting the instance and connecting again using mongodb

Browse Source
This commit is contained in:
Davidson Gomes 2023-12-20 09:56:53 -03:00
parent 2797250f34
commit 060a945aea
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/whatsapp/services/whatsapp.service.ts
View File

@ -2043,7 +2043,7 @@ export class 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;
@ -2054,16 +2054,16 @@ export class WAStartupService {
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);
} }