Skip to content

Commit 4b11cfb

Browse files
committed
Add develop debug branch
1 parent 541a87f commit 4b11cfb

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/api/integrations/channel/whatsapp/baileysMessage.processor.ts

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@ import { Logger } from '@config/logger.config';
22
import { BaileysEventMap, MessageUpsertType, proto } from 'baileys';
33
import { catchError, concatMap, delay, EMPTY, from, retryWhen, Subject, Subscription, take, tap } from 'rxjs';
44

5+
// Log de teste que confirma que o arquivo foi carregado
6+
require('fs').writeFileSync('/tmp/debug.log', `🧪 [TESTE] ARQUIVO CARREGADO - BaileysMessageProcessor - ${new Date().toISOString()}\n`, { flag: 'a' });
7+
58
type MessageUpsertPayload = BaileysEventMap['messages.upsert'];
69
type MountProps = {
710
onMessageReceive: (payload: MessageUpsertPayload, settings: any) => Promise<void>;
@@ -19,10 +22,14 @@ export class BaileysMessageProcessor {
1922
}>();
2023

2124
mount({ onMessageReceive }: MountProps) {
25+
// Log que não é sobrescrito - escreve em arquivo
26+
require('fs').writeFileSync('/tmp/debug.log', `🧪 [TESTE] mount chamado - ${new Date().toISOString()}\n`, { flag: 'a' });
2227
this.processorLogs.log(`🧪 [TESTE] mount chamado - BaileysMessageProcessor inicializado`);
2328
this.subscription = this.messageSubject
2429
.pipe(
2530
tap(({ messages }) => {
31+
// Log que não é sobrescrito - escreve em arquivo
32+
require('fs').writeFileSync('/tmp/debug.log', `🚀 [BaileysMessageProcessor] Processing batch of ${messages.length} messages - ${new Date().toISOString()}\n`, { flag: 'a' });
2633
this.processorLogs.log(`🚀 [BaileysMessageProcessor] Processing batch of ${messages.length} messages`);
2734
this.processorLogs.log(`🧪 [TESTE] LOG DE TESTE FUNCIONANDO - ${new Date().toISOString()}`);
2835
messages.forEach((msg, index) => {
@@ -54,6 +61,8 @@ export class BaileysMessageProcessor {
5461

5562
processMessage(payload: MessageUpsertPayload, settings: any) {
5663
const { messages, type, requestId } = payload;
64+
// Log que não é sobrescrito - escreve em arquivo
65+
require('fs').writeFileSync('/tmp/debug.log', `🧪 [TESTE] processMessage chamado - messages: ${messages.length}, type: ${type} - ${new Date().toISOString()}\n`, { flag: 'a' });
5766
this.processorLogs.log(`🧪 [TESTE] processMessage chamado - messages: ${messages.length}, type: ${type}`);
5867
this.messageSubject.next({ messages, type, requestId, settings });
5968
}

0 commit comments

Comments
 (0)