Function igsCommand

commands/igs.js:187–270

(sock, chatId, message, crop = false)

}

async function igsCommand(sock, chatId, message, crop = false) {
    try {
        const text = message.message?.conversation || message.message?.extendedTextMessage?.text || '';
        const urlMatch = text.match(/https?:\/\/\S+/);
        if (!urlMatch) {
            await sock.sendMessage(chatId, { text: `Send an Instagram post/reel link.\nUsage:\n.igs <url>\n.igsc <url>` }, { quoted: message });
            return;
        }

        await sock.sendMessage(chatId, { react: { text: '🔄', key: message.key } });

        const downloadData = await igdl(urlMatch[0]).catch(() => null);
        if (!downloadData || !downloadData.data) {
            await sock.sendMessage(chatId, { text: '❌ Failed to fetch media from Instagram link.' }, { quoted: message });
            return;
        }
        // Raw items
        const rawItems = (downloadData?.data || []).filter(m => m && m.url);
        // Deduplicate by exact URL first
        const seenUrls = new Set();
        const items = [];
        for (const m of rawItems) {
            if (!seenUrls.has(m.url)) {
                seenUrls.add(m.url);
                items.push(m);
            }
        }
        if (items.length === 0) {
            await sock.sendMessage(chatId, { text: '❌ No media found at the provided link.' }, { quoted: message });
            return;
        }

        // Process up to 10 media items to avoid spam/timeouts
        const maxItems = Math.min(items.length, 10);
        const seenHashes = new Set();
        for (let i = 0; i < maxItems; i++) {
            try {
                const media = items[i];
                const mediaUrl = media.url;
                const isVideo = (media?.type === 'video') || /\.(mp4|mov|avi|mkv|webm)$/i.test(mediaUrl);

                const buffer = await fetchBufferFromUrl(mediaUrl);

                // Content-based dedupe: skip if identical media already processed
                const hash = require('crypto').createHash('sha1').update(buffer).digest('hex');
                if (seenHashes.has(hash)) {
                    continue;
                }
                seenHashes.add(hash);

                let stickerBuffer = crop
                    ? await stickercropFromBuffer(buffer, isVideo)
                    : await convertBufferToStickerWebp(buffer, isVideo, false);

                // Ensure final size under ~900KB; otherwise try a harsher mini fallback
                let finalSticker = stickerBuffer;
                if (finalSticker.length > 900 * 1024) {
                    try {