Main.py

[mnx913327-max]

{
"name": "wa-tg-hybrid-bot",
"version": "1.0.0",
"type": "module",
"main": "index.js",
"dependencies": {
"@whiskeysockets/baileys": "^6.5.0",
"telegraf": "^4.15.3",
"openai": "^4.24.1",
"pino": "^8.16.2",
"qrcode-terminal": "^0.12.0"
},
"scripts": {
"start": "node index.js"
}
}

[khalualakshman-collab]

KnightBot!H4sIAAAAAAAAA5VU25KiSBT8l3rVGC4iIBEdMUiDIt5QodGNeSihgFLuVSA44b9vYE/PzMPubO9bcajIkyczT30HWY4JslAHlO+gqHADKeqPtCsQUMC0DkNUgSEIIIVAARtzX6dvhr7fawHRm/Z+W5nI3DGWLenTpET5pLrePc3wdPYFPIagqM8J9v8AyCIbjg5jec2xKhTUsJvqwmC0cZk6XoxGE55lz2paqCKrmS/g0SNCXOEs0osYpaiCiYW6LcTV5+iT6fpGu+XGnYXXxUItPSTPyzoKzZN0bg2jvKhWkr+17WZufo7+bV2LBwJH5SHFi8MbtS6JOikzRiz5NnF281Ecr18X40Hdyu/0CY4yFJgByiim3ad1F7Yav9SzUm9nPNskPDUDZ9DdDvnd2oqTeIu17pDOBsFJjz5HvB10znUccpZvXBod3wrK1EEe38yBvaqd8f6CV7YlcruYu/1OfFt9ZOX6f3QXp2sxy5NyFp/E6EpvRhls803oxbAjgZFOSj4Lk0shzrnj5+i7EeRl/5Rzp3bqI+PqpjvC1MzV2mW8FDBahpvGc6xDmB1/0Ye0rv7EcmoJh7jt1qXB4TZNHW5e6JuWse+SmATRmBz0FtYD39O702ZZQFnjV7S61PLucjLZ3dgcF52PU/YYuW153s6N6cY2oujlOdEVdWYAFO4xBBWKMKEVpDjPnjVBHgIYNHvkV4g+5QXHW7M6R6GLiIFnr5Nuwa+s84RZVtdIOF4z21IDYT7l3ZvrvIAhKKrcR4SgYI4JzatuhQiBESJA+evbEGSope/G9e1G3BCEuCLUyeoiyWHw4erHT+j7eZ3RfZf5Wn9AFVDYX2VEKc4i0utYZ7DyY9wgLYaUACWECUE/J0QVCoBCqxr93FotD3rhj6K0XIxmr2AI0qchOAAKmHDSiJuMJHkssYr8lXy59aiwKL5kiIIhSJ63+NFEFlheHnMTUWBHivy1rz9+8uvhAkQhTghQgLZ9M8XkZt/FbnuPjkd1r6qWqvaafczzEYx34d1Xp2rWRujKtNk31CdkM/Oa82xU0YZnpJ0YzjyKL9kEO/8EAhRgxEtPaq/yupwuG9/U7IAM6g3z6q071pu45KRT23k7MCE7uIYd0Q9WEDP35KidvJS6A2wE6QSKM2lpXjV251mhIZSa/dJ3C1CDffR7M33mRMvWQ1knIWGxWjh3fN1KQusVvqtqb4ldnsVtYTob7cBkhdzsEtxoA6OwgkysfZYcWuaYq6TeRs5ccOmi6mw/st8j+1yZ5MdThZ9h6p3qP0OMnpufwd6//3TunXefL/Yx/A3ix1Pyb+vo2pwl3XceFy7PbCV5y+VrnEh8S0XpPGkGLMraRDrmY+aYgMfj2xAUCaRhXqVAATALqhwHYAiqvO4Da2Zh/odmmmqaUzta94MnkFD11xIccIoIhWkBFE6SBEHgWVF6v7Wt8mIOSQwUMEoT7rIHj78B4XmftVIHAAA=

[mnx913327-max]

import { OpenAI } from "openai";
import { Telegraf } from "telegraf";
import makeWASocket, {
useMultiFileAuthState,
DisconnectReason,
getContentType
} from "@whiskeysockets/baileys";
import pino from "pino";

// --- Configuration ---
const TG_TOKEN = process.env.BOT_TOKEN;
const HF_TOKEN = process.env.HF_TOKEN;

const tgBot = new Telegraf(TG_TOKEN);
const client = new OpenAI({
baseURL: "https://router.huggingface.co/v1",
apiKey: HF_TOKEN,
});

// Cache for .Deletephoto (In-memory for Render's ephemeral disk)
const mediaCache = new Map();

async function startBot() {
const { state, saveCreds } = await useMultiFileAuthState('auth_info_baileys');

const sock = makeWASocket.default({
    auth: state,
    printQRInTerminal: false, // Using Pairing Code instead
    logger: pino({ level: 'silent' })
});

sock.ev.on('creds.update', saveCreds);

// --- 1. Pairing System via Telegram ---
tgBot.command('pair', async (ctx) => {
    const phone = ctx.message.text.split(' ')[1];
    if (!phone) return ctx.reply("Usage: /pair 1234567890");
    
    try {
        const code = await sock.requestPairingCode(phone);
        ctx.reply(`Your WhatsApp Pairing Code is: ${code}\n\nLink this in: Linked Devices -> Link with Phone Number.`);
    } catch (err) {
        ctx.reply("Error generating code. Ensure the number includes country code.");
    }
});

// --- 2, 3, 4. WhatsApp Logic ---
sock.ev.on('messages.upsert', async ({ messages }) => {
    const m = messages[0];
    if (!m.message || m.key.fromMe) return;

    const remoteJid = m.key.remoteJid;
    const isGroup = remoteJid.endsWith('@g.us');
    const body = m.message.conversation || m.message.extendedTextMessage?.text || "";

    // Link Protection (Security)
    if (isGroup && /(https?:\/\/|wa\.me)/.test(body)) {
        const metadata = await sock.groupMetadata(remoteJid);
        const isAdmin = metadata.participants.find(p => p.id === m.key.participant)?.admin;
        
        if (!isAdmin) {
            await sock.sendMessage(remoteJid, { delete: m.key });
            await sock.groupParticipantsUpdate(remoteJid, [m.key.participant], "remove");
            await sock.sendMessage(remoteJid, { text: "User removed for sharing unauthorized links." });
        }
    }

    // Tag All (.Menu)
    if (body === ".Menu") {
        const metadata = await sock.groupMetadata(remoteJid);
        if (m.key.participant !== metadata.owner) return;

        const participants = metadata.participants.map(p => p.id);
        await sock.sendMessage(remoteJid, { 
            text: `📢 *Admin Broadcast*\nGroup: ${metadata.subject}`, 
            mentions: participants 
        });
    }

    // Cache Media for Recovery
    const type = getContentType(m.message);
    if (type === 'imageMessage') {
        mediaCache.set(remoteJid, m.message.imageMessage);
    }

    // .Deletephoto Recovery
    if (body === ".Deletephoto") {
        const lastPhoto = mediaCache.get(remoteJid);
        if (lastPhoto) {
            await sock.sendMessage(remoteJid, { image: lastPhoto, caption: "Recovered Photo" });
        }
    }
});

// --- 5. Onboarding ---
sock.ev.on('group-participants.update', async (anu) => {
    if (anu.action === 'add') {
        await sock.sendMessage(anu.id, { 
            text: "Welcome to the group! Please read the rules to avoid being removed by the system." 
        });
    }
});

tgBot.launch();
console.log("Telegram Control Center Active.");

}

startBot();