NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-08-28 18:26:12 -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 08:08:08 -03:00
parent 541a87f6d2
commit 4385db2912
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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<void>;
@ -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 });
}