Update app.py

app.py

@@ -1,5 +1,6 @@
 import os
 import time
+import queue  # thread-safe queue ইম্পোর্ট করা হলো
 import threading
 import requests
 import asyncio
@@ -65,7 +66,7 @@ async def db_query(func):
 
 # ==================== UNIVERSAL MEDIA HELPER ====================
 def get_media_obj(msg):
-    """মেসেজ থেকে যেকোনো ধরনের মিডিয়া অবজেক্ট (ভিডিও, জিআইএফ, ডকুমেন্ট) খুঁজে বের করার ফাংশন"""
+    """মেসেজ থেকে মিডিয়া অবজেক্ট (ভিডিও, জিআইএফ, ডকুমেন্ট) খুঁজে বের করার ফাংশন"""
     if not msg:
         return None
     if msg.video:
@@ -79,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:
@@ -92,37 +93,37 @@ def get_msg_file_id(msg):
 
 # ==================== CUSTOM VIDEO STREAMING ENGINE ====================
 def get_file_stream(message_id):
-    """টেলিগ্রামের স্টোরেজ চ্যানেল থেকে রিয়েল-টাইমে ডাটা স্ট্রিম করার জেনারেটর"""
-    async def stream_generator():
+    """টেলিগ্রামের স্টোরেজ চ্যানেল থেকে মেইন ইভেন্ট লুপে থ্রেড-সেফ কিউ ব্যবহার করে ডাটা স্ট্রিম করার ফাংশন"""
+    q = queue.Queue(maxsize=10)  # মেমোরি নিয়ন্ত্রণে রাখার জন্য সর্বোচ্চ সাইজ ১০ রাখা হয়েছে
+
+    async def producer():
         try:
             msg = await bot.get_messages(STORAGE_CHANNEL_ID, message_id)
             media = get_media_obj(msg)
             if not media:
+                q.put(None)
                 return
             
-            # chunk_size অনুযায়ী ডাটা রিয়েল-টাইমে রিড করে পাঠানো হবে
+            # ডাটা রিড করে থ্রেড-সেফ কিউ-তে রাখা হচ্ছে
             async for chunk in bot.stream_media(media):
-                yield chunk
+                q.put(chunk)
         except Exception as e:
-            print(f"Error in stream_generator: {e}")
+            print(f"Error in stream producer: {e}")
+        finally:
+            q.put(None)  # স্ট্রিম শেষ হওয়ার সিগন্যাল
+
+    # প্রোডিউসারটিকে বটের নিজের মেইন ইভেন্ট লুপে রান করানো হলো
+    asyncio.run_coroutine_threadsafe(producer(), main_loop)
 
-    # Async জেনারেটরকে Flask-এর সাথে সিঙ্ক করার জন্য ইভেন্ট লুপ ফিক্স
-    loop = asyncio.new_event_loop()
-    def run():
-        asyncio.set_event_loop(loop)
-        gen = stream_generator()
+    # ফ্লাস্কের জন্য সিনক্রোনাস কন্সুমার জেনারেটর
+    def consumer():
         while True:
-            try:
-                chunk = loop.run_until_complete(gen.__anext__())
-                yield chunk
-            except StopAsyncIteration:
+            chunk = q.get()
+            if chunk is None:
                 break
-            except Exception as e:
-                print(f"Sync wrapper error: {e}")
-                break
-        loop.close()
-    
-    return run()
+            yield chunk
+
+    return consumer()
 
 @app.route('/stream/<int:message_id>')
 def stream_video(message_id):