Update main.py

main.py

@@ -1,78 +1,71 @@
-import logging
-import asyncio
-from telegram import Update
-from telegram.ext import ApplicationBuilder, ContextTypes, MessageHandler, filters
-from telegram.request import HTTPXRequest
-
-# --- تنظیمات ---
-TOKEN = '5700240160:AAFbRWWQMohMWSxzj7VKyC46IyJVtu89CQc'
-CHAT_ID = '@medical_cen_archive'
-
-# تنظیمات لاگ برای مشاهده وضعیت در کنسول
-logging.basicConfig(format='%(asctime)s - %(levelname)s - %(message)s', level=logging.INFO)
-
-async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    if not update.message or not update.message.text:
-        return
-
-    # جدا کردن کل متن فرستاده شده به خط‌های مجزا
-    lines = update.message.text.split('\n')
-    sent_count = 0
-    error_count = 0
-
-    for line in lines:
-        line = line.strip()
-        # بررسی اینکه خط خالی نباشد و حداقل ۳ بخش داشته باشد
-        if not line or line.count('*') < 2:
-            continue
-
-        try:
-            parts = line.split('*')
-            question_text = parts[0].strip()
-            options = [opt.strip() for opt in parts[1].split(',')]
-            correct_id = int(parts[2].strip())
-            explanation_text = parts[3].strip() if len(parts) >= 4 else None
-
-            # رعایت محدودیت ۲۰۰ کاراکتری تلگرام برای توضیح
-            if explanation_text and len(explanation_text) > 200:
-                explanation_text = explanation_text[:197] + "..."
-
-            # ارسال به کانال
-            await context.bot.send_poll(
-                chat_id=CHAT_ID,
-                question=question_text,
-                options=options,
-                type='quiz',
-                correct_option_id=correct_id,
-                explanation=explanation_text,
-                is_anonymous=True
-            )
-            
-            sent_count += 1
-            # یک وقفه کوتاه بین ارسال‌ها برای جلوگیری از ارور اسپم تلگرام
-            await asyncio.sleep(1.5) 
-
-        except Exception as e:
-            logging.error(f"Error in line: {line[:30]}... -> {e}")
-            error_count += 1
-
-    # فرستادن گزارش نهایی به خودت در ربات
-    if sent_count > 0:
-        await update.message.reply_text(f"✅ تعداد {sent_count} سوال با موفقیت ارسال شد.")
-    if error_count > 0:
-        await update.message.reply_text(f"⚠️ تعداد {error_count} خط با خطا مواجه شد (فرمت اشتباه).")
-
-if __name__ == '__main__':
-    print("--- Bot is LIVE and Ready ---")
-    print(f"Target Channel: {CHAT_ID}")
-    
-    # تنظیم تایم‌اوت بسیار بالا برای پایداری در برابر نوسان اینترنت
-    t_request = HTTPXRequest(connect_timeout=60, read_timeout=60)
-    
-    application = ApplicationBuilder().token(TOKEN).request(t_request).build()
-    
-    msg_handler = MessageHandler(filters.TEXT & (~filters.COMMAND), handle_message)
-    application.add_handler(msg_handler)
-    
-    # اجرای مداوم ربات
-    application.run_polling(drop_pending_updates=True)
+import logging
+import asyncio
+from telegram import Update
+from telegram.ext import ApplicationBuilder, ContextTypes, MessageHandler, filters
+from telegram.request import HTTPXRequest
+
+# --- تنظیمات ---
+TOKEN = '5700240160:AAFbRWWQMohMWSxzj7VKyC46IyJVtu89CQc'
+CHAT_ID = '@medical_cen_archive'
+
+# تنظیمات لاگ
+logging.basicConfig(format='%(asctime)s - %(levelname)s - %(message)s', level=logging.INFO)
+
+async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    if not update.message or not update.message.text:
+        return
+
+    lines = update.message.text.split('\n')
+    sent_count = 0
+    error_count = 0
+
+    for line in lines:
+        line = line.strip()
+        if not line or line.count('*') < 2:
+            continue
+
+        try:
+            parts = line.split('*')
+            question_text = parts[0].strip()
+            options = [opt.strip() for opt in parts[1].split(',')]
+            correct_id = int(parts[2].strip())
+            explanation_text = parts[3].strip() if len(parts) >= 4 else None
+
+            if explanation_text and len(explanation_text) > 200:
+                explanation_text = explanation_text[:197] + "..."
+
+            await context.bot.send_poll(
+                chat_id=CHAT_ID,
+                question=question_text,
+                options=options,
+                type='quiz',
+                correct_option_id=correct_id,
+                explanation=explanation_text,
+                is_anonymous=True
+            )
+            
+            sent_count += 1
+            await asyncio.sleep(2.0) # افزایش زمان انتظار برای امنیت بیشتر
+
+        except Exception as e:
+            logging.error(f"Error processing line: {e}")
+            error_count += 1
+
+    if sent_count > 0:
+        await update.message.reply_text(f"✅ تعداد {sent_count} سوال ارسال شد.")
+    if error_count > 0:
+        await update.message.reply_text(f"⚠️ تعداد {error_count} خط با خطا مواجه شد.")
+
+if __name__ == '__main__':
+    print("--- Bot is LIVE and Ready ---")
+    
+    # استفاده از تنظیمات بهینه برای جلوگیری از ارورهای شبکه هاست
+    t_request = HTTPXRequest(connect_timeout=20, read_timeout=20)
+    
+    application = ApplicationBuilder().token(TOKEN).request(t_request).build()
+    
+    msg_handler = MessageHandler(filters.TEXT & (~filters.COMMAND), handle_message)
+    application.add_handler(msg_handler)
+    
+    # اجرای ربات
+    application.run_polling(drop_pending_updates=True)