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

Merge pull request #2186 from muriloleal13/fix/baileys-message-processor-reconnection

Browse Source 
fix(baileys): resolve incoming message events not working after reconnection
This commit is contained in:
Davidson Gomes 2025-11-07 14:39:26 -03:00 committed by GitHub
commit 139ad9b3cb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/api/integrations/channel/whatsapp/baileysMessage.processor.ts
View File

@ -19,6 +19,22 @@ export class BaileysMessageProcessor {
}>();
mount({ onMessageReceive }: MountProps) {
// Se já existe subscription, fazer cleanup primeiro
if (this.subscription && !this.subscription.closed) {
this.subscription.unsubscribe();
}
// Se o Subject foi completado, recriar
if (this.messageSubject.closed) {
this.processorLogs.warn('MessageSubject was closed, recreating...');
this.messageSubject = new Subject<{
messages: WAMessage[];
type: MessageUpsertType;
requestId?: string;
settings: any;
}>();
}
this.subscription = this.messageSubject
.pipe(
tap(({ messages }) => {

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

@ -723,6 +723,11 @@ export class BaileysStartupService extends ChannelStartupService {
this.loadWebhook();
this.loadProxy();
// Remontar o messageProcessor para garantir que está funcionando após reconexão
this.messageProcessor.mount({
onMessageReceive: this.messageHandle['messages.upsert'].bind(this),
});
return await this.createClient(number);
} catch (error) {
this.logger.error(error);