Spaces:

akra35567
/

projeto_js

Build error

App Files Files Community

akra35567 commited on Nov 1, 2025

Commit

6598bed

verified ·

1 Parent(s): 4744f01

Update index.js

Browse files

Files changed (1) hide show

index.js +172 -173

index.js CHANGED Viewed

@@ -1,208 +1,207 @@
-// index.js - Akira Bot HF Spaces
 const {
   default: makeWASocket,
   useMultiFileAuthState,
   fetchLatestBaileysVersion,
   Browsers,
-  delay,
-  DisconnectReason
 } = require('@whiskeysockets/baileys');
 const pino = require('pino');
 const axios = require('axios');
 const express = require('express');
-const qrcode = require('qrcode');
 const PORT = process.env.PORT || 3000;
-const AKIRA_API_URL = process.env.AKIRA_API_URL || 'https://akra35567-akira.hf.space/api/akira';
-const BOT_REAL_JID = process.env.BOT_REAL_JID || '37839265886398@lid';
 let sock;
-let isConnecting = false;
 let lastProcessedTime = 0;
-let healthInterval;
-let currentQR = null;
-// --- Express Server para página QR ---
-const app = express();
-const server = app.listen(PORT, '0.0.0.0', () => {
-  console.log(`Servidor ativo na porta ${server.address().port}`);
-});
-app.get('/', (req, res) => {
-  res.send(`AKIRA BOT ONLINE | ${new Date().toLocaleString()} | <a href="/qr">Ver QR Code</a>`);
-});
-app.get('/qr', (req, res) => {
-  if (currentQR) {
-    qrcode.toDataURL(currentQR, { scale: 10, margin: 2 }, (err, url) => {
-      if (err) return res.send('<h1>Erro ao gerar QR</h1>');
-      res.send(`
-<!DOCTYPE html>
-<html>
-<head><title>Akira Bot - QR</title></head>
-<body style="font-family:sans-serif; text-align:center; background:#000; color:#0f0; padding:30px;">
-<h1>AKIRA BOT - ESCANEIE QR</h1>
-<img src="${url}" style="width:300px; margin:20px 0;">
-<p>Atualiza a página se QR expirar.</p>
-<script>setTimeout(()=>location.reload(),5000);</script>
-</body>
-</html>
-      `);
-    });
-  } else {
-    res.send('<h1>Bot já conectado!</h1><p>Atualize para ver QR.</p>');
-  }
-});
-// --- Normaliza JID ---
-function normalizeJid(jid) {
   if (!jid) return null;
-  return jid.replace(/@lid|@s\.whatsapp\.net|@c\.us/g, '').trim();
 }
-// --- Health Check ---
-function startHealthCheck() {
-  if (healthInterval) clearInterval(healthInterval);
-  healthInterval = setInterval(() => {
-    console.log(`[HEALTH] ${new Date().toLocaleString()} - Bot ativo`);
-    if (sock?.sendPresenceUpdate) {
-      sock.sendPresenceUpdate('available').catch(() => {});
-    }
-  }, 20000); // ping a cada 20s
 }
-// --- Conecta ao WhatsApp ---
 async function connect() {
-  if (isConnecting) return;
-  isConnecting = true;
-  try {
-    const { state, saveCreds } = await useMultiFileAuthState('auth_info_baileys');
-    const { version } = await fetchLatestBaileysVersion();
-    sock = makeWASocket({
-      version,
-      auth: state,
-      logger: pino({ level: 'silent' }),
-      browser: Browsers.macOS('Desktop'),
-      markOnlineOnConnect: true,
-      keepAliveIntervalMs: 30000,
-      connectTimeoutMs: 60000,
-      defaultQueryTimeoutMs: 60000,
-      syncFullHistory: false,
-      generateHighQualityLinkPreview: false,
-      printQRInTerminal: false,
-      getMessage: async () => ({ conversation: '' }),
-      shouldSyncHistoryMessage: () => false,
-      patchMessageBeforeSending: msg => msg.text ? { text: msg.text } : msg
-    });
-    sock.ev.on('creds.update', saveCreds);
-    sock.ev.on('connection.update', async update => {
-      const { connection, lastDisconnect, qr } = update;
-      if (qr) {
-        currentQR = qr;
-        console.log('[QR CODE] Acesse /qr para escanear');
-      }
-      if (connection === 'open') {
-        currentQR = null;
-        console.log('AKIRA BOT ONLINE! (Multi-device ativo)');
-        lastProcessedTime = Date.now();
-        isConnecting = false;
-        startHealthCheck();
-      }
-      if (connection === 'close') {
-        isConnecting = false;
-        const reason = lastDisconnect?.error?.output?.statusCode || 'desconhecido';
-        if (reason === DisconnectReason.loggedOut) {
-          console.log('Sessão encerrada. Escaneie novo QR em /qr');
-          return;
-        }
-        const delay = [408, 428, 440, 515].includes(reason) ? 45000 : 15000;
-        console.log(`Reconectando em ${delay/1000}s... (código: ${reason})`);
-        setTimeout(connect, delay);
-      }
-    });
-    sock.ev.on('messages.upsert', async m => {
-      try {
-        const msg = m.messages[0];
-        if (!msg.message || msg.key.fromMe) return;
-        if (msg.messageStubType || msg.message.protocolMessage) return;
-        if (msg.messageTimestamp * 1000 < lastProcessedTime - 10000) return;
-        const from = msg.key.remoteJid;
-        const isGroup = from.endsWith('@g.us');
-        const participant = msg.key.participant || from;
-        const numero = participant.replace(/@s\.whatsapp\.net|@lid/g, '');
-        const nome = msg.pushName?.trim() || numero;
-        const text = msg.message.conversation || msg.message.extendedTextMessage?.text || '';
-        if (!text.trim()) return;
-        console.log(`\n[MENSAGEM] ${isGroup ? 'GRUPO' : 'PV'} | ${nome} (${numero}): ${text}`);
-        if (!(await shouldActivate(msg, isGroup))) return;
-        await sock.sendPresenceUpdate('composing', from);
-        const start = Date.now();
-        try {
-          const res = await axios.post(AKIRA_API_URL, { usuario: nome, mensagem: text, numero }, { timeout: 30000 });
-          let resposta = res.data.resposta || "Não entendi.";
-          if (resposta.length > 4000) resposta = resposta.slice(0, 3990) + '...';
-          const typing = Math.min(Math.max(resposta.length * 50, 1000), 5000);
-          if (Date.now() - start < typing) await delay(typing - (Date.now() - start));
-          await sock.sendPresenceUpdate('paused', from);
-          try { await sock.presenceSubscribe(from); await sock.sendPresenceUpdate('available', from); await delay(1000); } catch {}
-          let attempts = 0;
-          while (attempts < 3) {
-            try { await sock.sendMessage(from, { text: resposta }, { quoted: msg }); break; }
-            catch (err) { attempts++; console.error(`Tentativa ${attempts} falhou: ${err.message}`); await delay(1500 * attempts); }
-          }
-          if (attempts >= 3) await sock.sendMessage(from, { text: "Erro ao responder. Tente novamente." }, { quoted: msg });
-        } catch (err) {
-          console.error('Erro na API:', err.message);
-          try { await sock.sendMessage(from, { text: "Erro interno. Tente novamente." }, { quoted: msg }); } catch {}
-        }
-      } catch (err) {
-        console.error('Erro geral:', err.message);
-      }
-    });
-  } catch (err) {
-    isConnecting = false;
-    console.error('Erro crítico:', err.message);
-    setTimeout(connect, 20000);
-  }
 }
-// --- Define quando o bot deve ativar ---
-async function shouldActivate(msg, isGroup) {
   const context = msg.message?.extendedTextMessage?.contextInfo;
-  const text = (msg.message?.conversation || msg.message?.extendedTextMessage?.text || '').toLowerCase();
-  if (context?.quotedMessage && context.stanzaId) {
-    const quotedJid = context.participant || context.quotedMessage?.key?.participant;
-    if (quotedJid && normalizeJid(quotedJid) === normalizeJid(BOT_REAL_JID)) return true;
   }
   if (isGroup) {
     const mentions = context?.mentionedJid || [];
-    if (text.includes('akira') || mentions.some(j => normalizeJid(j) === normalizeJid(BOT_REAL_JID))) return true;
   }
   return false;
 }
-// --- Inicia conexão ---
 connect();

+// ===============================================================
+// AKIRA BOT — JID/LID unify + Session fix + Reply PV/Group logic
+// ===============================================================
 const {
   default: makeWASocket,
   useMultiFileAuthState,
   fetchLatestBaileysVersion,
   Browsers,
+  delay
 } = require('@whiskeysockets/baileys');
 const pino = require('pino');
 const axios = require('axios');
 const express = require('express');
+const qrcode = require('qrcode-terminal');
+const logger = pino({ level: 'info' });
+const AKIRA_API_URL = 'https://akra35567-akira.hf.space/api/akira';
 const PORT = process.env.PORT || 3000;
 let sock;
+let BOT_JID = null;
 let lastProcessedTime = 0;
+// ===============================================================
+// 🔧 UTILITÁRIOS
+// ===============================================================
+function extractNumber(input = '') {
+  if (!input) return 'desconhecido';
+  const clean = input.toString();
+  const match = clean.match(/2449\d{8}/);
+  if (match) return match[0];
+  const local = clean.match(/9\d{8}/);
+  if (local) return `244${local[0]}`;
+  return clean.replace(/\D/g, '').slice(-12);
+}
+function normalizeJid(jid = '') {
   if (!jid) return null;
+  jid = jid.toString().trim();
+  // remove lixo e sufixos
+  jid = jid.replace(/[:@].*/g, '');
+  if (jid.startsWith('37') || jid.startsWith('202') || jid.length < 9)
+    return BOT_JID || '244952786417@s.whatsapp.net';
+  if (!jid.startsWith('244') && /^9\d{8}$/.test(jid))
+    jid = '244' + jid;
+  return `${jid}@s.whatsapp.net`;
 }
+function isBotJid(jid) {
+  const norm = normalizeJid(jid);
+  return norm === normalizeJid(BOT_JID);
 }
+// ===============================================================
+// ⚙️ CONEXÃO
+// ===============================================================
 async function connect() {
+  const { state, saveCreds } = await useMultiFileAuthState('auth_info_baileys');
+  const { version } = await fetchLatestBaileysVersion();
+  sock = makeWASocket({
+    version,
+    auth: state,
+    logger,
+    browser: Browsers.macOS('Desktop'),
+    markOnlineOnConnect: true,
+    syncFullHistory: false,
+    connectTimeoutMs: 60000
+  });
+  sock.ev.on('creds.update', saveCreds);
+  sock.ev.on('connection.update', async (update) => {
+    const { connection, qr } = update;
+    if (qr) {
+      qrcode.generate(qr, { small: true });
+      console.log('\n📱 ESCANEIE O QR PARA CONECTAR\n');
+    }
+    if (connection === 'open') {
+      BOT_JID = normalizeJid(sock.user.id);
+      console.log('✅ AKIRA BOT ONLINE!');
+      console.log('botJid detectado:', BOT_JID);
+      lastProcessedTime = Date.now();
+    }
+    if (connection === 'close') {
+      console.log('⚠️ Conexão perdida. Tentando reconectar...');
+      setTimeout(connect, 5000);
+    }
+  });
+  // ===============================================================
+  // 💬 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');
+    if (msg.messageTimestamp && msg.messageTimestamp * 1000 < lastProcessedTime - 10000) return;
+    // Extração inteligente do número real
+    let sender = msg.key.participant || msg.participant || msg.key.remoteJid;
+    const pn = msg.message?.participantPn || msg.message?.senderPn;
+    const lid = msg.key.senderLid || msg.participantLid || msg.message?.senderLid;
+    const possible = pn || lid || sender;
+    const senderNumber = extractNumber(possible);
+    const nome = msg.pushName || senderNumber;
+    const text =
+      msg.message.conversation ||
+      msg.message.extendedTextMessage?.text ||
+      msg.message?.imageMessage?.caption ||
+      msg.message?.videoMessage?.caption ||
+      '';
+    if (!text.trim()) return;
+    console.log(`\n[MENSAGEM] ${isGroup ? 'GRUPO' : 'PV'} | ${nome} (${senderNumber}): ${text}`);
+    const ativar = await shouldActivate(msg, isGroup, text);
+    if (!ativar) {
+      console.log('[IGNORADO] Não ativado para responder (não reply ou não menção).');
+      return;
+    }
+    await sock.sendPresenceUpdate('composing', from);
+    try {
+      const res = await axios.post(AKIRA_API_URL, {
+        usuario: nome,
+        mensagem: text,
+        numero: senderNumber
+      });
+      const resposta = res.data.resposta || '...';
+      console.log(`[RESPOSTA] ${resposta}`);
+      await delay(Math.min(resposta.length * 50, 4000));
+      await sock.sendPresenceUpdate('paused', from);
+      await sock.sendMessage(from, { text: resposta }, { quoted: msg });
+    } catch (err) {
+      console.error('⚠️ Erro na API:', err.message);
+      await sock.sendMessage(from, { text: 'Erro interno. 😴' }, { quoted: msg });
+    }
+  });
+  // ===============================================================
+  // 🧰 REGENERAÇÃO DE SESSÃO
+  // ===============================================================
+  sock.ev.on('message-decrypt-failed', async (msgKey) => {
+    console.log('⚠️ Tentando regenerar sessão perdida...');
+    try {
+      await sock.sendRetryRequest(msgKey.key);
+    } catch (e) {
+      console.log('❌ Falha ao regenerar sessão:', e.message);
+    }
+  });
 }
+// ===============================================================
+// 🎯 ATIVAÇÃO (reply / menção / PV)
+// ===============================================================
+async function shouldActivate(msg, isGroup, text) {
   const context = msg.message?.extendedTextMessage?.contextInfo;
+  const lowered = text.toLowerCase();
+  // Reply ao bot
+  if (context?.participant) {
+    const quoted = normalizeJid(context.participant);
+    if (isBotJid(quoted)) {
+      console.log(`[ATIVAÇÃO] Reply ao bot detectado (${BOT_JID})`);
+      return true;
+    }
   }
+  // Menção direta no grupo
   if (isGroup) {
     const mentions = context?.mentionedJid || [];
+    const mentionMatch = mentions.some(
+      j => isBotJid(j) || j.includes(BOT_JID.split('@')[0])
+    );
+    if (lowered.includes('akira') || mentionMatch) {
+      console.log('[ATIVAÇÃO] Menção direta a Akira detectada.');
+      return true;
+    }
   }
+  // PV → sempre responde
+  if (!isGroup) return true;
   return false;
 }
+// ===============================================================
+// 🌐 HEALTH CHECK
+// ===============================================================
+const app = express();
+const server = app.listen(PORT, '0.0.0.0', () => {
+  console.log(`Health check na porta ${server.address().port}`);
+});
+app.get('/', (req, res) => res.send('AKIRA BOT ONLINE ✅'));
 connect();