Update app.py

app.py

@@ -5,15 +5,11 @@ import requests
 import asyncio
 import re
 import random
-import urllib3
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
 from pyrogram import Client, filters, enums
 from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInfo
 
-# SSL Error ফিক্স করার জন্য ওয়ার্নিং হাইড করা হলো
-urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
-
 # ================= CONFIGURATION =================
 BOT_TOKEN = "8628213901:AAFvfHBpZ6tok40ZQuhIDLAVIMrHeiheMNY"
 
@@ -40,6 +36,21 @@ bot = Client(
     bot_token=BOT_TOKEN
 )
 
+# === ম্যাজিক ফিক্স: বটের মাধ্যমে সরাসরি মেসেজ পাঠানোর কিউ সিস্টেম ===
+send_queue = []
+
+async def background_worker():
+    while True:
+        if send_queue:
+            msg = send_queue.pop(0)
+            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)
+# ==========================================================
+
 async def db_query(func):
     return await asyncio.to_thread(func)
 
@@ -81,22 +92,10 @@ def api_send_code():
     hash_val = str(random.randint(1000000, 9999999))
     temp_otps[hash_val] = otp
     
-    url = f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
-    payload = {
-        "chat_id": user_id,
-        "text": f"🔐 আপনার Video Unlocker Pro এর Verification Code হচ্ছে: <b>{otp}</b>\n\nঅনুগ্রহ করে এটি কারো সাথে শেয়ার করবেন না।",
-        "parse_mode": "HTML"
-    }
+    text_msg = f"🔐 আপনার Video Unlocker Pro এর Verification Code হচ্ছে: <b>{otp}</b>\n\nঅনুগ্রহ করে এটি কারো সাথে শেয়ার করবেন না।"
     
-    # এখানে SSL Error বাইপাস করার লজিক দেওয়া হলো
-    try:
-        requests.post(url, json=payload, timeout=10)
-    except Exception:
-        # যদি নরমাল রিকোয়েস্ট ফেইল করে, তবে SSL ভেরিফিকেশন ছাড়া রিকোয়েস্ট করবে
-        try:
-            requests.post(url, json=payload, verify=False, timeout=10)
-        except Exception as e:
-            print("Telegram API Error:", e)
+    # মেসেজটি কিউতে যোগ করা হলো (যাতে ব্যাকগ্রাউন্ড ওয়ার্কার এটি বটের মাধ্যমে পাঠাতে পারে)
+    send_queue.append({"chat_id": user_id, "text": text_msg})
     
     return add_cors_headers(make_response(jsonify({"status": "ok", "hash": hash_val})))
 
@@ -456,4 +455,9 @@ def run_flask(): app.run(host="0.0.0.0", port=7860)
 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()