Update modules/BotCore.js

modules/BotCore.js

@@ -46,6 +46,7 @@ class BotCore {
     this.isConnected = false;
     this.lastProcessedTime = 0;
     this.processadas = new Set();
+    this.reconnectAttempts = 0;
 
     // Armazenamento
     this.store = null;
@@ -154,6 +155,12 @@ class BotCore {
    */
   async connect() {
     try {
+      // Evita múltiplas conexões simultâneas
+      if (this.sock && this.sock.ws && this.sock.ws.readyState === 1) {
+        this.logger.info('🔄 Já conectado, ignorando tentativa de reconexão');
+        return;
+      }
+
       this.logger.info('🔗 Conectando ao WhatsApp...');
 
       // Verifica se devemos limpar credenciais antigas
@@ -170,13 +177,19 @@ class BotCore {
         markOnlineOnConnect: true,
         syncFullHistory: false,
         printQRInTerminal: false,
-        connectTimeoutMs: 60000,
+        connectTimeoutMs: 120000, // Aumentado para 2 minutos
+        qrTimeout: 90000, // 90 segundos para QR
+        defaultQueryTimeoutMs: 60000,
+        // Configurações para ambientes com conectividade limitada
+        keepAliveIntervalMs: 30000,
+        retryRequestDelayMs: 5000,
+        maxRetries: 5,
         getMessage: async (key) => {
           if (!key) return undefined;
           try {
             if (this.store && typeof this.store.loadMessage === 'function') {
               const msg = await this.store.loadMessage(key.remoteJid, key.id);
-              return msg?.message;
+              return msg ? msg.message : undefined;
             }
           } catch (e) {}
           return undefined;
@@ -195,6 +208,14 @@ class BotCore {
       this.sock.ev.on('connection.update', this.handleConnectionUpdate.bind(this));
       this.sock.ev.on('messages.upsert', this.handleMessagesUpsert.bind(this));
 
+      // Timeout para forçar geração de QR se não vier automaticamente
+      this.qrTimeout = setTimeout(() => {
+        if (!this.currentQR && !this.isConnected) {
+          this.logger.warn('⏰ QR não gerado automaticamente. Tentando forçar...');
+          this._forceQRGeneration();
+        }
+      }, 10000); // 10 segundos
+
       this.logger.info('✅ Conexão inicializada');
 
     } catch (error) {
@@ -212,14 +233,28 @@ class BotCore {
 
       if (qr) {
         this.currentQR = qr;
-        this.logger.info('📱 QR Code gerado');
+        this.logger.info('📱 QR Code gerado - pronto para scan!');
+        this.logger.info('🔗 Acesse http://localhost:7860/qr para ver o QR code');
+
+        // Limpa timeout de força
+        if (this.qrTimeout) {
+          clearTimeout(this.qrTimeout);
+          this.qrTimeout = null;
+        }
       }
 
       if (connection === 'open') {
-        this.BOT_JID = this.sock.user?.id || null;
+        this.BOT_JID = (this.sock.user && this.sock.user.id) || null;
         this.isConnected = true;
         this.lastProcessedTime = Date.now();
         this.currentQR = null;
+        this.reconnectAttempts = 0; // Reseta contador de tentativas
+
+        // Limpa timeout de força
+        if (this.qrTimeout) {
+          clearTimeout(this.qrTimeout);
+          this.qrTimeout = null;
+        }
 
         this.logger.info('\n' + '═'.repeat(70));
         this.logger.info('✅ AKIRA BOT V21 ONLINE!');
@@ -229,10 +264,33 @@ class BotCore {
 
       } else if (connection === 'close') {
         this.isConnected = false;
-        const code = lastDisconnect?.error?.output?.statusCode;
-        this.logger.warn(`⚠️  Conexão perdida (${code}). Reconectando...`);
-        setTimeout(() => this.connect().catch(e => this.logger.error(e)), 5000);
+        const code = (lastDisconnect && lastDisconnect.error && lastDisconnect.error.output && lastDisconnect.error.output.statusCode) || undefined;
+        const reason = (lastDisconnect && lastDisconnect.error && lastDisconnect.error.message) || 'desconhecido';
+
+        this.logger.warn(`⚠️  Conexão perdida (código: ${code}, motivo: ${reason})`);
+
+        // Códigos de erro específicos
+        if (code === 408) {
+          this.logger.warn('⏰ Timeout de conexão - possível problema de rede');
+        } else if (code === 401) {
+          this.logger.warn('🔐 Credenciais rejeitadas - será necessário novo login');
+          // Limpa credenciais em caso de auth error
+          this._cleanAuthOnError();
+        } else if (code === 403) {
+          this.logger.warn('🚫 Conta banida ou bloqueada');
+        }
+
+        // Reconecta com backoff exponencial
+        const delay = Math.min(5000 * Math.pow(2, this.reconnectAttempts || 0), 30000);
+        this.reconnectAttempts = (this.reconnectAttempts || 0) + 1;
+
+        this.logger.info(`🔄 Reconectando em ${delay/1000}s... (tentativa ${this.reconnectAttempts})`);
+        setTimeout(() => this.connect().catch(e => this.logger.error('Erro na reconexão:', e)), delay);
+
+      } else if (connection === 'connecting') {
+        this.logger.info('🔄 Conectando ao WhatsApp...');
       }
+
     } catch (error) {
       this.logger.error('❌ Erro em handleConnectionUpdate:', error.message);
     }
@@ -404,7 +462,7 @@ class BotCore {
           deveResponder = true;
         } else {
           // Em grupos, responde se for reply ao bot ou menção
-          if (replyInfo?.ehRespostaAoBot) {
+          if (replyInfo && replyInfo.ehRespostaAoBot) {
             deveResponder = true;
           } else if (this.messageProcessor.isBotMentioned(m)) {
             deveResponder = true;
@@ -412,7 +470,7 @@ class BotCore {
         }
       } else {
         // Texto
-        if (replyInfo?.ehRespostaAoBot) {
+        if (replyInfo && replyInfo.ehRespostaAoBot) {
           deveResponder = true;
         } else if (!ehGrupo) {
           // Em PV sempre responde
@@ -439,7 +497,7 @@ class BotCore {
         mensagem: texto,
         tipo_conversa: ehGrupo ? 'grupo' : 'pv',
         tipo_mensagem: foiAudio ? 'audio' : 'texto',
-        mensagem_citada: replyInfo?.textoMensagemCitada || '',
+        mensagem_citada: (replyInfo && replyInfo.textoMensagemCitada) || '',
         reply_metadata: replyInfo ? {
           reply_to_bot: replyInfo.ehRespostaAoBot,
           quoted_author_name: replyInfo.quemEscreveuCitacao || 'desconhecido'
@@ -480,7 +538,7 @@ class BotCore {
         
         await this.simulateTyping(m.key.remoteJid, tempoDigitacao);
 
-        const opcoes = ehGrupo || (replyInfo?.ehRespostaAoBot) ? { quoted: m } : {};
+        const opcoes = ehGrupo || (replyInfo && replyInfo.ehRespostaAoBot) ? { quoted: m } : {};
         await this.sock.sendMessage(m.key.remoteJid, { text: resposta }, opcoes);
       }
 
@@ -550,6 +608,49 @@ class BotCore {
     }
   }
 
+  /**
+   * Limpa credenciais em caso de erro de autenticação
+   */
+  _cleanAuthOnError() {
+    const fs = require('fs');
+    try {
+      if (fs.existsSync(this.config.AUTH_FOLDER)) {
+        fs.rmSync(this.config.AUTH_FOLDER, { recursive: true, force: true });
+        this.logger.info('🧹 Credenciais limpas devido a erro de autenticação');
+      }
+      this.isConnected = false;
+      this.currentQR = null;
+      this.BOT_JID = null;
+    } catch (error) {
+      this.logger.error('❌ Erro ao limpar credenciais:', error.message);
+    }
+  }
+
+  /**
+   * Força geração de QR code se não vier automaticamente
+   */
+  async _forceQRGeneration() {
+    try {
+      this.logger.info('🔄 Forçando geração de QR code...');
+
+      if (this.sock) {
+        this.sock.ev.removeAllListeners();
+        if (this.sock.ws) {
+          this.sock.ws.close();
+        }
+      }
+
+      // Pequeno delay antes de reconectar
+      await delay(2000);
+
+      // Reconecta
+      await this.connect();
+
+    } catch (error) {
+      this.logger.error('❌ Erro ao forçar QR:', error.message);
+    }
+  }
+
   /**
    * Obtém QR Code atual
    */