143 lines
3.9 KiB
JavaScript
143 lines
3.9 KiB
JavaScript
const { default: makeWASocket, useMultiFileAuthState, DisconnectReason, fetchLatestBaileysVersion, proto, generateWAMessageFromContent, generateWAMessageContent } = require('@fizzxydev/baileys-pro');
|
|
const express = require('express');
|
|
const { Boom } = require('@hapi/boom');
|
|
const qrcode = require('qrcode');
|
|
const path = require('path');
|
|
const fs = require('fs');
|
|
|
|
const app = express();
|
|
app.use(express.json());
|
|
app.use(express.static('public'));
|
|
|
|
let sock;
|
|
let qrData = null;
|
|
let isConnected = false;
|
|
|
|
const initBaileys = async () => {
|
|
const { version } = await fetchLatestBaileysVersion();
|
|
const { state, saveCreds } = await useMultiFileAuthState('auth');
|
|
|
|
sock = makeWASocket({
|
|
version,
|
|
auth: state,
|
|
printQRInTerminal: false
|
|
});
|
|
|
|
sock.ev.on('connection.update', async (update) => {
|
|
const { connection, lastDisconnect, qr } = update;
|
|
if (qr) {
|
|
qrData = await qrcode.toDataURL(qr);
|
|
isConnected = false;
|
|
}
|
|
if (connection === 'close') {
|
|
const shouldReconnect = lastDisconnect?.error?.output?.statusCode !== DisconnectReason.loggedOut;
|
|
if (shouldReconnect) {
|
|
console.log('🔁 Reconnexion...');
|
|
initBaileys();
|
|
} else {
|
|
console.log('❌ Déconnecté.');
|
|
}
|
|
} else if (connection === 'open') {
|
|
console.log('✅ Connecté à WhatsApp');
|
|
isConnected = true;
|
|
}
|
|
});
|
|
|
|
sock.ev.on('creds.update', saveCreds);
|
|
};
|
|
|
|
async function generateMediaMessage(sock, type, url) {
|
|
const generated = await generateWAMessageContent(
|
|
{ [type]: { url } },
|
|
{ upload: sock.waUploadToServer }
|
|
);
|
|
return generated[`${type}Message`];
|
|
}
|
|
|
|
async function sendInteractive(sock, jid, imageUrl) {
|
|
const imageMsg = await generateMediaMessage(sock, 'image', imageUrl);
|
|
|
|
const content = {
|
|
viewOnceMessage: {
|
|
message: {
|
|
messageContextInfo: {
|
|
deviceListMetadata: {},
|
|
deviceListMetadataVersion: 2,
|
|
},
|
|
interactiveMessage: proto.Message.InteractiveMessage.create({
|
|
body: { text: 'Quel produit vous intéresse ?' },
|
|
footer: { text: 'Répondez via un bouton' },
|
|
header: {
|
|
title: 'Menu produits',
|
|
hasMediaAttachment: true,
|
|
imageMessage: imageMsg,
|
|
},
|
|
nativeFlowMessage: {
|
|
buttons: [
|
|
{
|
|
name: 'quick_reply',
|
|
buttonParamsJson: JSON.stringify({
|
|
display_text: '📦 Voir produits',
|
|
id: '.produits',
|
|
}),
|
|
},
|
|
{
|
|
name: 'ctl_url',
|
|
buttonParamsJson: JSON.stringify({
|
|
display_text: '🛒 Visiter boutique',
|
|
url: 'https://canguidev.fr',
|
|
merchant_url: 'https://canguidev.fr',
|
|
}),
|
|
},
|
|
],
|
|
},
|
|
}),
|
|
},
|
|
},
|
|
};
|
|
|
|
const msg = generateWAMessageFromContent(jid, content, {});
|
|
await sock.relayMessage(jid, msg.message, { messageId: msg.key.id });
|
|
}
|
|
|
|
initBaileys();
|
|
|
|
app.get('/login', (req, res) => {
|
|
res.sendFile(path.join(__dirname, 'public', 'login.html'));
|
|
});
|
|
|
|
app.get('/api/qrcode', (req, res) => {
|
|
res.json({ qr: qrData, connected: isConnected });
|
|
});
|
|
|
|
app.post('/sendText', async (req, res) => {
|
|
const { phone, message } = req.body;
|
|
if (!sock || !isConnected) return res.status(400).json({ error: 'Non connecté' });
|
|
try {
|
|
await sock.sendMessage(`${phone}@s.whatsapp.net`, { text: message });
|
|
res.json({ success: true });
|
|
} catch (e) {
|
|
res.status(500).json({ error: e.message });
|
|
}
|
|
});
|
|
|
|
app.post('/sendButtons', async (req, res) => {
|
|
sock.sendMessage(jid, {
|
|
text: "Hello World !",
|
|
footer: "Fizzxy - 2025",
|
|
buttons: [
|
|
{
|
|
buttonId: `🚀`,
|
|
buttonText: {
|
|
displayText: '🗿'
|
|
},
|
|
type: 1
|
|
}
|
|
],
|
|
headerType: 1,
|
|
viewOnce: true
|
|
},{ quoted: null })
|
|
});
|
|
|
|
app.listen(3001, () => console.log('🚀 Serveur Baileys démarré sur http://localhost:3001'));
|