Function handler

plugins/mega.ts:38–105

(sock: any, message: any, args: string[], context: BotContext)

    usage: '.mega <mega-url>',

    async handler(sock: any, message: any, args: string[], context: BotContext) {
        const chatId = context.chatId || message.key.remoteJid;
        const text = args.join(' ').trim();

        if (!text) {
            return sock.sendMessage(
                chatId,
                { text: `*Usage:* .mega https://mega.nz/file/xxxx#xxxx` },
                { quoted: message }
            );
        }

        try {
            const file = File.fromURL(text);
            await file.loadAttributes();

            if (((file.size as number) as any) >= 500 * 1024 * 1024) {
                return sock.sendMessage(
                    chatId,
                    { text: '❌ *Error:* File too large (Limit: 500MB)' },
                    { quoted: message }
                );
            }

            const { key } = await sock.sendMessage(chatId, {
                text: `🌩️ *MEGA DOWNLOAD*\n\n▢ *File:* ${file.name}\n▢ *Size:* ${formatBytes(((file.size as number) as number))}\n\n*Progress:* 0% [░░░░░░░░░░]`
            }, { quoted: message });

            const stream = (file as any).download();
            const chunks: Buffer[] = [];
            let lastUpdate = Date.now();

            stream.on('progress', async (info: { bytesLoaded: number; bytesTotal: number }) => {
                const { bytesLoaded, bytesTotal } = info;
                const percentage = Math.floor((bytesLoaded / bytesTotal) * 100);

                if (Date.now() - lastUpdate > 3000 || percentage === 100) {
                    const bar = generateBar(percentage);
                    await sock.sendMessage(chatId, {
                        text: `🌩️ *MEGA DOWNLOAD*\n\n▢ *File:* ${file.name}\n▢ *Size:* ${formatBytes(bytesTotal)}\n\n*Progress:* ${percentage}% [${bar}]`,
                        edit: key
                    });
                    lastUpdate = Date.now();
                }
            });

            stream.on('data', (chunk: Buffer) => chunks.push(chunk));

            stream.on('end', async () => {
                const buffer = Buffer.concat(chunks);
                const ext = path.extname(file.name ?? '').toLowerCase();

                await sock.sendMessage(chatId, {
                    document: buffer,
                    fileName: file.name,
                    mimetype: MIME_TYPES[ext] || 'application/octet-stream',
                    caption: `✅ *Download Complete*\n▢ *File:* ${file.name}\n▢ *Size:* ${formatBytes(((file.size as number) as number))}`
                }, { quoted: message });