Update streamlit_app.py

streamlit_app.py

@@ -27,27 +27,33 @@ def run_monitor():
             # فحص حالة البث
             client = TikTokLiveClient(unique_id=TIKTOK_USERNAME)
             is_live = asyncio.run(client.is_live())
-            
+
             if is_live:
                 print(f"[{datetime.now().strftime('%H:%M')}] 🔴 البث بدأ! جاري النقل إلى يوتيوب...")
-                
-                # أمر النقل المباشر
-                # نستخدم shell=True لضمان عمل الـ pipe (|) بشكل صحيح
+
+                # أمر النقل المباشر - محسّن للصوت
                 cmd = (
-                    f"streamlink https://www.tiktok.com/{TIKTOK_USERNAME}/live best --stdout | "
-                    f"ffmpeg -i pipe:0 -c:v copy -c:a aac -ar 44100 -ab 128k -f flv {YT_RTMP_URL}"
+                    f"streamlink https://www.tiktok.com/{TIKTOK_USERNAME}/live best --hls-live-edge 3 --stdout | "
+                    f"ffmpeg -thread_queue_size 8192 -i pipe:0 "
+                    f"-c:v copy "
+                    f"-c:a aac -ar 48000 -b:a 192k -ac 2 "
+                    f"-af 'highpass=f=200,lowpass=f=3000,aresample=async=1' "
+                    f"-buffer_size 1024k "
+                    f"-fflags +genpts+igndts "
+                    f"-max_interleave_delta 0 "
+                    f"-f flv {YT_RTMP_URL}"
                 )
-                
+
                 process = subprocess.Popen(cmd, shell=True)
                 process.wait() # سينتظر هنا حتى ينتهي البث فعلياً
                 print("⏹️ انتهى البث، العودة لوضع المراقبة...")
             else:
                 #print(f"🔍 فحص: {TIKTOK_USERNAME} غير متصل حالياً.")
                 pass
-                
+
         except Exception as e:
             print(f"⚠️ تنبيه: {e}")
-            
+
         time.sleep(POLL_INTERVAL)
 
 # تشغيل الخيط الخلفي فور تشغيل التطبيق (مرة واحدة فقط)
@@ -99,4 +105,4 @@ st.info("💡 بمجرد أن يبدأ صاحب الحساب البث، سيقو
 if st.button("تحديث الحالة"):
     st.rerun()
 
-st.write(f"آخر فحص تم في: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
+st.write(f"آخر فحص تم في: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")