رفع ملفات

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148

// commands/لرابط.js
import axios from 'axios';
import FormData from 'form-data';
import { fileTypeFromBuffer } from 'file-type';

async function uploadFile(fileBuffer) {
    try {
        const form = new FormData();
        const fileInfo = await fileTypeFromBuffer(fileBuffer);
        const ext = fileInfo?.ext || 'bin';
        form.append('files[]', fileBuffer, `file.${ext}`);

        const uploadRes = await axios.post('https://uguu.se/upload.php', form, {
            headers: { ...form.getHeaders() },
            timeout: 30000
        });

        if (!uploadRes.data?.files?.[0]?.url) {
            throw new Error('فشل رفع الملف');
        }

        return {
            url: uploadRes.data.files[0].url,
            fileName: uploadRes.data.files[0].name || 'ملف'
        };
    } catch (error) {
        throw new Error(error.message || 'فشل الاتصال');
    }
}

export default {
    name: 'لرابط',
    aliases: ['رفع', 'upload', 'رابط'],
    category: 'tools',
    description: '📤 رفع الملفات إلى Uguu',

    async execute(sock, m, args, { cfg }) {
        const chatJid = m.key.remoteJid;
        const sender = m.key.participant || m.participant || m.key.remoteJid;
        const comando = 'لرابط';

        // ✅ التحقق من النخبة والمطور
        const isOwner = cfg.ownerNumber === sender;
        const isElite = (cfg.eliteNumbers || []).includes(sender);

        if (!isOwner && !isElite) {
            return sock.sendMessage(chatJid, {
                text: cfg.msgs.elite(comando)
            }, { quoted: m });
        }

        // ✅ التحقق من وجود رد
        const quoted = m.message?.extendedTextMessage?.contextInfo?.quotedMessage;
        if (!quoted) {
            return sock.sendMessage(chatJid, {
                text: `📤 *رفع الملفات إلى Uguu*\n\n` +
                      `📌 *الاستخدام:*\n` +
                      `• ارد على صورة/فيديو/ملف\n` +
                      `• اكتب .لرابط`
            }, { quoted: m });
        }

        // ✅ تحديد نوع الملف
        const isImage = quoted.imageMessage;
        const isVideo = quoted.videoMessage;
        const isAudio = quoted.audioMessage;
        const isDocument = quoted.documentMessage;

        if (!isImage && !isVideo && !isAudio && !isDocument) {
            return sock.sendMessage(chatJid, {
                text: '❌ قم بالرد على صورة، فيديو، صوت، أو ملف.'
            }, { quoted: m });
        }

        await sock.sendMessage(chatJid, { react: { text: '⏳', key: m.key } });

        try {
            // ✅ تحميل الميديا
            const { downloadContentFromMessage } = await import('@whiskeysockets/baileys');
            
            let mediaType = 'image';
            let mediaMessage = null;
            
            if (quoted.imageMessage) {
                mediaType = 'image';
                mediaMessage = quoted.imageMessage;
            } else if (quoted.videoMessage) {
                mediaType = 'video';
                mediaMessage = quoted.videoMessage;
            } else if (quoted.audioMessage) {
                mediaType = 'audio';
                mediaMessage = quoted.audioMessage;
            } else if (quoted.documentMessage) {
                mediaType = 'document';
                mediaMessage = quoted.documentMessage;
            }

            if (!mediaMessage) {
                throw new Error('لا يمكن قراءة الملف');
            }

            // ✅ تحميل الملف
            const stream = await downloadContentFromMessage(mediaMessage, mediaType);
            let buffer = Buffer.from([]);
            for await (const chunk of stream) {
                buffer = Buffer.concat([buffer, chunk]);
            }

            if (!buffer || buffer.length < 100) {
                throw new Error('فشل تحميل الملف');
            }

            // ✅ تحديد نوع الملف
            const fileInfo = await fileTypeFromBuffer(buffer);
            const mimeType = fileInfo?.mime || mediaMessage.mimetype || 'application/octet-stream';

            // ✅ رفع الملف
            const result = await uploadFile(buffer);

            if (result?.url) {
                const size = buffer.length;
                const sizeFormatted = size > 1024 * 1024 
                    ? `${(size / (1024 * 1024)).toFixed(2)} MB`
                    : `${(size / 1024).toFixed(2)} KB`;

                await sock.sendMessage(chatJid, {
                    text: `✅ *تم الرفع بنجاح*\n\n` +
                          `📦 *الملف:* ${result.fileName || 'ملف'}\n` +
                          `📂 *النوع:* ${mimeType}\n` +
                          `📊 *الحجم:* ${sizeFormatted}\n` +
                          `🔗 *الرابط:* ${result.url}`
                }, { quoted: m });

                await sock.sendMessage(chatJid, { react: { text: '✅', key: m.key } });
            } else {
                throw new Error('لم يتم العثور على رابط');
            }

        } catch (error) {
            console.error('❌ Upload Error:', error);
            await sock.sendMessage(chatJid, { react: { text: '❌', key: m.key } });
            await sock.sendMessage(chatJid, {
                text: `❌ *خطأ:* ${error.message}`
            }, { quoted: m });
        }
    }
};