Spaces:
Sleeping
Sleeping
File size: 4,038 Bytes
1d1373f |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 |
import { default as makeWASocket, DisconnectReason, useMultiFileAuthState, makeInMemoryStore } from '@whiskeysockets/baileys';
import express from 'express';
import qrcode from 'qrcode-terminal';
import pino from 'pino';
const app = express();
app.use(express.json());
let sock = null;
let qrCode = null;
let isConnected = false;
const logger = pino({ level: 'silent' });
// Initialize WhatsApp connection
async function connectToWhatsApp() {
const { state, saveCreds } = await useMultiFileAuthState('auth_info');
sock = makeWASocket({
auth: state,
printQRInTerminal: true,
logger,
});
sock.ev.on('creds.update', saveCreds);
sock.ev.on('connection.update', (update) => {
const { connection, lastDisconnect, qr } = update;
if (qr) {
qrCode = qr;
console.log('QR Code received, scan it!');
qrcode.generate(qr, { small: true });
}
if (connection === 'close') {
const shouldReconnect = lastDisconnect?.error?.output?.statusCode !== DisconnectReason.loggedOut;
console.log('Connection closed. Reconnecting:', shouldReconnect);
isConnected = false;
if (shouldReconnect) {
connectToWhatsApp();
}
} else if (connection === 'open') {
console.log('✅ WhatsApp connected successfully!');
isConnected = true;
qrCode = null;
}
});
sock.ev.on('messages.upsert', async (m) => {
const msg = m.messages[0];
if (!msg.key.fromMe && m.type === 'notify') {
console.log('New message:', msg.message?.conversation || 'Media message');
}
});
}
// Routes
app.get('/', (req, res) => {
res.json({
status: 'running',
connected: isConnected,
endpoints: {
status: 'GET /status',
qr: 'GET /qr',
send: 'POST /send',
logout: 'POST /logout'
}
});
});
app.get('/status', (req, res) => {
res.json({
connected: isConnected,
hasQR: qrCode !== null
});
});
app.get('/qr', (req, res) => {
if (qrCode) {
res.json({
success: true,
qr: qrCode,
message: 'Scan this QR code with WhatsApp'
});
} else if (isConnected) {
res.json({
success: false,
message: 'Already connected to WhatsApp'
});
} else {
res.json({
success: false,
message: 'QR code not available yet, please wait...'
});
}
});
app.post('/send', async (req, res) => {
if (!isConnected || !sock) {
return res.status(400).json({
success: false,
message: 'WhatsApp not connected'
});
}
const { number, message } = req.body;
if (!number || !message) {
return res.status(400).json({
success: false,
message: 'number and message are required'
});
}
try {
// Format number (add @s.whatsapp.net if not present)
const jid = number.includes('@') ? number : `${number}@s.whatsapp.net`;
await sock.sendMessage(jid, { text: message });
res.json({
success: true,
message: 'Message sent successfully'
});
} catch (error) {
res.status(500).json({
success: false,
message: error.message
});
}
});
app.post('/logout', async (req, res) => {
if (sock) {
await sock.logout();
isConnected = false;
qrCode = null;
res.json({ success: true, message: 'Logged out successfully' });
} else {
res.json({ success: false, message: 'Not connected' });
}
});
// Start server
const PORT = process.env.PORT || 7860;
app.listen(PORT, '0.0.0.0', () => {
console.log(`🚀 Baileys WhatsApp Server running on port ${PORT}`);
connectToWhatsApp();
}); |