diff --git a/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts b/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts index 589ee4f3..19f9f892 100644 --- a/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts +++ b/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts @@ -19,10 +19,12 @@ export class BaileysMessageProcessor { }>(); mount({ onMessageReceive }: MountProps) { + this.processorLogs.log(`๐Ÿงช [TESTE] mount chamado - BaileysMessageProcessor inicializado`); this.subscription = this.messageSubject .pipe( tap(({ 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) => { 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) { const { messages, type, requestId } = payload; + this.processorLogs.log(`๐Ÿงช [TESTE] processMessage chamado - messages: ${messages.length}, type: ${type}`); this.messageSubject.next({ messages, type, requestId, settings }); }