Update streamlit_app.py

streamlit_app.py

@@ -3,6 +3,7 @@ from io import BytesIO
 from PIL import Image, ImageDraw, ImageFont
 import streamlit as st
 
+# ---------- إعدادات ----------
 FONT_PATH = "/tmp/Palestine.ttf"
 FONT_URL = "https://github.com/mokhtarbsaid/rare-arabic-fonts/raw/main/palestine/palestine-regular.ttf"
 COMMENTS_URL = "https://reoo88-signserver.hf.space/comments"
@@ -61,9 +62,12 @@ def start_stream(yt_key, username):
     threading.Thread(target=comments_updater, daemon=True).start()
     time.sleep(3)
 
-    sl_cmd = f"streamlink https://www.tiktok.com/@{username}/live best --hls-live-edge 3 --stdout"
+    # إصلاح 1: استخدام shell=False
+    sl_cmd = ["streamlink", f"https://www.tiktok.com/@{username}/live", "best", "--hls-live-edge", "3", "--stdout"]
+    
     ff_cmd = [
-        "ffmpeg", "-thread_queue_size", "8192",
+        "ffmpeg",
+        "-thread_queue_size", "8192",
         "-i", "pipe:0",
         "-f", "image2pipe", "-r", "2", "-i", "pipe:1",
         "-filter_complex", "[0:v]scale=720:1280[vid];[vid][1:v]overlay=0:0",
@@ -75,22 +79,29 @@ def start_stream(yt_key, username):
     ]
 
     try:
-        sl_process = subprocess.Popen(sl_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.DEVNULL)
-        ffmpeg_process = subprocess.Popen(ff_cmd, stdin=subprocess.PIPE, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+        sl_process = subprocess.Popen(sl_cmd, stdout=subprocess.PIPE, stderr=subprocess.DEVNULL)
+        # إصلاح 2: تعيين bufsize كبير
+        ffmpeg_process = subprocess.Popen(ff_cmd, stdin=subprocess.PIPE, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL, bufsize=10**8)
 
+        # خيط لتغذية ffmpeg بصورة التعليقات
         def feed_overlay():
             while ffmpeg_process.poll() is None:
                 try:
                     img_data = create_comment_overlay()
                     ffmpeg_process.stdin.write(img_data)
                     ffmpeg_process.stdin.flush()
-                except:
+                except BrokenPipeError:
+                    print("[INFO] توقف ffmpeg عن استقبال الصور (Broken pipe - طبيعي عند انتهاء البث)")
+                    break
+                except Exception as e:
+                    print(f"[ERROR] خطأ في تغذية الصور: {e}")
                     break
                 time.sleep(0.5)
-            ffmpeg_process.stdin.close()
+            # لا نغلق stdin هنا، نترك العملية الرئيسية تتعامل معه
 
         threading.Thread(target=feed_overlay, daemon=True).start()
 
+        # تغذية الفيديو من streamlink
         while ffmpeg_process.poll() is None:
             data = sl_process.stdout.read(8192)
             if not data:
@@ -103,7 +114,7 @@ def start_stream(yt_key, username):
     except Exception as e:
         print(f"[ERROR] {e}")
 
-st.title("بث تيك توك مع تعليقات كاملة")
+st.title("بث تيك توك مع تعليقات - حل نهائي")
 with st.form("f"):
     user = st.text_input("معرف تيك توك", "majd.alban")
     key = st.text_input("مفتاح يوتيوب", type="password")