Update streamlit_app.py

streamlit_app.py

@@ -14,13 +14,12 @@ from TikTokLive import TikTokLiveClient
 TIKTOK_USERNAME = "@ah_md107" 
 STATUS = "/tmp/status.json"
 LOCK_FILE = "/tmp/app_monitor_core.lock" 
-POLL_INTERVAL = 40 
+POLL_INTERVAL = 60  # زيادة الفاصل الزمني لتجنب حظر الـ IP
 GRACE_PERIOD_SECONDS = 120 
-# البث سيعتمد حصراً على هذا المفتاح الثابت دون تعديل عناوين
 CUSTOM_STREAM_KEY = os.getenv("CUSTOM_STREAM_KEY", "skqf-rd92-dfa7-74cx-bxr2")
 
 # ══════════════════════════════════════════════════════════════════════════════ #
-# محرك المراقبة (مباشر على المفتاح + إغلاق آمن)
+# محرك المراقبة الذكي
 # ══════════════════════════════════════════════════════════════════════════════ #
 def run_monitor():
     lock_file = open(LOCK_FILE, 'w')
@@ -33,13 +32,20 @@ def run_monitor():
     
     while True:
         try:
+            # 1. التحقق من سلامة عملية البث الفعلية (System Health Check)
+            if is_streaming and (process is None or process.poll() is not None):
+                is_streaming = False
+                process = None
+                with open(STATUS, "w") as f: json.dump({"live": False, "msg": "انقطع الاتصال، بانتظار المذيع..."}, f)
+
+            # 2. فحص حالة اللايف في تيك توك
             client = TikTokLiveClient(unique_id=TIKTOK_USERNAME)
             is_live = asyncio.run(client.is_live())
             
             if is_live:
                 offline_start_time = None
                 if not is_streaming:
-                    # إطلاق البث فوراً على المفتاح الثابت
+                    # بدء البث على المفتاح الثابت
                     cmd = (
                         f"streamlink https://www.tiktok.com/{TIKTOK_USERNAME}/live best --hls-live-edge 3 --stdout | "
                         f"ffmpeg -thread_queue_size 8192 -i pipe:0 -c:v copy -c:a aac -ar 48000 -b:a 192k -ac 2 "
@@ -53,7 +59,7 @@ def run_monitor():
                 if is_streaming:
                     if offline_start_time is None: offline_start_time = time.time()
                     
-                    # إذا انتهت مهلة الأمان، نغلق العملية
+                    # إغلاق آمن بعد مهلة الأمان
                     if time.time() - offline_start_time >= GRACE_PERIOD_SECONDS:
                         if process: process.terminate()
                         is_streaming = False
@@ -64,16 +70,30 @@ def run_monitor():
         except Exception:
             time.sleep(POLL_INTERVAL)
 
-# تشغيل الخيط
+# تشغيل المحرك في الخلفية
 if "core_monitor_initialized" not in st.session_state:
     threading.Thread(target=run_monitor, name="CoreTikTokMonitor", daemon=True).start()
     st.session_state.core_monitor_initialized = True
 
 # ══════════════════════════════════════════════════════════════════════════════ #
-# الواجهة (عرض الحالة فقط)
+# الواجهة (Streamlit)
 # ══════════════════════════════════════════════════════════════════════════════ #
-st.title("📡 رادار بث أحمد عبدالله - المباشر السريع")
-if os.path.exists(STATUS):
-    with open(STATUS, "r") as f: s = json.load(f)
-    if s.get("live"): st.success("🔴 أحمد عبدالله مباشر على المفتاح الثابت!"); 
-    else: st.info(s.get("msg", "بانتظار المذيع..."))
+st.set_page_config(page_title="AutoStreamer Pro", page_icon="📡")
+st.title("📡 رادار بث أحمد عبدالله - النسخة المستقرة")
+
+def get_status():
+    if not os.path.exists(STATUS) or os.path.getsize(STATUS) == 0:
+        return {"live": False, "msg": "جاري فحص حالة البث..."}
+    try:
+        with open(STATUS, "r") as f: return json.load(f)
+    except: return {"live": False, "msg": "بانتظار المذيع..."}
+
+s = get_status()
+if s.get("live"):
+    st.success("🔴 أحمد عبدالله مباشر الآن!")
+    st.info(f"يتم البث عبر المفتاح الثابت: {CUSTOM_STREAM_KEY[:5]}****")
+else:
+    st.info(s.get("msg", "بانتظار المذيع..."))
+
+if st.button("🔄 تحديث حالة الرادار"):
+    st.rerun()