Update streamlit_app.py

streamlit_app.py

@@ -72,7 +72,7 @@ def get_clean_tiktok_cookies():
 # ══════════════════════════════════════════════════════════════════════════════ #
 def cleanup_old_broadcasts(yt):
     try:
-        write_log("[Cleanup] جاري فحص الحساب بحثاً عن أي بثوث قديمة معلقة...")
+        write_log("[Cleanup] جاري فحص الحساب بحثاً عن أي بثوث قديمة معلقة لتصفيرها...")
         res = yt.liveBroadcasts().list(broadcastType="all", mine=True, part="id,status").execute()
         if res.get("items"):
             for item in res["items"]:
@@ -81,11 +81,11 @@ def cleanup_old_broadcasts(yt):
                 if life_status in ["live", "testing", "ready", "liveStarting"]:
                     try:
                         yt.liveBroadcasts().transition(broadcastStatus="complete", id=b_id, part="status").execute()
-                        write_log(f"[Cleanup] تم إغلاق بث قديم معلق بنجاح: {b_id}")
-                    except Exception as ex:
-                        write_log(f"[Cleanup Error] فشل إغلاق البث {b_id}: {ex}")
+                        write_log(f"[Cleanup] تم إغلاق وتطهير بث معلق سابق: {b_id}")
+                    except Exception:
+                        pass
     except Exception as e:
-        write_log(f"[Cleanup Core Error] خطأ أثناء تنظيف الحساب: {e}")
+        write_log(f"[Cleanup Error] خطأ أثناء تنظيف الحساب: {e}")
 
 # ══════════════════════════════════════════════════════════════════════════════ #
 # دالة إنشاء البث الحي وتوليد مفتاح البث تلقائياً عبر الـ API
@@ -95,7 +95,7 @@ def create_dynamic_youtube_stream(yt):
         cleanup_old_broadcasts(yt)
         current_date = datetime.now().strftime("%d-%m-%Y")
         
-        write_log("[API] جاري إنشاء غرفة بث جديدة (Broadcast)...")
+        write_log("[API] جاري إنشاء غرفة بث جديدة على يوتيوب...")
         broadcast_body = {
             "snippet": {
                 "title": f"تغطية مباشرة ومستمرة | أحمد عبدالله",
@@ -109,9 +109,8 @@ def create_dynamic_youtube_stream(yt):
         }
         broadcast_res = yt.liveBroadcasts().insert(part="snippet,status", body=broadcast_body).execute()
         broadcast_id = broadcast_res["id"]
-        write_log(f"[API] تم إنشاء غرفة البث بنجاح. ID: {broadcast_id}")
 
-        write_log("[API] جاري توليد مفتاح بث ذكي ديناميكي (Stream Key)...")
+        write_log("[API] جاري توليد مفتاح بث ديناميكي ذكي...")
         stream_body = {
             "snippet": {"title": f"Automated Key - {current_date}"},
             "cdn": {
@@ -123,44 +122,49 @@ def create_dynamic_youtube_stream(yt):
         stream_res = yt.liveStreams().insert(part="snippet,cdn", body=stream_body).execute()
         stream_id = stream_res["id"]
         stream_key = stream_res["cdn"]["ingestionInfo"]["streamName"]
-        write_log(f"[API] تم توليد المفتاح الذكي بنجاح.")
 
-        write_log("[API] جاري ربط غرفة البث بالمفتاح المولد (Binding)...")
+        write_log("[API] جاري ربط الغرفة بالمفتاح المولد...")
         yt.liveBroadcasts().bind(id=broadcast_id, part="id", streamId=stream_id).execute()
-        write_log("[API] اكتملت عملية الربط والتهيئة بنجاح.")
         
         return broadcast_id, stream_key
     except Exception as e:
-        write_log(f"[API Error] خطأ فادح أثناء إنشاء البث والمفتاح: {e}")
+        write_log(f"[API Error] خطأ في إنشاء البث: {e}")
         return None, None
 
 # ══════════════════════════════════════════════════════════════════════════════ #
-# دالة ذكية لمراقبة وصول البيانات وتحويل حالة البث إلى LIVE فور الاستقرار
+# دالة الانتظار الذكية لملء البافر (Buffer) ثم إطلاق البث المباشر على يوتيوب
 # ══════════════════════════════════════════════════════════════════════════════ #
 def monitor_and_switch_to_live(yt, broadcast_id):
-    write_log("[Live Monitor] جاري مراقبة وصول بيانات البث من ffmpeg إلى يوتيوب...")
-    # فحص متكرر لمدة دقيقتين بانتظار استقرار الإشارة
-    for i in range(24): 
-        time.sleep(5)
+    # 🔥 هنا نقوم بحجز دقيقة ونصف (90 ثانية) ليقوم السيرفر بتخزين أول دقيقتين من بث تيك توك في البافر لضمان الجودة
+    write_log("[⏳ Buffer Mode] جاري البدء بتخزين البث في الذاكرة المؤقتة (البافر) لمنع الشاشة الرمادية والتقطيع...")
+    
+    # الانتظار على 3 مراحل مع طباعة التحديث في اللوج لكي تتابع الاستقرار
+    for count in range(3):
+        time.sleep(30)
+        write_log(f"[⏳ Buffer Mode] اكتمل {30 * (count + 1)} ثانية من تخزين البث وتغذية خوادم يوتيوب بالبيانات...")
+
+    write_log("[Live Monitor] جاري التحقق من استقرار الإشارة في يوتيوب لإطلاق البث للجمهور...")
+    
+    for i in range(15): 
         try:
-            # فحص حالة البث الحالية
             status_res = yt.liveBroadcasts().list(id=broadcast_id, part="status").execute()
             if status_res.get("items"):
                 life_status = status_res["items"][0]["status"].get("lifeCycleStatus")
-                write_log(f"[Live Monitor] حالة البث الحالية في سيرفر يوتيوب: {life_status}")
+                write_log(f"[Live Monitor] حالة معالجة البيانات الحالية في يوتيوب: {life_status}")
                 
-                # إذا أصبح البث جاهزاً لاستقبال أمر الـ live أو الإشارة بدأت تتدفق
                 try:
-                    write_log("[API] محاولة إرسال أمر إطلاق البث المباشر (Transition to LIVE)...")
+                    write_log("[API] إرسال أمر تحويل حالة البث إلى LIVE الآن...")
                     yt.liveBroadcasts().transition(broadcastStatus="live", id=broadcast_id, part="status").execute()
-                    write_log(f"[🔥 SUCCESS] البث الآن مباشر وظاهر للجميع على يوتيوب! ID: {broadcast_id}")
+                    write_log(f"[🔥 SUCCESS] البث المباشر انطلق الآن ومستقر ومحمي بالبافر بالكامل! ID: {broadcast_id}")
                     return
                 except Exception as transition_error:
-                    write_log(f"[API Note] يوتيوب لم يستقر بعد لقبل أمر الـ Live، جاري إعادة المحاولة... ({transition_error})")
+                    write_log(f"[API Note] يوتيوب يقوم بمعالجة البافر حالياً، إعادة المحاولة بعد قليل... ({transition_error})")
+                    time.sleep(5)
         except Exception as e:
-            write_log(f"[Live Monitor Error] خطأ أثناء فحص حالة الإشارة: {e}")
+            write_log(f"[Live Monitor Error] خطأ في فحص الإشارة: {e}")
+            time.sleep(5)
             
-    write_log("[⚠️ ALERT] انتهت مهلة الفحص ولم يتمكن الكود من تحويل البث لـ LIVE تلقائياً، يرجى فحص لوج الأخطاء أعلاه.")
+    write_log("[⚠️ ALERT] انتهت مهلة الفحص، يرجى مراجعة سجل الأخطاء لمعرفة سبب امتناع يوتيوب عن التحويل.")
 
 # ══════════════════════════════════════════════════════════════════════════════ #
 # دالة إنهاء البث الحالي وحفظ الأرشيف ملحقاً بالتاريخ في نهايته
@@ -168,7 +172,7 @@ def monitor_and_switch_to_live(yt, broadcast_id):
 def close_dynamic_youtube_stream(yt, broadcast_id):
     try:
         if not broadcast_id: return
-        write_log(f"[API] جاري إنهاء البث {broadcast_id} وإلحاق التاريخ بالأرشيف...")
+        write_log(f"[API] جاري إنهاء البث {broadcast_id} وحفظه في الأرشيف...")
         
         try:
             b_data = yt.liveBroadcasts().list(id=broadcast_id, part="snippet").execute()
@@ -178,16 +182,16 @@ def close_dynamic_youtube_stream(yt, broadcast_id):
                 snippet["title"] = f"{snippet.get('title', 'بث مباشر')} - {current_date}"
                 snippet["description"] = f"{snippet.get('description', '')}\n\nتم إنهاء الأرشفة بنجاح بتاريخ: {current_date}"
                 yt.liveBroadcasts().update(part="snippet", body={"id": broadcast_id, "snippet": snippet}).execute()
-        except Exception as ue:
-            write_log(f"[API Error] فشل تحديث عنوان الأرشيف: {ue}")
+        except Exception:
+            pass
 
         yt.liveBroadcasts().transition(broadcastStatus="complete", id=broadcast_id, part="status").execute()
-        write_log(f"[API] تم قفل البث {broadcast_id} بنجاح وتحويله إلى فيديو مؤرشف.")
+        write_log(f"[API] تم قفل البث وتحويله بنجاح إلى أرشيف مستقل بالقناة.")
     except Exception as e:
         write_log(f"[API Error] خطأ أثناء إغلاق البث: {e}")
 
 # ══════════════════════════════════════════════════════════════════════════════ #
-# محرك المراقبة المدمج بنظام الجلسات الذكية واللوج
+# محرك المراقبة المدمج بنظام البافر والجلسات الذكية
 # ══════════════════════════════════════════════════════════════════════════════ #
 def run_monitor():
     lock_file = open(LOCK_FILE, 'w')
@@ -213,7 +217,7 @@ def run_monitor():
             if is_streaming and (process is None or process.poll() is not None):
                 is_streaming = False
                 process = None
-                write_log("[System] انقطع اتصال البث بشكل غير متوقع من المصدر.")
+                write_log("[System] انقطع اتصال البث من المصدر.")
                 close_dynamic_youtube_stream(yt, current_broadcast_id)
                 current_broadcast_id = None
                 with open(STATUS, "w") as f: json.dump({"live": False, "msg": "انقطع الاتصال..."}, f)
@@ -225,7 +229,7 @@ def run_monitor():
                 offline_start_time = None
                 if not is_streaming:
                     write_log(f"[Radar] 🔴 تم رصد بث مباشر للحساب {TIKTOK_USERNAME} على تيك توك!")
-                    with open(STATUS, "w") as f: json.dump({"live": False, "msg": "تم رصد بث جديد! جاري إنشاء غرفة بث وتوليد مفتاح ذكي على يوتيوب..."}, f)
+                    with open(STATUS, "w") as f: json.dump({"live": False, "msg": "تم رصد بث جديد! جاري تجميع البافر والتهيئة..."}, f)
                     
                     broadcast_id, dynamic_key = create_dynamic_youtube_stream(yt)
                     
@@ -234,23 +238,25 @@ def run_monitor():
                         cookie_string = get_clean_tiktok_cookies()
                         header_option = f'--http-header "Cookie={cookie_string}"' if cookie_string else ""
                         
-                        write_log("[FFMPEG] جاري بدء تشغيل الـ streamlink والـ ffmpeg لضخ البيانات...")
+                        write_log("[FFMPEG] جاري تشغيل خط المعالجة وضخ البيانات مع تفعيل التخزين المؤقت الممتد (Buffer)...")
+                        
+                        # 🔥 تعديل الـ FFMPEG: أضفنا -live_start_index -20 لجمع القطع السابقة و -max_interleave_delta لملء البافر لمنع شاشة الرمادي
                         cmd = (
-                            f'streamlink --loglevel error {header_option} "https://www.tiktok.com/{TIKTOK_USERNAME}/live" best --hls-live-edge 3 --stdout | '
-                            f"ffmpeg -hide_banner -loglevel error -thread_queue_size 8192 -i pipe:0 "
+                            f'streamlink --loglevel error {header_option} "https://www.tiktok.com/{TIKTOK_USERNAME}/live" best --hls-live-edge 5 --stdout | '
+                            f"ffmpeg -hide_banner -loglevel error -thread_queue_size 16384 -i pipe:0 "
                             f"-c:v copy -c:a aac -ar 48000 -b:a 192k -ac 2 "
                             f"-af 'highpass=f=200,lowpass=f=3000,aresample=async=1' "
-                            f"-buffer_size 4096k -fflags +genpts+igndts -max_interleave_delta 0 "
+                            f"-buffer_size 8192k -max_delay 50000000 -fflags +genpts+igndts -max_interleave_delta 0 "
                             f"-f flv 'rtmp://a.rtmp.youtube.com/live2/{dynamic_key}'"
                         )
                         process = subprocess.Popen(cmd, shell=True)
                         is_streaming = True
                         with open(STATUS, "w") as f: json.dump({"live": True}, f)
                         
-                        # تفعيل الخيط الذكي لمراقبة الإشارة وتفعيل الـ Live في يوتيوب
+                        # تشغيل خيط فحص البافر وإطلاق الـ Live بعد التأخير المطلق
                         threading.Thread(target=monitor_and_switch_to_live, args=(yt, broadcast_id), daemon=True).start()
                     else:
-                        write_log("[System Error] تم إلغاء البث الحالي بسبب فشل تهيئة الـ API.")
+                        write_log("[System Error] إلغاء الجلسة بسبب فشل تهيئة الـ API.")
                         with open(STATUS, "w") as f: json.dump({"live": False, "msg": "فشل إنشاء البث، جاري المحاولة لاحقاً..."}, f)
             
             else:
@@ -268,7 +274,7 @@ def run_monitor():
             
             time.sleep(POLL_INTERVAL)
         except Exception as main_e:
-            write_log(f"[Core Loop Error] خطأ في الحلقة الرئيسية للرادار: {main_e}")
+            write_log(f"[Core Loop Error] خطأ في الحلقة الرئيسية: {main_e}")
             time.sleep(POLL_INTERVAL)
 
 # تشغيل خيط الرادار
@@ -277,7 +283,7 @@ if "core_monitor_initialized" not in st.session_state:
     st.session_state.core_monitor_initialized = True
 
 # ══════════════════════════════════════════════════════════════════════════════ #
-# واجهة العرض (Streamlit UI) مع شاشة عرض اللوج
+# واجهة العرض (Streamlit UI)
 # ══════════════════════════════════════════════════════════════════════════════ #
 st.set_page_config(page_title="AutoStream Pro", page_icon="📡", layout="wide")
 st.title("📡 رادار البث الآلي الذكي بالكامل")
@@ -295,7 +301,7 @@ with col1:
 
     s = get_status()
     if s.get("live"):
-        st.success(f"🔴 حساب {TIKTOK_USERNAME} مباشر الآن على يوتيوب بنجاح")
+        st.success(f"🔴 حساب {TIKTOK_USERNAME} مباشر على يوتيوب بنجاح (محمي بنظام البافر)")
     else:
         st.info(s.get("msg", "بانتظار المذيع..."))
 
@@ -307,7 +313,6 @@ with col2:
     if os.path.exists(LOG_FILE):
         with open(LOG_FILE, "r", encoding="utf-8") as lf:
             logs = lf.readlines()
-        # عرض آخر 40 سطر من اللوج في صندوق مخصص للـ Debug
         st.code("".join(logs[-40:]), language="text")
     else:
-        st.text("لا توجد سجلات لوج حالياً، انتظر بدء تشغيل الرادار.")
+        st.text("بانتظار تسجيل أولى البيانات من الرادار...")