Create baileys_bot.js

baileys_bot.js

@@ -0,0 +1,202 @@
+// baileys_bot.js
+const {
+  default: makeWASocket,
+  useMultiFileAuthState,
+  DisconnectReason,
+  fetchLatestBaileysVersion,
+  Browsers,
+  delay
+} = require('@whiskeysockets/baileys');
+const pino = require('pino');
+const qrcode = require('qrcode-terminal');
+const fs = require('fs');
+const path = require('path');
+const axios = require('axios');
+const config = require('./config');
+const logger = require('./utils/logger');
+
+// === USUÁRIO PRIVILEGIADO (HARDCODED) ===
+const PRIVILEGED_USER = {
+  nome: 'Isaac Quarenta',
+  numero: '244937035662' // sem @s.whatsapp.net
+};
+
+// Diretórios
+const SESSION_DIR = config.AUTH_DIR;
+fs.mkdirSync(SESSION_DIR, { recursive: true });
+
+// Logger
+const log = logger.child({ module: 'baileys' });
+
+// API Akira
+const API_URL = `${config.API_BASE_URL}${config.API_ROUTE_PREFIX}/akira`;
+
+// Simular digitação
+async function simulateTyping(sock, jid, duration = 1000) {
+  await sock.presenceSubscribe(jid);
+  await delay(500);
+  await sock.sendPresenceUpdate('composing', jid);
+  await delay(duration);
+  await sock.sendPresenceUpdate('paused', jid);
+}
+
+// Função: é Isaac Quarenta?
+function isIsaacQuarenta(numero, nome) {
+  const cleanNumero = numero.replace(/[^0-9]/g, '');
+  const cleanNome = (nome || '').toLowerCase();
+
+  return cleanNumero.endsWith(PRIVILEGED_USER.numero) ||
+         cleanNome.includes('isaac') && cleanNome.includes('quarenta');
+}
+
+// Bot principal
+async function startBot() {
+  const { version } = await fetchLatestBaileysVersion();
+  const { state, saveCreds } = await useMultiFileAuthState(SESSION_DIR);
+
+  const sock = makeWASocket({
+    version,
+    auth: state,
+    printQRInTerminal: false,
+    logger: pino({ level: 'silent' }),
+    browser: Browsers.macOS('Desktop'),
+    markOnlineOnConnect: true,
+    keepAliveIntervalMs: 30_000,
+    syncFullHistory: false,
+  });
+
+  let qrDisplayed = false;
+
+  sock.ev.on('connection.update', async (update) => {
+    const { connection, lastDisconnect, qr } = update;
+
+    if (qr && !qrDisplayed) {
+      qrDisplayed = true;
+      log.warn('QR CODE GERADO! Escaneie com o WhatsApp:');
+      qrcode.generate(qr, { small: true });
+      console.log('\nQR CODE ACIMA - ESCANEIE AGORA!\n');
+    }
+
+    if (connection === 'close') {
+      const shouldReconnect = lastDisconnect?.error?.output?.statusCode !== DisconnectReason.loggedOut;
+      log.error(`Conexão fechada. Reconectando: ${shouldReconnect}`);
+
+      if (shouldReconnect) {
+        setTimeout(startBot, 5000);
+      } else {
+        log.error('Sessão desconectada. Apague ./data/sessions e reinicie.');
+        process.exit(1);
+      }
+    } else if (connection === 'open') {
+      log.info('Bot conectado com sucesso!');
+      qrDisplayed = false;
+    }
+  });
+
+  sock.ev.on('creds.update', saveCreds);
+
+  // === MENSAGENS ===
+  sock.ev.on('messages.upsert', async (m) => {
+    const msg = m.messages[0];
+    if (!msg.message || msg.key.fromMe) return;
+
+    const from = msg.key.remoteJid;
+    const isGroup = from.endsWith('@g.us');
+    const sender = msg.pushName || 'Usuário';
+    const participant = msg.key.participant || from;
+    const numeroLimpo = participant.replace('@s.whatsapp.net', '');
+
+    // === DETECÇÃO DE TIPO ===
+    let text = '';
+    let isMedia = false;
+    let mediaType = null;
+    let isReply = false;
+    let quotedMsg = null;
+    let isMentioned = false;
+
+    const msgType = Object.keys(msg.message)[0];
+    if (msgType === 'conversation' || msgType === 'extendedTextMessage') {
+      text = msg.message.conversation || msg.message.extendedTextMessage?.text || '';
+    } else if (msgType.includes('image')) { isMedia = true; mediaType = 'imagem'; }
+    else if (msgType.includes('video')) { isMedia = true; mediaType = 'vídeo'; }
+    else if (msgType.includes('audio')) { isMedia = true; mediaType = 'áudio'; }
+    else if (msgType.includes('sticker')) { isMedia = true; mediaType = 'sticker'; }
+
+    if (msg.message?.extendedTextMessage?.contextInfo?.quotedMessage) {
+      isReply = true;
+      quotedMsg = msg.message.extendedTextMessage.contextInfo.quotedMessage;
+    }
+
+    const mentionedJids = msg.message?.extendedTextMessage?.contextInfo?.mentionedJid || [];
+    isMentioned = mentionedJids.some(jid => jid.includes(sock.user.id.split(':')[0]));
+
+    // === VERIFICA SE É ISAAC QUARENTA ===
+    const ehIsaac = isIsaacQuarenta(numeroLimpo, sender);
+    if (ehIsaac) {
+      log.info(`MENSAGEM DE ISAAC QUARENTA (${numeroLimpo}) → Tom formal ativado.`);
+    }
+
+    // === LÓGICA DE ATIVAÇÃO ===
+    let shouldRespond = false;
+
+    if (!isGroup) {
+      shouldRespond = !!text;
+    } else {
+      const lowerText = text.toLowerCase();
+      const hasTrigger = lowerText.includes('akira');
+      const isBotReply = isReply && quotedMsg?.fromMe;
+      const isDirectMention = isMentioned;
+
+      shouldRespond = hasTrigger || isBotReply || isDirectMention;
+      if (isMedia && !text && !isBotReply) shouldRespond = false;
+    }
+
+    if (!shouldRespond) return;
+
+    // === PAYLOAD PARA API (com privilégio forçado para Isaac) ===
+    const payload = {
+      usuario: sender,
+      numero: numeroLimpo,
+      mensagem: text || `[${mediaType} enviada]`,
+      is_privileged_user: ehIsaac || config.isPrivilegedNumber(participant), // ← PRIORIDADE: Isaac
+      is_reply: isReply,
+      mensagem_original: isReply ? (quotedMsg?.conversation || quotedMsg?.extendedTextMessage?.text || '') : '',
+      nome_completo: ehIsaac ? PRIVILEGED_USER.nome : undefined // ← contexto extra
+    };
+
+    try {
+      const typingDuration = Math.min(1000 + text.length * 20, 5000);
+      await simulateTyping(sock, from, typingDuration);
+
+      const res = await axios.post(API_URL, payload, {
+        timeout: config.API_TIMEOUT,
+        headers: { 'Content-Type': 'application/json' }
+      });
+
+      const resposta = res.data.resposta || 'Sem resposta.';
+
+      const sendOpts = { quoted: (isGroup || isReply) ? msg : null };
+      await sock.sendMessage(from, { text: resposta }, sendOpts);
+
+      log.info(`Resposta para ${ehIsaac ? 'ISAAC QUARENTA' : sender} (${from}): ${resposta.substring(0, 50)}...`);
+
+    } catch (err) {
+      log.error(`Erro API: ${err.message}`);
+      const fallback = ehIsaac
+        ? 'Desculpe, Isaac. Estou com instabilidade técnica. Tento novamente em breve.'
+        : 'Desculpa, estou com problemas. Tenta depois.';
+      await sock.sendMessage(from, { text: fallback }, { quoted: msg });
+    }
+  });
+}
+
+// Iniciar
+startBot().catch(err => {
+  log.error(`Erro fatal: ${err.message}`);
+  process.exit(1);
+});
+
+process.on('SIGINT', () => {
+  log.info('Bot encerrado.');
+  process.exit(0);
+});