diff --git a/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts b/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts index 7abd6ed7..19f9f892 100644 --- a/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts +++ b/src/api/integrations/channel/whatsapp/baileysMessage.processor.ts @@ -2,9 +2,6 @@ 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; @@ -22,14 +19,10 @@ 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) => { @@ -61,8 +54,6 @@ 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 }); }