Function handler

plugins/rle.ts:30–201

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

    usage: '.rle compress <text or reply to media>\n.rle decompress <encoded or reply to compressed file>',

    async handler(sock: any, message: any, args: any[], context: BotContext) {
        const { chatId, channelInfo } = context;

        const quoted = getQuoted(message);
        const quotedText = quoted?.conversation || quoted?.extendedTextMessage?.text || '';
        const mediaType = getMediaType(quoted);

        if (!args.length) {
            return await sock.sendMessage(chatId, {
                text: `🗜️ *RLE Compressor*\n\n` +
                      `*Text:*\n` +
                      `\`.rle compress AAABBBCCDDDD\`\n` +
                      `\`.rle decompress <encoded>\`\n\n` +
                      `*File/Media (reply to any file or media):*\n` +
                      `\`.rle compress\` — reply to image/video/audio/doc\n` +
                      `\`.rle decompress\` — reply to .rle compressed file\n\n` +
                      `⚠️ RLE works best on data with repeated bytes.\n` +
                      `For photos/videos, compression may increase size.`,
                ...channelInfo
            }, { quoted: message });
        }

        const mode = args[0]?.toLowerCase();
        if (mode !== 'compress' && mode !== 'decompress') {
            return await sock.sendMessage(chatId, {
                text: `❌ Use \`compress\` or \`decompress\``,
                ...channelInfo
            }, { quoted: message });
        }

        const binPath = path.join(process.cwd(), 'lib', 'bin', 'rle');
        if (!fs.existsSync(binPath)) {
            return await sock.sendMessage(chatId, {
                text: `❌ RLE binary not available on this server (g++ not installed).`,
                ...channelInfo
            }, { quoted: message });
        }

        const tempDir = path.join(process.cwd(), 'temp');
        fs.mkdirSync(tempDir, { recursive: true });
        const id = Date.now();

        try {
            if (mode === 'compress') {
                let inputBuffer: Buffer;
                let sourceLabel: string;
                let originalName = `file_${id}`;

                if (mediaType && quoted) {
                    await sock.sendMessage(chatId, { text: '⏳ Downloading media...', ...channelInfo }, { quoted: message });
                    const msgObj = { message: { [`${mediaType}Message`]: quoted[`${mediaType}Message`] } };
                    inputBuffer = await downloadMediaMessage(msgObj as any, 'buffer', {} as any) as Buffer;
                    sourceLabel = `${mediaType} (${inputBuffer.length.toLocaleString()} bytes)`;
                    originalName = `${mediaType}_${id}`;
                } else {
                    const textInput = args.slice(1).join(' ').trim() || quotedText;
                    if (!textInput) {
                        return await sock.sendMessage(chatId, {