Arman_king

[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"
}
}

[mnx913327-max]

Y

[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();