// src/server.js
import venom from 'venom-bot';
import express from 'express';
const app = express();
const PORT = 3000;
app.use(express.json());
let clientInstance = null;
// Inicia o Venom
venom
.create({
session: 'bot',
headless: true,
})
.then((client) => {
clientInstance = client;
console.log('Bot iniciado com sucesso');
})
.catch((error) => console.log('Erro ao iniciar o bot:', error));
// Endpoint para envio de mensagem
app.post('/send', async (req, res) => {
const { number, message } = req.body;
if (!clientInstance) {
return res.status(503).json({ error: 'Cliente ainda não iniciado' });
}
if (!number || !message) {
return res.status(400).json({ error: 'Número e mensagem são obrigatórios' });
}
try {
const formattedNumber = ${number}@c.us;
await clientInstance.sendText(formattedNumber, message);
res.json({ success: true, message: 'Mensagem enviada com sucesso' });
} catch (err) {
console.error('Erro ao enviar mensagem:', err);
res.status(500).json({ error: 'Erro ao enviar mensagem' });
}
});
// Inicia o servidor Express
app.listen(PORT, () => {
console.log(Servidor Express rodando em http://localhost:${PORT});
});
// src/server.js
import venom from 'venom-bot';
import express from 'express';
const app = express();
const PORT = 3000;
app.use(express.json());
let clientInstance = null;
// Inicia o Venom
venom
.create({
session: 'bot',
headless: true,
})
.then((client) => {
clientInstance = client;
console.log('Bot iniciado com sucesso');
})
.catch((error) => console.log('Erro ao iniciar o bot:', error));
// Endpoint para envio de mensagem
app.post('/send', async (req, res) => {
const { number, message } = req.body;
if (!clientInstance) {
return res.status(503).json({ error: 'Cliente ainda não iniciado' });
}
if (!number || !message) {
return res.status(400).json({ error: 'Número e mensagem são obrigatórios' });
}
try {
const formattedNumber =
${number}@c.us;await clientInstance.sendText(formattedNumber, message);
res.json({ success: true, message: 'Mensagem enviada com sucesso' });
} catch (err) {
console.error('Erro ao enviar mensagem:', err);
res.status(500).json({ error: 'Erro ao enviar mensagem' });
}
});
// Inicia o servidor Express
app.listen(PORT, () => {
console.log(
Servidor Express rodando em http://localhost:${PORT});});