-2

Estou integrando o Venom Bot com um assistente GPT e já está funcionando, mas dois números do WhatsApp foram banidos, possivelmente por conta do bug recente da Meta. Isso me preocupou, pois não posso perder os números. Para evitar problemas, configurei tempos de resposta aleatórios entre 30 e 75 segundos e fiz o bot pausar por 10 minutos a cada 50 mensagens enviadas. Durante a pausa, ele acumula mensagens e responde todas ao voltar, mas isso causa envios simultâneos para diferentes usuários, o que pode ser arriscado. Preciso de ajuda para criar uma fila de respostas, com um intervalo de pelo menos 5 segundos entre cada envio, garantindo que as respostas sejam enviadas sequencialmente e nunca simultaneamente.

const axios = require('axios');
const fs = require('fs');
const path = require('path');
const FormData = require('form-data'); // Certifique-se de que esta biblioteca está instalada!
const getRandomDelay = () => Math.floor(Math.random() * (5000 - 3000 + 1)) + 3000; // Retorna entre 5000 e 10000 ms
const HISTORICO_DIR = path.join(__dirname, 'historico_usuarios'); // Diretório para históricos
////const DELAY_TIME = 5000; // Tempo de espera para consolidar mensagens//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
const RATE_LIMIT_INTERVAL = 100; // Tempo mínimo entre envios para o Flask (5 segundos)/////////////////////////////////////////////////////////////////////////////////////////////////////
const MAX_MESSAGES_BEFORE_PAUSE = 5; // Número máximo de mensagens antes de pausar/////////////////////////////////////////////////////////////////////////////////////////////////////////
const PAUSE_DURATION = () => Math.floor(Math.random() * (10 - 5 + 1) + 5) * 60 * 1000;; // Duração da pausa em milissegundos (10 minutos)///////////////////////////////////////////////////////////////////////////////////////////////////
const pausedUsersFile = './paused_users.json'; // Arquivo JSON para salvar usuários pausados
let messageBuffers = {}; // Buffer de mensagens por usuário
let timers = {}; // Timers para cada usuário
let processedMessageIds = new Set(); // Conjunto de IDs de mensagens processadas
let lastSentTimes = {}; // Armazena o último envio para cada usuário
let messageCount = 0; // Contador de mensagens enviadas
let isPaused = false; // Flag para indicar pausa
let messageQueue = []; // Fila para armazenar mensagens recebidas durante a pausa


// Função para transcrever áudios usando Whisper (OpenAI)
const transcribeAudio = async (audioFilePath) => {
  try {
    const formData = new FormData();
    formData.append('file', fs.createReadStream(audioFilePath)); // Carrega o áudio
    formData.append('model', 'whisper-1'); // Modelo Whisper

    const response = await axios.post('https://api.openai.com/v1/audio/transcriptions', formData, {
        headers: {
          'Authorization': `_P88EBLoJ89ekDEzmW_PvtiLy7OoihKqorxpQDkRTAIIaZT3BlbkFJWhC62eFgeFPIVMYM9vTv5qx3bsbi1OqPeDfOfWoIiH4etz_qDVIQmmi3alonKV0D5bQ8m7utQA`, // Certifique-se que a chave é válida
          ...formData.getHeaders()
        }
      });
      

    return response.data.text; // Retorna o texto transcrito
  } catch (error) {
    console.error('Erro ao transcrever áudio:', error.response?.data || error.message);
    throw new Error('Falha na transcrição do áudio');
  }
};

// Flag para controlar o bloqueio de resposta por usuário
const stopResponseFlags = loadPausedUsers(); 


// Função para simular um efeito de digitação com duração controlada
async function simulateTypingEffect(client, recipient, message) {
    const typingTime = message.length * 10; // Calcula o tempo de digitação com base no tamanho da mensagem//////////////////////////////////////////////////////////////////////////
  
    const typingInterval = setInterval(() => {
      client.startTyping(recipient); // Inicia a simulação de digitação
    }, 1000);
  
    await new Promise(resolve => setTimeout(resolve, typingTime)); // Aguarda o tempo de digitação
  
    clearInterval(typingInterval); // Para a simulação de digitação
    await client.sendText(recipient, message); // Envia a mensagem
  
    // Marca a conversa como não lida após enviar a resposta
    await client.markUnseenMessage(recipient);
    console.log(`Conversa com o usuário ${recipient} marcada como não lida.`);
  }
  
// Função para carregar usuários pausados do arquivo JSON
function loadPausedUsers() {
  if (fs.existsSync(pausedUsersFile)) {
    const data = fs.readFileSync(pausedUsersFile);
    return JSON.parse(data);
  }
  return {};
}

// Função para salvar usuários pausados no arquivo JSON
function savePausedUsers() {
  fs.writeFileSync(pausedUsersFile, JSON.stringify(stopResponseFlags, null, 2));
}

// Adicione o monitoramento aqui
fs.watchFile(pausedUsersFile, (curr, prev) => {
    console.log('O arquivo paused_users.json foi alterado. Atualizando estados...');
    
    // Carrega os estados atualizados
    const updatedFlags = loadPausedUsers();
  
    // Verifica cada usuário no JSON atualizado
    for (const userId in updatedFlags) {
      if (!updatedFlags[userId] && stopResponseFlags[userId]) {
        // O estado do usuário mudou de pausado para ativo
        console.log(`Usuário ${userId} retomado. Removendo da lista de pausados.`);
        delete stopResponseFlags[userId]; // Atualiza a lista de pausados localmente
      } else if (updatedFlags[userId] && !stopResponseFlags[userId]) {
        // O estado do usuário mudou para pausado
        console.log(`Usuário ${userId} pausado. Adicionando à lista de pausados.`);
        stopResponseFlags[userId] = true;
      }
    }
  
    // Atualiza os estados locais
    Object.assign(stopResponseFlags, updatedFlags);
    console.log('Estados atualizados:', stopResponseFlags);
  });
  


// Inicialização do Venom Bot
venom.create({
  session: 'session-3', //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  browserArgs: ['--no-sandbox', '--disable-setuid-sandbox'],
  headless: 'new',
  executablePath: 'C:\\Program Files\\Google\\Chrome\\Application\\chrome.exe'
}).then((client) => {
  console.log('Venom Bot iniciado com sucesso!');
  start(client);
}).catch((error) => {
  console.error('Erro ao iniciar o Venom Bot:', error);
});

function start(client) {

   client.onAck((ack) => {
    // Verifica se a mensagem enviada é "Ficou alguma dúvida?"
    if (ack.body === 'Ficou alguma dúvida?') {
        const userId = ack.to; // ID do usuário para quem a mensagem foi enviada
        stopResponseFlags[userId] = true; // Ativa a flag de pausa para esse usuário
        savePausedUsers(); // Salva o estado de pausa
        console.log(`Respostas pausadas para o usuário ${userId} após enviar "Ficou alguma dúvida?"`);
    }
  });  
  
  client.onMessage((message) => {
    const user = message.from;

    // Verifica se o bot está pausado
    if (isPaused) {
        console.log(`Bot está pausado. Mensagem de ${user} adicionada à fila.`);
        messageQueue.push(message); // Armazena a mensagem na fila durante a pausa
        return;
    }

    // Verifica a flag de parada antes de responder
    if (stopResponseFlags[user]) {
        console.log(`Respostas pausadas para o usuário ${user}`);
        return;
    }

    // Ignora mensagens de grupos e de status
    if (message.isGroupMsg || message.from === 'status@broadcast') {
        return;
    }

    // Verifica se a mensagem é de mídia
    if (message.type == 'ptt') {
        message.isMedia = true;
        console.log(`Mensagem de mídia recebida de ${user}: ${message.mimetype}`);
    } else {
        console.log(`Mensagem recebida de ${user}: ${message.body || '(sem conteúdo de texto)'}`);
    }

    if (!message.fromMe) {
        if (message.body?.startsWith("P:")) {
            pauseResponses(message.body, user, client);
            return;
        }

        if (message.body?.startsWith("R:")) {
            resumeResponses(message.body, user, client);
            return;
        }

        // Processa a mensagem
        handleUserMessage(message, client);
        messageCount++; // Incrementa o contador de mensagens

        // Verifica se o limite foi atingido
        if (messageCount >= MAX_MESSAGES_BEFORE_PAUSE) {
            console.log(`Limite de ${MAX_MESSAGES_BEFORE_PAUSE} mensagens atingido. Iniciando pausa.`);
            isPaused = true;

            // Inicia a pausa
            setTimeout(() => {
                console.log("Pausa finalizada. Retomando atendimento.");
                isPaused = false;
                messageCount = 0; // Reseta o contador de mensagens

                // Processa as mensagens acumuladas durante a pausa
                processQueuedMessages(client);
            }, PAUSE_DURATION);
        }
    }
});

      

  client.onStateChange((state) => {
    console.log('Estado do cliente:', state);
    if (['CONFLICT', 'UNPAIRED', 'UNLAUNCHED'].includes(state)) {
      console.log('Estado em conflito ou não pareado. Tentando estabilizar a conexão...');
      client.useHere();
    }
  });

  client.onStreamChange((state) => {
    console.log('Estado da conexão:', state);
    if (state === 'DISCONNECTED') {
      console.log('Tentando reconectar...');
      client.restartService();
    }
  });
}

const { exec } = require('child_process'); // Para conversão do áudio

async function handleUserMessage(message, client) {
  const userId = message.from;

  if (processedMessageIds.has(message.id)) {
    console.log(`Mensagem ${message.id} já processada. Ignorando.`);
    return;
  }

  processedMessageIds.add(message.id);

  if (!messageBuffers[userId]) {
    messageBuffers[userId] = [];
  }

  // **Processar áudio enviado pelo usuário**
  if (message.isMedia && message.mimetype.startsWith('audio')) {
    try {
      console.log('Áudio recebido. Baixando...');

      const audioBuffer = await client.decryptFile(message);
      const oggFilePath = path.join(__dirname, `audio-${message.id}.ogg`);
      const mp3FilePath = path.join(__dirname, `audio-${message.id}.mp3`);

      // Salva o áudio como .ogg
      fs.writeFileSync(oggFilePath, audioBuffer);
      console.log('Áudio salvo localmente em formato OGG:', oggFilePath);

      // Converte o áudio de .ogg para .mp3 usando ffmpeg
      await convertAudioToMp3(oggFilePath, mp3FilePath);

      console.log('Áudio convertido para MP3:', mp3FilePath);

      // Transcreve o áudio usando Whisper
      const transcription = await transcribeAudio(mp3FilePath);
      console.log('Transcrição do áudio:', transcription);

     // Adiciona a transcrição ao buffer do usuário
     messageBuffers[userId].push(transcription);

     // Reinicia o timer de envio consolidado
     clearTimeout(timers[userId]);
     timers[userId] = setTimeout(() => {
     sendBufferedMessages(userId, client);
     }, getRandomDelay());


      // Remove os arquivos locais para economizar espaço
      fs.unlinkSync(oggFilePath);
      fs.unlinkSync(mp3FilePath);
    } catch (error) {
      console.error('Erro ao processar áudio:', error.message);
      await client.sendText(userId, 'Desculpe, houve um erro ao processar seu áudio.');
    }
    return; // Saia da função, pois o áudio já foi processado
  }

  // Processar mensagens de texto
  messageBuffers[userId].push(message.body);

  clearTimeout(timers[userId]);
  timers[userId] = setTimeout(() => {
    sendBufferedMessages(userId, client);
  }, getRandomDelay());

  setTimeout(() => {
    processedMessageIds.delete(message.id);
  }, 60000);

  if (processedMessageIds.has(message.id)) {
    console.log(`Mensagem ${message.id} já processada. Ignorando.`);
    return;
  }

  processedMessageIds.add(message.id);

  if (!messageBuffers[userId]) {
    messageBuffers[userId] = [];
  }

  messageBuffers[userId].push(message.body);

  clearTimeout(timers[userId]);
timers[userId] = setTimeout(() => {
  sendBufferedMessages(userId, client);
}, getRandomDelay());


  setTimeout(() => {
    processedMessageIds.delete(message.id);
  }, 60000);
}

// Função para converter áudio de .ogg para .mp3
async function convertAudioToMp3(inputPath, outputPath) {
    return new Promise((resolve, reject) => {
      exec(`ffmpeg -i ${inputPath} -acodec libmp3lame ${outputPath}`, (error) => {
        if (error) {
          console.error('Erro ao converter áudio:', error);
          return reject(error);
        }
        console.log(`Áudio convertido com sucesso para ${outputPath}`);
        resolve();
      });
    });
  }

// Função para enviar mensagens consolidadas ao Flask
async function sendBufferedMessages(userId, client) {
  const currentTime = Date.now();

  if (lastSentTimes[userId] && currentTime - lastSentTimes[userId] < RATE_LIMIT_INTERVAL) {
    console.log(`Bloqueando envio para ${userId} por rate limiting.`);
    return;
  }

  lastSentTimes[userId] = currentTime;

  const messages = messageBuffers[userId].join('\n');
  console.log(`Buffer para envio ao servidor (usuário ${userId}):\n${messages}`);
  delete messageBuffers[userId];
  clearTimeout(timers[userId]);

  const historico = [{ role: 'user', content: messages }];


  const requestData = {
    message: messages,
    user_id: userId,
    message_id: `buffered-${Date.now()}`
  };



  try {
    const response = await axios.post('http://127.0.0.1:5003/gpt', requestData);
    const replies = response.data.responses;

    for (const reply of replies) {
        console.log(`Enviando resposta para ${userId}:`, reply);
        await simulateTypingEffect(client, userId, reply); // Chama a função de simulação de digitação
        historico.push({ role: 'assistant', content: reply });

        // Envia as imagens das 4 praias após mensagem específica
        if (reply.trim().includes("Seguem algumas fotos da Pousada.")) {
          console.log('Correspondência encontrada. Enviando as imagens.');
          const folderPath = path.join(__dirname, 'pousada'); // Caminho dinâmico
          await sendMultipleImages(client, userId, folderPath);
      } 
        if (reply.trim().includes("Só um momento, vou te enviar algumas fotos da Pousada.")) {
          console.log('Correspondência encontrada. Enviando as imagens.');
          const folderPath = path.join(__dirname, 'pousada'); // Caminho dinâmico
          await sendMultipleImages(client, userId, folderPath);  
      }
      

      const pauseTriggers = [
        'Só um momento, vou verificar para você.',
        'Um momento, por favor! Vou transferir você para minha colega, que verificará a disponibilidade e enviará o orçamento.',
        'Só um momento, vou transferir para o setor responsável.',
        'Só um momento, já te passo as informações de pagamento.',
        'Só um momento, vou preparar um pacote especial para vocês que vai tornar essa experiência ainda mais inesquecível.',
        'Ficou alguma dúvida?',
        'Seguem algumas fotos da Pousada.',
      ];
      
      if (pauseTriggers.some(trigger => reply.includes(trigger))) {
        stopResponseFlags[userId] = true;
        savePausedUsers();
        console.log(`Flag de parada ativado para o usuário ${userId}`);
        break;
      }
      
      
    }

    await client.markUnseenMessage(userId);

  } catch (error) {
    console.error(`Erro ao enviar mensagens do usuário ${userId} ao Flask:`, error.message);
    await client.sendText(userId, 'Um momento, por favor! Vou transferir você para minha colega, que verificará a disponibilidade e enviará o orçamento.');
    // Pausa as respostas para o usuário após o erro
    stopResponseFlags[userId] = true;
    savePausedUsers(); // Salva o estado no arquivo JSON
    console.log(`Respostas pausadas para o usuário ${userId} devido ao erro.`);
  }
}

async function processQueuedMessages(client) {
    console.log("Processando mensagens acumuladas na fila...");
    while (messageQueue.length > 0) {
        const message = messageQueue.shift(); // Remove a primeira mensagem da fila
        console.log(`Processando mensagem de ${message.from}: ${message.body || '(sem conteúdo de texto)'}`);
        await handleUserMessage(message, client); // Processa a mensagem normalmente
    }
    console.log("Todas as mensagens acumuladas foram processadas.");
}

// Função para enviar múltiplas imagens
async function sendMultipleImages(client, recipient, folderPath) {
  try {
    const files = fs.readdirSync(folderPath); // Lista todos os arquivos na pasta
    const imageFiles = files.filter(file => /\.(jpg|jpeg|png|gif|mp4)$/i.test(file)); // Filtra apenas imagens

    for (const image of imageFiles) {
      const imagePath = path.join(folderPath, image);
      console.log(`Enviando imagem: ${imagePath} para ${recipient}`);
      const imageNameWithoutExtension = path.parse(image).name; // Extrai o nome do arquivo sem a extensão
      await client.sendImage(recipient, imagePath, image, imageNameWithoutExtension);

      await new Promise(resolve => setTimeout(resolve, 1500)); // Pausa entre os envios
    }

    console.log(`Todas as imagens da pasta ${folderPath} foram enviadas para ${recipient}.`);

    // Envia a mensagem "Ficou alguma dúvida?" após o envio de todas as imagens
    await client.sendText(recipient, 'Ficou alguma dúvida?');
    console.log(`Mensagem de dúvida enviada para ${recipient}`);

  } catch (error) {
    console.error(`Erro ao enviar imagens da pasta ${folderPath}:`, error.message);
  }
}


async function pauseResponses(command, user, client) {
  let userToPause = command.split("P:")[1].trim();
  userToPause = formatUserId(userToPause);

  const historyPath = path.join(HISTORICO_DIR, `${userToPause}.json`);

  if (fs.existsSync(historyPath)) {
    stopResponseFlags[userToPause] = true;
    savePausedUsers();
    console.log(`Respostas para o usuário ${userToPause} foram pausadas via comando.`);
    await client.sendText(user, `Respostas para o usuário ${userToPause} foram pausadas.`);
  } else {
    console.log(`Usuário ${userToPause} não encontrado na pasta de histórico.`);
    await client.sendText(user, `Usuário ${userToPause} não encontrado.`);
  }
}

async function resumeResponses(command, user, client) {
    let userToResume = command.split("R:")[1].trim();
    userToResume = formatUserId(userToResume);
  
    const historyPath = path.join(HISTORICO_DIR, `${userToResume}.json`);
  
    if (fs.existsSync(historyPath)) {
      if (stopResponseFlags[userToResume]) {
        delete stopResponseFlags[userToResume]; // Remove o usuário da lista de pausados
        savePausedUsers(); // Salva a atualização no arquivo JSON
        console.log(`Respostas para o usuário ${userToResume} foram retomadas via comando.`);
        await client.sendText(user, `Respostas para o usuário ${userToResume} foram retomadas.`);
      } else {
        console.log(`Usuário ${userToResume} já estava ativo e recebendo respostas.`);
        await client.sendText(user, `Respostas para o usuário ${userToResume} já estavam ativas.`);
      }
    } else {
      console.log(`Usuário ${userToResume} não encontrado na pasta de históricos.`);
      await client.sendText(user, `Usuário ${userToResume} não encontrado. Verifique se o número está correto.`);
    }
  }
  

function formatUserId(userId) {
  if (!userId.startsWith("55")) {
    userId = "55" + userId;
  }
  if (!userId.includes("@c.us")) {
    userId += "@c.us";
  }
  return userId;
}
Novo contribuidor
Itacatrip é um usuário novo. Seja gentil ao pedir esclarecimentos, comentar, e responder. Consulte nosso Código de Conduta.
1
  • Para que a pergunta possa ser tratada dentro do escopo deste site é importante você editar e fornecer um Exemplo Mínimo, Completo e Verificável do problema que não dependa de nenhuma API externa (por exemplo, simulando dados já baixados de forma que não seja necessário ninguém da comunidade consultar links, e que a pergunta continue válida se a API mudar). Caso seja um problema de entendimento/funcionamento da API e não do algoritmo ou do funcionamento da sua parte do código, já seria o caso de buscar suporte diretamente com o fornecedor da API. Queira consultar a central de ajuda e respectivos links para um melhor proveito do site.
    – Largato
    Commented 1 hora atrás

0

Pesquise outras perguntas com a tag .