Update streamlit_app.py

streamlit_app.py

@@ -11,9 +11,9 @@ from TikTokLive import TikTokLiveClient
 from TikTokLive.events import CommentEvent, DisconnectEvent, ConnectEvent
 from TikTokLive.client.errors import UserOfflineError, UserNotFoundError
 
-# ---------- تحميل الخط تلقائياً ----------
-FONT_PATH = "Palestine.ttf"
-FONT_URL = "https://github.com/mokhtarbsaid/rare-arabic-fonts/raw/main/palestine/palestine-regular.ttf"
+# ---------- إعدادات ثابتة ----------
+FONT_PATH = "arial.ttf"  # تأكد من وجود ملف خط في مجلد المشروع
+FONT_URL = "https://github.com/mokhtarbsaid/rare-arabic-fonts/raw/main/palestine/palestine-regular.ttf" # خط احتياطي
 
 def download_font():
     if not os.path.exists(FONT_PATH):
@@ -24,56 +24,41 @@ def download_font():
 
 download_font()
 
-# ---------- إعدادات التعليقات ----------
+# متغيرات التعليقات
 comments_list = []
-MAX_COMMENTS = 8
+MAX_COMMENTS = 10
 lock = threading.Lock()
 
-# متغير التحكم في التعليقات الوهمية (متغير عام عادي)
-fake_comments_enabled = True
-fake_counter = 0
-
-def add_fake_comment():
-    global fake_counter
-    fake_counter += 1
-    fake_comments = [
-        f"زائر {fake_counter}: بالتوفيق",
-        f"محب {fake_counter}: بث رائع",
-        f"صديق {fake_counter}: متابع من العراق",
-    ]
-    return fake_comments[fake_counter % 3]
-
-def create_comment_overlay():
-    width, height = 720, 1280
+# ---------- دالة توليد صورة التعليقات ----------
+def create_comment_overlay(width=720, height=1280):
+    """تولد صورة PNG شفافة تحتوي على أحدث التعليقات"""
     img = Image.new("RGBA", (width, height), (0, 0, 0, 0))
     draw = ImageDraw.Draw(img)
+    
     try:
+        # استخدام حجم خط مناسب للتعليقات
         font = ImageFont.truetype(FONT_PATH, 28)
     except:
         font = ImageFont.load_default()
-
+    
     with lock:
         current = comments_list[-MAX_COMMENTS:]
-
+    
+    # رسم التعليقات من الأسفل إلى الأعلى
     y_offset = height - 60
     for comment in reversed(current):
+        # ظل أسود خفيف
         draw.text((12, y_offset + 2), comment, font=font, fill=(0, 0, 0, 180))
+        # نص أبيض
         draw.text((10, y_offset), comment, font=font, fill=(255, 255, 255, 255))
-        y_offset -= 40
-
+        y_offset -= 45  # تباعد عمودي بين التعليقات
+    
     buf = BytesIO()
     img.save(buf, format="PNG")
     buf.seek(0)
     return buf.read()
 
-# ---------- مولّد التعليقات الوهمية ----------
-def fake_comment_generator():
-    while fake_comments_enabled:
-        time.sleep(3)
-        with lock:
-            comments_list.append(add_fake_comment())
-
-# ---------- عميل تعليقات تيك توك ----------
+# ---------- عميل تيك توك (لجلب التعليقات) ----------
 def run_tiktok_client(username):
     while True:
         try:
@@ -83,7 +68,7 @@ def run_tiktok_client(username):
 
             @client.on(ConnectEvent)
             async def on_connect(event: ConnectEvent):
-                st.session_state["client_status"] = "✅ متصل بغرفة البث"
+                print("✅ تم الاتصال بغرفة البث لجلب التعليقات")
 
             @client.on(CommentEvent)
             async def on_comment(event: CommentEvent):
@@ -93,26 +78,25 @@ def run_tiktok_client(username):
 
             @client.on(DisconnectEvent)
             async def on_disconnect(event: DisconnectEvent):
-                st.session_state["client_status"] = "🔌 انقطع الاتصال، إعادة المحاولة..."
+                print("🔌 انقطع اتصال التعليقات، إعادة المحاولة...")
 
-            st.session_state["client_status"] = "🔄 جاري الاتصال بـ TikTok..."
             loop.run_until_complete(client.start())
-        except UserOfflineError:
-            st.session_state["client_status"] = "⚠️ الحساب غير متصل حالياً"
-        except UserNotFoundError:
-            st.session_state["client_status"] = "❌ اسم المستخدم غير موجود"
+        except (UserOfflineError, UserNotFoundError):
+            print("⚠️ المستخدم غير متصل حالياً")
         except Exception as e:
-            st.session_state["client_status"] = f"❌ خطأ: {str(e)[:50]}"
+            print(f"❌ خطأ في اتصال التعليقات: {e}")
         time.sleep(10)
 
-# ---------- تشغيل البث مع صورة التعليقات ----------
+# ---------- تشغيل البث ----------
 def start_streaming(yt_key, tiktok_username):
+    # 1. أمر streamlink لجلب الفيديو
     streamlink_cmd = f"streamlink https://www.tiktok.com/@{tiktok_username}/live best --hls-live-edge 3 --stdout"
     
+    # 2. أمر ffmpeg مع استقبال صورة التعليقات من أنبوب
     ffmpeg_cmd = (
-        f"ffmpeg -thread_queue_size 8192 -i pipe:0 "
-        f"-f image2pipe -r 2 -i pipe:1 "
-        f"-filter_complex \"[0:v]scale=720:1280[vid];[vid][1:v]overlay=0:0\" "
+        f"ffmpeg -thread_queue_size 8192 -i pipe:0 "  # الفيديو من streamlink
+        f"-f image2pipe -r 1 -i pipe:1 "             # صورة التعليقات من الأنبوب الثاني
+        f"-filter_complex \"[0:v]scale=720:1280[vid];[vid][1:v]overlay=0:0\" " # تراكب الصورة على الفيديو
         f"-map \"[outv]\" -map 0:a? "
         f"-c:v libx264 -preset ultrafast -tune zerolatency -b:v 1500k -maxrate 2000k -bufsize 3000k -g 30 "
         f"-c:a aac -ar 48000 -b:a 192k -ac 2 "
@@ -122,9 +106,12 @@ def start_streaming(yt_key, tiktok_username):
     try:
         print(f"[INFO] بدء البث من @{tiktok_username} إلى يوتيوب...")
         
+        # تشغيل streamlink
         sl_process = subprocess.Popen(streamlink_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.DEVNULL)
+        # تشغيل ffmpeg مع أنبوبين (stdin للفيديو والصورة)
         ffmpeg_process = subprocess.Popen(ffmpeg_cmd, shell=True, stdin=subprocess.PIPE, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
         
+        # خيط لتغذية صورة التعليقات
         def feed_overlay():
             while ffmpeg_process.poll() is None:
                 try:
@@ -133,11 +120,12 @@ def start_streaming(yt_key, tiktok_username):
                     ffmpeg_process.stdin.flush()
                 except:
                     break
-                time.sleep(0.5)
+                time.sleep(1)  # تحديث كل ثانية
             ffmpeg_process.stdin.close()
         
         threading.Thread(target=feed_overlay, daemon=True).start()
         
+        # تغذية الفيديو من streamlink
         while ffmpeg_process.poll() is None:
             data = sl_process.stdout.read(8192)
             if not data:
@@ -155,40 +143,25 @@ def start_streaming(yt_key, tiktok_username):
 st.set_page_config(page_title="بث تيك توك مع تعليقات")
 st.title("📱 بث تيك توك إلى يوتيوب مع تعليقات متحركة")
 
-if "client_status" not in st.session_state:
-    st.session_state["client_status"] = "⏳ في انتظار البدء..."
-
 with st.form(key="stream_form"):
     tiktok_user = st.text_input("معرف مستخدم تيك توك (بدون @)").strip()
     yt_stream_key = st.text_input("مفتاح بث يوتيوب (RTMP Key)", type="password").strip()
-    enable_fake = st.checkbox("تفعيل التعليقات الوهمية للتجربة", value=True)
     submit_button = st.form_submit_button(label="ابدأ البث الآن")
 
 if submit_button:
     if not tiktok_user or not yt_stream_key:
         st.error("يرجى إدخال اسم المستخدم ومفتاح البث.")
     else:
-        # تعديل قيمة المتغير العام مباشرة (لا نحتاج global في هذا المستوى)
-        fake_comments_enabled = enable_fake
-        
-        if fake_comments_enabled:
-            threading.Thread(target=fake_comment_generator, daemon=True).start()
-        
+        # تشغيل عميل التعليقات
         threading.Thread(target=run_tiktok_client, args=(tiktok_user,), daemon=True).start()
+        # بدء البث
         threading.Thread(target=start_streaming, args=(yt_stream_key, tiktok_user), daemon=True).start()
         st.success("تم بدء العمليات في الخلفية. انتظر ظهور البث على يوتيوب.")
 
-# عرض حالة اتصال التعليقات
-st.subheader("📡 حالة اتصال التعليقات")
-status_text = st.empty()
-status_text.text(st.session_state["client_status"])
-
 # عرض التعليقات الحية
 st.subheader("💬 أحدث التعليقات")
 placeholder = st.empty()
-
 while True:
-    status_text.text(st.session_state["client_status"])
     with lock:
         current = comments_list[-8:] if comments_list else ["لا توجد تعليقات بعد"]
     placeholder.text("\n".join(current))