Update streamlit_app.py

streamlit_app.py

@@ -61,10 +61,10 @@ def get_tiktok_stream_url():
         pass
     return None
 
-def start_stream_simple(stream_key, stream_url):
+def start_stream_final(stream_key, stream_url):
     if not stream_key or not stream_url:
         return None
-    log("🎬 بدء البث البسيط (vsync 2 + إعدادات أساسية)...")
+    log("🎬 بدء البث النهائي (مقاوم للتقطيع)...")
     rtmp_url = f"rtmp://a.rtmp.youtube.com/live2/{stream_key}"
 
     cmd = [
@@ -75,9 +75,27 @@ def start_stream_simple(stream_key, stream_url):
         "-probesize", "50M",
         "-thread_queue_size", "65535",
         "-rtbufsize", "512M",
+
+        # 🛡️ درع إعادة الاتصال
+        "-reconnect", "1",
+        "-reconnect_streamed", "1",
+        "-reconnect_delay_max", "15",
+        "-timeout", "10000000",
+
         "-i", stream_url,
+
+        # 🛡️ تصحيح الطوابع الزمنية وتجاهل التالف
         "-err_detect", "ignore_err",
+        "-fflags", "+genpts+igndts+discardcorrupt",
+        "-avoid_negative_ts", "make_zero",
+        "-use_wallclock_as_timestamps", "1",
+        "-correct_ts_overflow", "1",
+        "-max_interleave_delta", "2000000",
+
+        # أبعاد 1080p
         "-vf", "scale=1080:1920:force_original_aspect_ratio=increase,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black:eval=frame",
+
+        # فيديو – جودة عالية ومستقرة
         "-c:v", "libx264",
         "-preset", "ultrafast",
         "-crf", "18",
@@ -92,13 +110,17 @@ def start_stream_simple(stream_key, stream_url):
         "-color_primaries", "bt709",
         "-color_trc", "bt709",
         "-colorspace", "bt709",
+
+        # صوت – بسيط ومتناسق
         "-c:a", "aac",
         "-b:a", "192k",
         "-ac", "2",
         "-ar", "44100",
         "-async", "1",
+
+        # إرسال – صمود إضافي
         "-max_muxing_queue_size", "65535",
-        "-max_delay", "5000000",
+        "-max_delay", "3000000",                   # 3 ثوانٍ مرونة
         "-flvflags", "no_duration_filesize+add_keyframe_index",
         "-f", "flv", rtmp_url
     ]
@@ -127,7 +149,7 @@ def run_monitor():
     was_streaming = False
     consecutive_fails = 0
 
-    log("🚀 محرك البث البسيط (vsync 2)")
+    log("🚀 محرك البث النهائي (مقاوم للتقطيع)")
 
     while True:
         try:
@@ -138,7 +160,7 @@ def run_monitor():
                     log("🟢 بدء بث جديد...")
                     if processes:
                         kill_process_tree(processes["ffmpeg"].pid)
-                    processes = start_stream_simple(STREAM_KEY, stream_url)
+                    processes = start_stream_final(STREAM_KEY, stream_url)
                     if processes:
                         is_streaming = True
                         was_streaming = True
@@ -146,7 +168,7 @@ def run_monitor():
                 else:
                     if is_streaming and processes and processes["ffmpeg"].poll() is not None:
                         log("⚠️ ffmpeg مات، إعادة تشغيل...")
-                        processes = start_stream_simple(STREAM_KEY, stream_url)
+                        processes = start_stream_final(STREAM_KEY, stream_url)
                         if not processes:
                             is_streaming = False
                             was_streaming = False
@@ -168,7 +190,7 @@ def run_monitor():
             time.sleep(10)
 
 if __name__ == "__main__":
-    log("✅ بدء تشغيل المحرك البسيط")
+    log("✅ بدء تشغيل المحرك النهائي")
     t = threading.Thread(target=run_monitor, daemon=True)
     t.start()
     while True: