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;
}