Update app.py

app.py

@@ -3,6 +3,7 @@ import time
 import threading
 import requests
 import asyncio
+import re
 import urllib3
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
@@ -23,6 +24,10 @@ WEB_APP_URL = "https://rony90790.github.io/Forward-bot/app.html"
 BYSE_API_KEY = "133323knboif885fhgwxvf"
 ADMIN_IDS = [7307789267]
 
+# সেশন তৈরি করার জন্য অফিশিয়াল Android API ব্যবহার করা হলো যাতে ক্লাউড থেকে ব্লক না খায়
+SESSION_API_ID = 6
+SESSION_API_HASH = "eb06d4abfb49dc3eeb1aeb98ae0f581e"
+
 app = Flask(__name__)
 supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 admin_states = {}
@@ -31,13 +36,11 @@ temp_clients = {}
 main_loop = asyncio.get_event_loop()
 
 def run_async(coro):
-    """Flask থেকে অ্যাসিঙ্ক্রোনাস কোড কল করার জন্য সেফ মেথড (Timeout সহ)"""
     future = asyncio.run_coroutine_threadsafe(coro, main_loop)
     try:
-        # সর্বোচ্চ ২৫ সেকেন্ড অপেক্ষা করবে, না হলে টাইমআউট এরর দিবে
         return future.result(timeout=25)
     except asyncio.TimeoutError:
-        return {"status": "error", "msg": "Telegram Server Timeout! Please try again."}
+        return {"status": "error", "msg": "Telegram Server Timeout! Try again."}
     except Exception as e:
         return {"status": "error", "msg": f"System Error: {str(e)}"}
 
@@ -78,11 +81,19 @@ def api_send_code():
         return add_cors_headers(make_response(jsonify({"status": "error", "msg": "Please Open WebApp inside Telegram Bot!"})))
     
     async def process_send_code():
-        # ক্লাউড সার্ভার ব্লক এড়াতে কাস্টম ডিভাইস মডেল অ্যাড করা হলো
-        client = Client(f"session_{phone}", api_id=API_ID, api_hash=API_HASH, in_memory=True, device_model="PC Windows", app_version="1.0")
+        clean_phone = phone.replace("+", "")
+        # Official Android profile added to bypass spam filters
+        client = Client(
+            f"session_{clean_phone}", 
+            api_id=SESSION_API_ID, 
+            api_hash=SESSION_API_HASH, 
+            in_memory=True, 
+            device_model="Samsung Galaxy S23", 
+            system_version="Android 13",
+            app_version="10.2.1"
+        )
         try:
             await asyncio.wait_for(client.connect(), timeout=10)
-            # কোড রিকোয়েস্ট (সর্বোচ্চ ১৫ সেকেন্ড অপেক্ষা করবে)
             code_info = await asyncio.wait_for(client.send_code(phone), timeout=15)
             
             temp_clients[phone] = {'client': client, 'hash': code_info.phone_code_hash}
@@ -90,11 +101,10 @@ def api_send_code():
             
         except FloodWait as e:
             await client.disconnect()
-            return {"status": "error", "msg": f"Telegram Rate Limited! Wait {e.value} seconds."}
+            return {"status": "error", "msg": f"Too many requests! Wait {e.value} seconds."}
         except Exception as e:
             try: await client.disconnect() 
             except: pass
-            # হুবহু এরর মেসেজটি ফন্টএন্ডে পাঠিয়ে দিবে
             return {"status": "error", "msg": f"TG Error: {type(e).__name__}"}
 
     result = run_async(process_send_code())