diff --git a/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts b/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts index 19f9f892..7abd6ed7 100644 --- a/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts +++ b/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts @@ -2,6 +2,9 @@ import { Logger } from '@config/logger.config'; import { BaileysEventMap, MessageUpsertType, proto } from 'baileys'; import { catchError, concatMap, delay, EMPTY, from, retryWhen, Subject, Subscription, take, tap } from 'rxjs'; +// Log de teste que confirma que o arquivo foi carregado +require('fs').writeFileSync('/tmp/debug.log', `🧪 [TESTE] ARQUIVO CARREGADO - BaileysMessageProcessor - ${new Date().toISOString()}\n`, { flag: 'a' }); + type MessageUpsertPayload = BaileysEventMap['messages.upsert']; type MountProps = { onMessageReceive: (payload: MessageUpsertPayload, settings: any) => Promise; @@ -19,10 +22,14 @@ export class BaileysMessageProcessor { }>(); mount({ onMessageReceive }: MountProps) { + // Log que não é sobrescrito - escreve em arquivo + require('fs').writeFileSync('/tmp/debug.log', `🧪 [TESTE] mount chamado - ${new Date().toISOString()}\n`, { flag: 'a' }); this.processorLogs.log(`🧪 [TESTE] mount chamado - BaileysMessageProcessor inicializado`); this.subscription = this.messageSubject .pipe( tap(({ messages }) => { + // Log que não é sobrescrito - escreve em arquivo + require('fs').writeFileSync('/tmp/debug.log', `🚀 [BaileysMessageProcessor] Processing batch of ${messages.length} messages - ${new Date().toISOString()}\n`, { flag: 'a' }); 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) => { @@ -54,6 +61,8 @@ export class BaileysMessageProcessor { processMessage(payload: MessageUpsertPayload, settings: any) { const { messages, type, requestId } = payload; + // Log que não é sobrescrito - escreve em arquivo + require('fs').writeFileSync('/tmp/debug.log', `🧪 [TESTE] processMessage chamado - messages: ${messages.length}, type: ${type} - ${new Date().toISOString()}\n`, { flag: 'a' }); this.processorLogs.log(`🧪 [TESTE] processMessage chamado - messages: ${messages.length}, type: ${type}`); this.messageSubject.next({ messages, type, requestId, settings }); }