| 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)
|
|
|
