Update app.py

app.py

@@ -5,9 +5,10 @@ import requests
 import asyncio
 import re
 import random
+import queue
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
-from pyrogram import Client, filters, enums
+from pyrogram import Client, filters, enums, idle
 from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInfo
 
 # ================= CONFIGURATION =================
@@ -36,19 +37,19 @@ bot = Client(
     bot_token=BOT_TOKEN
 )
 
-# === ম্যাজিক ফিক্স: বটের মাধ্যমে সরাসরি মেসেজ পাঠানোর কিউ সিস্টেম ===
-send_queue = []
+# === ম্যাজিক ফিক্স: থ্রেড-সেফ কিউ সিস্টেম (Thread-safe Queue) ===
+send_queue = queue.Queue()
 
 async def background_worker():
     while True:
-        if send_queue:
-            msg = send_queue.pop(0)
+        while not send_queue.empty():
+            msg = send_queue.get()
             try:
                 # সরাসরি বটের নিজস্ব কানেকশন দিয়ে মেসেজ পাঠানো হচ্ছে
                 await bot.send_message(chat_id=int(msg['chat_id']), text=msg['text'], parse_mode=enums.ParseMode.HTML)
             except Exception as e:
                 print("Error sending OTP via MTProto:", e)
-        await asyncio.sleep(0.5)
+        await asyncio.sleep(1)
 # ==========================================================
 
 async def db_query(func):
@@ -94,8 +95,8 @@ def api_send_code():
     
     text_msg = f"🔐 আপনার Video Unlocker Pro এর Verification Code হচ্ছে: <b>{otp}</b>\n\nঅনুগ্রহ করে এটি কারো সাথে শেয়ার করবেন না।"
     
-    # মেসেজটি কিউতে যোগ করা হলো (যাতে ব্যাকগ্রাউন্ড ওয়ার্কার এটি বটের মাধ্যমে পাঠাতে পারে)
-    send_queue.append({"chat_id": user_id, "text": text_msg})
+    # মেসেজটি কিউতে যোগ করা হলো
+    send_queue.put({"chat_id": user_id, "text": text_msg})
     
     return add_cors_headers(make_response(jsonify({"status": "ok", "hash": hash_val})))
 
@@ -452,12 +453,13 @@ async def catch_admin_steps(client, message):
 
 def run_flask(): app.run(host="0.0.0.0", port=7860)
 
+async def main():
+    await bot.start()
+    print("🤖 Pyrogram Bot and Background Worker is running!")
+    asyncio.create_task(background_worker())
+    await idle()
+    await bot.stop()
+
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()
-    print("🤖 Pyrogram Bot is starting...")
-    
-    # ব্যাকগ্রাউন্ড ওয়ার্কার চালু করা হলো যা কিউ থেকে মেসেজ নিয়ে বটের মাধ্যমে সেন্ড করবে
-    loop = asyncio.get_event_loop()
-    loop.create_task(background_worker())
-    
-    bot.run()
+    bot.run(main())