Function handler

plugins/analyze.js:39–138

(sock, message, args, context)

    description: 'Deep text analysis: reading level, sentiment, word stats (C++ powered)',
    usage: '.analyze <text or reply to any message/file>',
    async handler(sock, message, args, context) {
        const { chatId, channelInfo } = context;
        const binPath = getBin('analyze');
        if (!fs.existsSync(binPath)) {
            return await sock.sendMessage(chatId, {
                text: `❌ Analyze binary not available on this server (g++ not installed or not yet compiled).`,
                ...channelInfo
            }, { quoted: message });
        }
        const quoted = getQuoted(message);
        const quotedText = quoted?.conversation || quoted?.extendedTextMessage?.text || '';
        const hasDoc = !!quoted?.documentMessage;
        const textInput = args.join(' ').trim() || quotedText;
        if (!textInput && !hasDoc) {
            return await sock.sendMessage(chatId, {
                text: `📈 *Text Analyzer*\n\n` +
                    `*Usage:* \`.analyze <paste any text>\`\n\n` +
                    `*Or reply to:*\n` +
                    `• Any text message\n` +
                    `• A .txt or document file\n\n` +
                    `*Output includes:*\n` +
                    `📊 Word/sentence/paragraph count\n` +
                    `📖 Flesch Reading Ease score & level\n` +
                    `😊 Sentiment analysis (positive/negative/neutral)\n` +
                    `⏱️ Reading time estimate\n` +
                    `🏆 Top 20 keywords`,
                ...channelInfo
            }, { quoted: message });
        }
        await sock.sendMessage(chatId, { text: '🔍 Analyzing...', ...channelInfo }, { quoted: message });
        const tempDir = path.join(process.cwd(), 'temp');
        fs.mkdirSync(tempDir, { recursive: true });
        const id = Date.now();
        try {
            let stdout;
            if (hasDoc && quoted) {
                const msgObj = { message: { documentMessage: quoted.documentMessage } };
                const buf = await downloadMediaMessage(msgObj, 'buffer', {});
                const tmpFile = path.join(tempDir, `analyze_in_${id}.txt`);
                fs.writeFileSync(tmpFile, buf);
                const result = await execAsync(`"${binPath}" --file "${tmpFile}"`, { timeout: 30000 });
                stdout = result.stdout;
                try {
                    fs.unlinkSync(tmpFile);
                }
                catch { }
            }
            else {
                const tmpFile = path.join(tempDir, `analyze_in_${id}.txt`);
                fs.writeFileSync(tmpFile, textInput);
                const result = await execAsync(`"${binPath}" --file "${tmpFile}"`, { timeout: 30000 });
                stdout = result.stdout;
                try {
                    fs.unlinkSync(tmpFile);
                }
                catch { }
            }
            const data = JSON.parse(stdout.trim());