Update app.py

app.py

@@ -80,7 +80,7 @@ def get_media_obj(msg):
     return None
 
 def get_msg_file_id(msg):
-    """মেসেজ থেকে ক্র্যাশ-ফ্রিfile_id বের করার ফাংশন"""
+    """মেসেজ থেকে ক্র্যাশ-ফ্রি file_id বের করার ফাংশন"""
     if not msg:
         return None
     if msg.photo:
@@ -101,27 +101,37 @@ def get_file_stream(message_id):
             msg = await bot.get_messages(STORAGE_CHANNEL_ID, message_id)
             media = get_media_obj(msg)
             if not media:
-                q.put(None)
+                await asyncio.to_thread(q.put, None)
                 return
             
-            # ডাটা রিড করে থ্রেড-সেফ কিউ-তে রাখা হচ্ছে
+            # ডাটা রিড করে থ্রেড-সেফ কিউ-তে রাখা হচ্ছে (asyncio.to_thread ব্যবহারের ফলে মেইন লুপ কখনো ফ্রিজ হবে না)
             async for chunk in bot.stream_media(media):
-                q.put(chunk)
+                await asyncio.to_thread(q.put, chunk)
         except Exception as e:
             print(f"Error in stream producer: {e}")
         finally:
-            q.put(None)  # স্ট্রিম শেষ হওয়ার সিগন্যাল
+            await asyncio.to_thread(q.put, None)  # স্ট্রিম শেষ হওয়ার সিগন্যাল
 
     # প্রোডিউসারটিকে বটের নিজের মেইন ইভেন্ট লুপে রান করানো হলো
     asyncio.run_coroutine_threadsafe(producer(), main_loop)
 
     # ফ্লাস্কের জন্য সিনক্রোনাস কন্সুমার জেনারেটর
     def consumer():
-        while True:
-            chunk = q.get()
-            if chunk is None:
-                break
-            yield chunk
+        try:
+            while True:
+                try:
+                    # সর্বোচ্চ ১৫ সেকেন্ড অপেক্ষা করবে, ফলে থ্রেড কখনো অনন্তকাল হ্যাং হবে না
+                    chunk = q.get(timeout=15)
+                except queue.Empty:
+                    break
+                if chunk is None:
+                    break
+                yield chunk
+        except GeneratorExit:
+            # ইউজার যদি মাঝপথে ব্রাউজার ট্যাব কেটে দেয়, তবে কিউ খালি করে ব্যাকগ্রাউন্ড থ্রেড রিলিজ করা হবে
+            while not q.empty():
+                try: q.get_nowait()
+                except: break
 
     return consumer()
 
@@ -996,7 +1006,7 @@ async def catch_admin_steps(client, message):
     elif state.get("step") == "broadcast":
         await process_broadcast(client, message)
 
-def run_flask(): app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 7860)))
+def run_flask(): app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 7860)), threaded=True) # Multithreading explicitly enabled
 
 async def main():
     await bot.start()