Update bot.js

bot.js

@@ -1,27 +1,16 @@
 // ============================================================
-// 🌐 NETWORK FIX FOR HUGGING FACE (Force IPv4)
-// ============================================================
-const dns = require('dns');
-dns.setDefaultResultOrder('ipv4first');
-
-// ============================================================
-// 🪄 HUGGING FACE KEEP-ALIVE TRICK
-// ============================================================
-
-
-// ... (the rest of your code stays exactly the same)
-// ============================================================
-// 🪄 HUGGING FACE KEEP-ALIVE TRICK
+// 🪄 HUGGING FACE KEEP-ALIVE TRICK (Explicit 0.0.0.0 bind)
 // ============================================================
 const http = require('http');
 const server = http.createServer((req, res) => {
     res.writeHead(200, { 'Content-Type': 'text/plain' });
     res.end('Lecture Downloader Bot is alive and running on Hugging Face!');
 });
-server.listen(7860, () => console.log('🌐 Web server running on port 7860 (Hugging Face Requirement)'));
+// Explicitly binding to 0.0.0.0 is critical for Hugging Face network routing
+server.listen(7860, '0.0.0.0', () => console.log('🌐 Web server running on 0.0.0.0:7860'));
 
 // ============================================================
-// 🤖 BOT CODE
+// 🤖 BOT LIBRARIES
 // ============================================================
 const TelegramBot = require('node-telegram-bot-api');
 const axios = require('axios');
@@ -33,26 +22,11 @@ const FormData = require('form-data');
 // ============================================================
 // ⚙️ CONFIGURATION
 // ============================================================
-const TOKEN = '8548617432:AAHAe65kcsDv30c0YnG4nZasQT5dasBw9aU'; 
+const TOKEN = '8476068831:AAG9mEiMYhlIOEBYSy2P11V88NePwrJh06w'; 
 const OWNER_USERNAME = 'silent000666'; 
-
-// Banner Image
 const BANNER_URL = 'https://img.freepik.com/free-vector/laptop-with-program-code-isometric-icon-software-development-programming-applications-dark-neon_39422-971.jpg';
-
-// Initialize
-// Initialize with strict IPv4 Network enforcement
-const bot = new TelegramBot(TOKEN, { 
-    polling: true,
-    request: {
-        agentOptions: {
-            family: 4  // Strictly forces IPv4 at the socket level
-        }
-    }
-});
 const userState = {}; 
 
-console.log('🚀 GOFILE BOT STARTED...');
-
 // ============================================================
 // 📝 LOGGER
 // ============================================================
@@ -66,171 +40,158 @@ function log(message) {
 }
 
 // ============================================================
-// 🎮 HANDLERS
+// 🚀 DELAYED BOOT SEQUENCE (The Network Fix)
 // ============================================================
-bot.onText(/\/start/, async (msg) => {
-    userState[msg.chat.id] = null;
-    await bot.sendPhoto(msg.chat.id, BANNER_URL, {
-        caption: `👋 *Welcome, ${msg.from.first_name}*\n\nI am your **Lecture Downloader**.\n\n🔹 **Modes:**\n• < 50MB: Direct Telegram File\n• > 50MB: High-Speed Gofile Link\n\n_Click below to start:_`,
-        parse_mode: 'Markdown',
-        reply_markup: {
-            inline_keyboard: [
-                [{ text: "🚀 Start Extraction", callback_data: "btn_extract" }]
-            ]
-        }
-    });
-});
+console.log("⏳ Waiting 5 seconds for Hugging Face DNS to stabilize...");
 
-bot.on('callback_query', async (q) => {
-    const chatId = q.message.chat.id;
-    bot.answerCallbackQuery(q.id);
-
-    if (q.data === 'btn_extract') {
-        userState[chatId] = 'WAITING_URL';
-        await bot.sendMessage(chatId, "🔗 *Send the Lecture Link now.*", {
-            reply_markup: { inline_keyboard: [[{ text: "❌ Cancel", callback_data: "btn_cancel" }]] }
+setTimeout(() => {
+    console.log("🚀 Network Ready! Booting Telegram Bot...");
+    
+    const bot = new TelegramBot(TOKEN, { polling: true });
+
+    // Stop errors from crashing the bot
+    bot.on("polling_error", (err) => log(`[Polling Error] ${err.message}`));
+
+    // ============================================================
+    // 🎮 HANDLERS
+    // ============================================================
+    bot.onText(/\/start/, async (msg) => {
+        userState[msg.chat.id] = null;
+        await bot.sendPhoto(msg.chat.id, BANNER_URL, {
+            caption: `👋 *Welcome, ${msg.from.first_name}*\n\nI am your **Lecture Downloader**.\n\n🔹 **Modes:**\n• < 50MB: Direct Telegram File\n• > 50MB: High-Speed Gofile Link\n\n_Click below to start:_`,
+            parse_mode: 'Markdown',
+            reply_markup: {
+                inline_keyboard: [
+                    [{ text: "🚀 Start Extraction", callback_data: "btn_extract" }]
+                ]
+            }
         });
-    }
-    else if (q.data === 'btn_cancel') {
-        userState[chatId] = null;
-        bot.deleteMessage(chatId, q.message.message_id);
-    }
-});
-
-bot.on('message', async (msg) => {
-    const chatId = msg.chat.id;
-    const text = msg.text;
+    });
 
-    if (!text || text.startsWith('/') || userState[chatId] !== 'WAITING_URL') return;
+    bot.on('callback_query', async (q) => {
+        const chatId = q.message.chat.id;
+        bot.answerCallbackQuery(q.id);
 
-    userState[chatId] = null;
-    if (!text.startsWith('http')) return bot.sendMessage(chatId, "⚠️ Invalid Link.");
+        if (q.data === 'btn_extract') {
+            userState[chatId] = 'WAITING_URL';
+            await bot.sendMessage(chatId, "🔗 *Send the Lecture Link now.*", {
+                reply_markup: { inline_keyboard: [[{ text: "❌ Cancel", callback_data: "btn_cancel" }]] }
+            });
+        }
+        else if (q.data === 'btn_cancel') {
+            userState[chatId] = null;
+            bot.deleteMessage(chatId, q.message.message_id);
+        }
+    });
 
-    // RESET LOG
-    fs.writeFileSync(LOG_FILE, `--- NEW PROCESS STARTED ---\n`);
-    log(`User sent link: ${text}`);
+    bot.on('message', async (msg) => {
+        const chatId = msg.chat.id;
+        const text = msg.text;
 
-    const processMsg = await bot.sendMessage(chatId, "🕵️‍♂️ *Starting Process...*\n_Analyzing..._", { parse_mode: 'Markdown' });
+        if (!text || text.startsWith('/') || userState[chatId] !== 'WAITING_URL') return;
 
-    try {
-        // --- STEP 1: ANALYZE URL ---
-        log("STEP 1: Analyzing URL...");
-        let streamUrl = text;
-        let cookieString = "";
-        let userAgent = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64)';
+        userState[chatId] = null;
+        if (!text.startsWith('http')) return bot.sendMessage(chatId, "⚠️ Invalid Link.");
 
-        try {
-            const res = await axios.get(text, { headers: { 'User-Agent': userAgent }, timeout: 15000 });
-            
-            if (res.headers['set-cookie']) {
-                cookieString = res.headers['set-cookie'].map(c => c.split(';')[0]).join('; ');
-            }
+        fs.writeFileSync(LOG_FILE, `--- NEW PROCESS STARTED ---\n`);
+        log(`User sent link: ${text}`);
 
-            // Regex Check
-            const match = res.data.match(/src:\s*'(\/Stream\/Index\/[^']+)'/);
-            if (match) {
-                streamUrl = `https://vss-v2-app.techsol360.com${match[1]}`;
-                log(`✅ Found HIDDEN Stream URL`);
-            } 
-        } catch (e) {
-            log(`⚠️ Scrape Error: ${e.message} (Using original link)`);
-        }
+        const processMsg = await bot.sendMessage(chatId, "🕵️‍♂️ *Starting Process...*\n_Analyzing..._", { parse_mode: 'Markdown' });
 
-        // --- STEP 2: DOWNLOAD ---
-        log("STEP 2: Starting FFmpeg Download...");
-        await bot.editMessageText(`⬇️ *Downloading...*\n_Please wait..._`, { chat_id: chatId, message_id: processMsg.message_id, parse_mode: 'Markdown' });
-
-        const timestamp = Date.now();
-        const filePath = path.join(__dirname, `Lecture_${timestamp}.mp4`);
-        
-        const cmd = `ffmpeg -user_agent "${userAgent}" -headers "Cookie: ${cookieString}" -i "${streamUrl}" -c copy -bsf:a aac_adtstoasc "${filePath}" -y`;
-        
-        exec(cmd, { maxBuffer: 1024 * 1024 * 50 }, async (err, stdout, stderr) => {
-            if (err) {
-                log(`❌ FFmpeg Error: ${err.message}`);
-                await sendErrorLog(chatId, processMsg.message_id);
-                return;
+        try {
+            log("STEP 1: Analyzing URL...");
+            let streamUrl = text;
+            let cookieString = "";
+            let userAgent = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64)';
+
+            try {
+                const res = await axios.get(text, { headers: { 'User-Agent': userAgent }, timeout: 15000 });
+                if (res.headers['set-cookie']) {
+                    cookieString = res.headers['set-cookie'].map(c => c.split(';')[0]).join('; ');
+                }
+                const match = res.data.match(/src:\s*'(\/Stream\/Index\/[^']+)'/);
+                if (match) {
+                    streamUrl = `https://vss-v2-app.techsol360.com${match[1]}`;
+                    log(`✅ Found HIDDEN Stream URL`);
+                } 
+            } catch (e) {
+                log(`⚠️ Scrape Error: ${e.message} (Using original link)`);
             }
 
-            if (!fs.existsSync(filePath)) {
-                log("❌ File missing after download.");
-                await sendErrorLog(chatId, processMsg.message_id);
-                return;
-            }
+            log("STEP 2: Starting FFmpeg Download...");
+            await bot.editMessageText(`⬇️ *Downloading...*\n_Please wait..._`, { chat_id: chatId, message_id: processMsg.message_id, parse_mode: 'Markdown' });
 
-            const stats = fs.statSync(filePath);
-            const sizeMB = stats.size / (1024 * 1024);
-            log(`✅ Download Success. Size: ${sizeMB.toFixed(2)} MB`);
-
-            // --- STEP 3: UPLOAD ---
-            if (sizeMB < 49) {
-                log("STEP 3: Uploading to Telegram (Small File)...");
-                await bot.editMessageText(`📤 *Uploading to Telegram...*`, { chat_id: chatId, message_id: processMsg.message_id, parse_mode: 'Markdown' });
-                
-                try {
-                    await bot.sendDocument(chatId, filePath, { caption: `📦 ${sizeMB.toFixed(2)} MB` });
-                    log("Telegram Upload Success.");
-                } catch (tgErr) {
-                    log(`Telegram Error: ${tgErr.message}`);
+            const timestamp = Date.now();
+            const filePath = path.join(__dirname, `Lecture_${timestamp}.mp4`);
+            
+            const cmd = `ffmpeg -user_agent "${userAgent}" -headers "Cookie: ${cookieString}" -i "${streamUrl}" -c copy -bsf:a aac_adtstoasc "${filePath}" -y`;
+            
+            exec(cmd, { maxBuffer: 1024 * 1024 * 50 }, async (err, stdout, stderr) => {
+                if (err) {
+                    log(`❌ FFmpeg Error: ${err.message}`);
+                    await sendErrorLog(chatId, processMsg.message_id, bot);
+                    return;
                 }
-            } else {
-                log("STEP 3: Uploading to Gofile (Large File)...");
-                await bot.editMessageText(`🚀 *Uploading to Gofile Cloud...*`, { chat_id: chatId, message_id: processMsg.message_id, parse_mode: 'Markdown' });
-
-                try {
-                    const link = await uploadToGofile(filePath);
-                    log(`✅ Gofile Success: ${link}`);
-                    
-                    await bot.sendMessage(chatId, `✅ *Done!*\n\n🔗 [Download Link](${link})\n📦 Size: ${sizeMB.toFixed(2)} MB`, { parse_mode: 'Markdown', disable_web_page_preview: true });
-                } catch (cloudErr) {
-                    log(`❌ Gofile Failed: ${cloudErr.message}`);
-                    await sendErrorLog(chatId, processMsg.message_id);
+                if (!fs.existsSync(filePath)) {
+                    log("❌ File missing after download.");
+                    await sendErrorLog(chatId, processMsg.message_id, bot);
+                    return;
                 }
-            }
 
-            // Cleanup
-            if (fs.existsSync(filePath)) fs.unlinkSync(filePath);
-        });
+                const stats = fs.statSync(filePath);
+                const sizeMB = stats.size / (1024 * 1024);
+                log(`✅ Download Success. Size: ${sizeMB.toFixed(2)} MB`);
+
+                if (sizeMB < 49) {
+                    log("STEP 3: Uploading to Telegram...");
+                    await bot.editMessageText(`📤 *Uploading to Telegram...*`, { chat_id: chatId, message_id: processMsg.message_id, parse_mode: 'Markdown' });
+                    try {
+                        await bot.sendDocument(chatId, filePath, { caption: `📦 ${sizeMB.toFixed(2)} MB` });
+                        log("Telegram Upload Success.");
+                    } catch (tgErr) { log(`Telegram Error: ${tgErr.message}`); }
+                } else {
+                    log("STEP 3: Uploading to Gofile...");
+                    await bot.editMessageText(`🚀 *Uploading to Gofile Cloud...*`, { chat_id: chatId, message_id: processMsg.message_id, parse_mode: 'Markdown' });
+                    try {
+                        const link = await uploadToGofile(filePath);
+                        log(`✅ Gofile Success: ${link}`);
+                        await bot.sendMessage(chatId, `✅ *Done!*\n\n🔗 [Download Link](${link})\n📦 Size: ${sizeMB.toFixed(2)} MB`, { parse_mode: 'Markdown', disable_web_page_preview: true });
+                    } catch (cloudErr) {
+                        log(`❌ Gofile Failed: ${cloudErr.message}`);
+                        await sendErrorLog(chatId, processMsg.message_id, bot);
+                    }
+                }
+                if (fs.existsSync(filePath)) fs.unlinkSync(filePath);
+            });
+        } catch (error) {
+            log(`❌ CRITICAL: ${error.message}`);
+            await sendErrorLog(chatId, processMsg.message_id, bot);
+        }
+    });
 
-    } catch (error) {
-        log(`❌ CRITICAL: ${error.message}`);
-        await sendErrorLog(chatId, processMsg.message_id);
-    }
-});
+}, 5000); // <-- This is the 5-second Magic Delay!
 
 // ============================================================
 // 📤 GOFILE UPLOAD
 // ============================================================
 async function uploadToGofile(filePath) {
     log("Initiating Gofile Upload...");
-    
     const form = new FormData();
     form.append('file', fs.createReadStream(filePath));
-
     const res = await axios.post('https://upload.gofile.io/uploadfile', form, {
-        headers: {
-            ...form.getHeaders(),
-            'User-Agent': 'Mozilla/5.0'
-        },
-        maxContentLength: Infinity,
-        maxBodyLength: Infinity
+        headers: { ...form.getHeaders(), 'User-Agent': 'Mozilla/5.0' },
+        maxContentLength: Infinity, maxBodyLength: Infinity
     });
-
-    if (res.data.status === 'ok') {
-        return res.data.data.downloadPage;
-    } else {
-        throw new Error(`Gofile API Status: ${res.data.status}`);
-    }
+    if (res.data.status === 'ok') return res.data.data.downloadPage;
+    else throw new Error(`Gofile API Status: ${res.data.status}`);
 }
 
 // ============================================================
 // 🚨 ERROR REPORTER
 // ============================================================
-async function sendErrorLog(chatId, msgId) {
-    await bot.editMessageText("❌ *Process Failed.* Sending logs...", { chat_id: chatId, message_id: msgId, parse_mode: 'Markdown' });
+async function sendErrorLog(chatId, msgId, botInstance) {
+    await botInstance.editMessageText("❌ *Process Failed.* Sending logs...", { chat_id: chatId, message_id: msgId, parse_mode: 'Markdown' });
     try {
-        await bot.sendDocument(chatId, LOG_FILE, { 
-            caption: "📜 *Error Log*\nOpen this file to see details." 
-        });
+        await botInstance.sendDocument(chatId, LOG_FILE, { caption: "📜 *Error Log*\nOpen this file to see details." });
     } catch (e) { console.error(e); }
 }