NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-08-29 02:36:11 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add develop debug branch

Browse Source
This commit is contained in:
Saulo Mendes Martins 2025-08-21 07:48:05 -03:00
parent 7632ee7f99
commit 541a87f6d2
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -19,10 +19,12 @@ export class BaileysMessageProcessor {
}>(); }>();
mount({ onMessageReceive }: MountProps) { mount({ onMessageReceive }: MountProps) {
this.processorLogs.log(`🧪 [TESTE] mount chamado - BaileysMessageProcessor inicializado`);
this.subscription = this.messageSubject this.subscription = this.messageSubject
.pipe( .pipe(
tap(({ messages }) => { tap(({ messages }) => {
this.processorLogs.log(`🚀 [BaileysMessageProcessor] Processing batch of ${messages.length} messages`); this.processorLogs.log(`🚀 [BaileysMessageProcessor] Processing batch of ${messages.length} messages`);
this.processorLogs.log(`🧪 [TESTE] LOG DE TESTE FUNCIONANDO - ${new Date().toISOString()}`);
messages.forEach((msg, index) => { messages.forEach((msg, index) => {
this.processorLogs.log(`📱 [BaileysMessageProcessor] Message ${index + 1}: ${msg.key?.remoteJid} - ${msg.message?.conversation || msg.message?.extendedTextMessage?.text || 'NO_TEXT'}`); this.processorLogs.log(`📱 [BaileysMessageProcessor] Message ${index + 1}: ${msg.key?.remoteJid} - ${msg.message?.conversation || msg.message?.extendedTextMessage?.text || 'NO_TEXT'}`);
}); });
@ -52,6 +54,7 @@ export class BaileysMessageProcessor {
processMessage(payload: MessageUpsertPayload, settings: any) { processMessage(payload: MessageUpsertPayload, settings: any) {
const { messages, type, requestId } = payload; const { messages, type, requestId } = payload;
this.processorLogs.log(`🧪 [TESTE] processMessage chamado - messages: ${messages.length}, type: ${type}`);
this.messageSubject.next({ messages, type, requestId, settings }); this.messageSubject.next({ messages, type, requestId, settings });
} }