Update app.py

app.py

@@ -5,7 +5,7 @@ import threading
 import json
 import pickle
 import psutil
-from datetime import datetime, timezone, timedelta
+from datetime import datetime, timezone
 from google.oauth2.credentials import Credentials
 from google.auth.transport.requests import Request
 from googleapiclient.discovery import build
@@ -60,7 +60,7 @@ def kill_process_tree(pid):
 def get_tiktok_stream_url():
     try:
         url = f"https://www.tiktok.com/{TIKTOK_USERNAME}/live"
-        cmd = ["streamlink", "--stream-url", url, "best,720p,480p", "--retry-streams", "5", "--retry-open", "3"]
+        cmd = ["streamlink", "--stream-url", url, "best", "--retry-streams", "5", "--retry-open", "3"]
         if os.path.exists("/tmp/tiktok_cookies_adult.txt"):
             cmd.extend(["--cookies", "/tmp/tiktok_cookies_adult.txt"])
         elif os.path.exists("/tmp/tiktok_cookies.txt"):
@@ -84,28 +84,30 @@ def get_tiktok_stream_url():
 
 def start_stream(stream_key, stream_url):
     if not stream_key or not stream_url: return None
-    log("🎬 بدء البث (الأبعاد الطولية الحقيقية لمنع الاقتصاص)...")
+    log("🎬 بدء البث (تحويل الفيديو H.264 + فلاتر صوتية + تخطي الحظر)...")
     rtmp_url = f"rtmp://a.rtmp.youtube.com/live2/{stream_key}"
-    
+    try: subprocess.run(["killall", "-9", "ffmpeg", "yt-dlp", "streamlink"], stderr=subprocess.DEVNULL)
+    except: pass
     cmd = [
         "nice", "-n", "19", "ffmpeg", "-hide_banner", "-loglevel", "warning",
         "-thread_queue_size", "2048",
         "-user_agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36",
         "-headers", "Referer: https://www.tiktok.com/\r\n",
-        
-        "-rw_timeout", "15000000",
-        "-fflags", "+genpts+discardcorrupt", "-flags", "+global_header", "-i", stream_url,
-        
-        "-c:v", "libx264", "-preset", "ultrafast", "-b:v", "2500k", "-maxrate", "2500k", "-bufsize", "5000k", 
-        "-pix_fmt", "yuv420p", "-g", "60", "-r", "30", "-fps_mode", "cfr",
-        
-        # التعديل البرمجي هنا: تغيير الأبعاد إلى الطولية 1080x1920 وملاءمتها بالكامل لحماية الصورة من القص
-        "-vf", "scale=1080:1920:force_original_aspect_ratio=decrease,pad=1080:1920:(ow-iw)/2:(oh-ih)/2,setsar=1",
-
-        "-c:a", "aac", "-b:a", "192k", "-ar", "44100", "-profile:a", "aac_low", 
-        "-af", "aresample=async=1:first_pts=0",
-        
-        "-rtmp_live", "live", "-max_muxing_queue_size", "2048", "-f", "flv", rtmp_url
+        "-fflags", "+genpts+discardcorrupt+igndts",  # إصلاح التزامن
+        "-flags", "+global_header",
+        "-reconnect", "1",
+        "-reconnect_at_eof", "1",
+        "-reconnect_delay_max", "60",
+        "-i", stream_url,
+        "-c:v", "libx264", "-preset", "ultrafast", "-b:v", "2500k",
+        "-maxrate", "2500k", "-bufsize", "5000k",
+        "-pix_fmt", "yuv420p",
+        "-g", "60",
+        "-c:a", "aac", "-b:a", "192k", "-ar", "44100",
+        "-profile:a", "aac_low",
+        "-af", "aresample=async=1000:min_hard_comp=0.100000:first_pts=0,highpass=f=50,lowpass=f=15000,dynaudnorm=f=150:g=15:m=25:p=0.95",
+        "-max_muxing_queue_size", "2048",
+        "-f", "flv", rtmp_url
     ]
     with open(FFMPEG_LOG, "w") as stderr_file:
         proc = subprocess.Popen(cmd, stdout=subprocess.DEVNULL, stderr=stderr_file, preexec_fn=os.setsid)
@@ -140,17 +142,15 @@ def create_new_broadcast():
         yt = build_youtube_client()
         if not yt: return None, None
         
-        baghdad_tz = timezone(timedelta(hours=3))
-        now = datetime.now(baghdad_tz)
+        now = datetime.now(timezone.utc)
         date_str = now.strftime('%d-%m-%Y %H:%M')
-        
         title = f"🔥 بث تيك توك أعدام المباشر | {date_str} 🚀"
         description = (
-            "أهلاً بكم في البث المباشر المخصص لـ دكتور أعدام.\n"
+            "أهلاً بكم في البث المباشر المخصص لـ أعدام.\n"
             "استمتعوا معنا بأجواء البث وتفاعلوا في التعليقات!\n\n"
             "🔔 لا تنسوا الاشتراك في القناة وتفعيل زر التنبيهات ليصلكم كل جديد فور انطلاق البث.\n"
             "شكراً لدعمكم المتواصل!\n\n"
-            "#دكتور_إعدام #بث_مباشر #تيك_توك #TikTokLive #الاردن #بث #مباشر #a3dam_111"
+            "#أعدام #بث_مباشر #تيك_توك #TikTokLive #الاردن #بث #مباشر #a3dam_111"
         )
         
         insert_body = {
@@ -167,7 +167,6 @@ def create_new_broadcast():
         bid = new_broadcast["id"]
         log(f"✅ بث جديد: {bid} | {title}")
         
-        # ملاحظة: يوتيوب يتعرف تلقائياً على البث الطولي بناءً على أبعاد دفق الـ ffmpeg المرسل (1080x1920)
         stream_insert = yt.liveStreams().insert(
             part="snippet,cdn,contentDetails",
             body={"snippet": {"title": "TikTok Stream Key"}, "cdn": {"ingestionType": "rtmp", "resolution": "1080p", "frameRate": "30fps"}, "contentDetails": {"isReusable": True}}
@@ -184,41 +183,62 @@ def create_new_broadcast():
         log(f"❌ فشل إنشاء بث جديد: {e}")
         return None, None
 
-def finalize_all_broadcasts():
+# ✅ دالة جديدة: تنظيف البث السابق لنفس المساحة فقط
+def cleanup_own_previous_broadcast():
+    """تنهي بثاً سابقاً لهذه المساحة فقط (إن وُجد وما زال مفتوحاً)"""
+    if not os.path.exists(BROADCAST_FILE):
+        return
     try:
+        with open(BROADCAST_FILE, "r") as f:
+            data = json.load(f)
+        bid = data.get("broadcast_id")
+        if not bid:
+            return
         yt = build_youtube_client()
-        if not yt: return
-        broadcasts = yt.liveBroadcasts().list(mine=True, part="id,status").execute()
-        for item in broadcasts.get("items", []):
-            bid = item["id"]
-            status = item.get("status", {}).get("lifeCycleStatus", "")
-            if status in ["ready", "created", "live", "testing"]:
-                try:
-                    yt.liveBroadcasts().transition(broadcastStatus="complete", id=bid, part="status").execute()
-                except: pass
-    except: pass
+        if not yt:
+            return
+        # جلب حالة البث
+        resp = yt.liveBroadcasts().list(id=bid, part="status").execute()
+        items = resp.get("items", [])
+        if not items:
+            os.remove(BROADCAST_FILE)
+            return
+        status = items[0]["status"]["lifeCycleStatus"]
+        if status in ["live", "ready", "created", "testing"]:
+            log(f"🧹 إنهاء بث سابق لهذه المساحة: {bid}")
+            yt.liveBroadcasts().transition(broadcastStatus="complete", id=bid, part="status").execute()
+        # نحذف الملف على أية حال لأننا سننشئ بثاً جديداً
+        os.remove(BROADCAST_FILE)
+    except Exception as e:
+        log(f"⚠️ تعذر تنظيف البث السابق: {e}")
+        if os.path.exists(BROADCAST_FILE):
+            os.remove(BROADCAST_FILE)
 
 def finalize_current_broadcast(broadcast_id):
     if not broadcast_id: return
-    log(f"⚠️ جاري إغلاق البث على يوتيوب رسمياً... ID: {broadcast_id}")
     try:
         yt = build_youtube_client()
         if not yt: return
         yt.liveBroadcasts().transition(broadcastStatus="complete", id=broadcast_id, part="status").execute()
-        log("✅ تم إغلاق البث في يوتيوب بنجاح.")
-    except Exception as e: 
-        log(f"❌ خطأ أثناء إغلاق البث: {e}")
-        pass
-    if os.path.exists(BROADCAST_FILE): os.remove(BROADCAST_FILE)
+        log(f"🛑 تم إنهاء البث: {broadcast_id}")
+    except Exception as e:
+        log(f"⚠️ فشل إنهاء البث: {e}")
+    if os.path.exists(BROADCAST_FILE):
+        os.remove(BROADCAST_FILE)
 
 # ------------------------------------------------------------
 # المحرك الرئيسي
 # ------------------------------------------------------------
 def monitor_loop():
+    try: subprocess.run(["killall", "-9", "ffmpeg", "yt-dlp", "streamlink"], stderr=subprocess.DEVNULL)
+    except: pass
     time.sleep(2)
     if os.path.exists(LOCK_FILE): return
     with open(LOCK_FILE, "w") as f: f.write(str(os.getpid()))
-    finalize_all_broadcasts()
+    
+    # ✅ تنظيف بث هذه المساحة فقط (وليس كل البثوث)
+    cleanup_own_previous_broadcast()
+    
     ffmpeg_proc = None
     was_streaming = False
     consecutive_fails = 0
@@ -229,19 +249,18 @@ def monitor_loop():
         try:
             stream_url = get_tiktok_stream_url()
             if stream_url:
-                if consecutive_fails > 0:
-                    log("✅ تم التقاط رابط التيك توك مجدداً بعد الانقطاع.")
                 consecutive_fails = 0
-                
-                if was_streaming and ffmpeg_proc and ffmpeg_proc.poll() is None: pass
+                if was_streaming and ffmpeg_proc and ffmpeg_proc.poll() is None:
+                    pass
                 elif was_streaming and ffmpeg_proc and ffmpeg_proc.poll() is not None:
                     kill_process_tree(ffmpeg_proc.pid)
                     ffmpeg_proc = start_stream(current_stream_key, stream_url)
                 else:
                     if not current_broadcast_id:
-                        finalize_all_broadcasts()
+                        # لا ننهي كل البثوث، فقط ننشئ بثًا جديدًا (المساحة الأخرى مستقلة)
                         stream_key, bid = create_new_broadcast()
-                        if not stream_key: stream_key = CUSTOM_STREAM_KEY
+                        if not stream_key:
+                            stream_key = CUSTOM_STREAM_KEY
                         current_broadcast_id = bid
                         current_stream_key = stream_key
                     ffmpeg_proc = start_stream(current_stream_key, stream_url)
@@ -249,20 +268,17 @@ def monitor_loop():
             else:
                 if was_streaming:
                     consecutive_fails += 1
-                    log(f"⚠️ تعذر جلب رابط التيك توك. محاولة رقم {consecutive_fails}/20")
-                    
-                    # تم زيادة مدة الانتظار إلى 20 محاولة (حوالي 10 دقائق)
-                    if consecutive_fails >= 20:
-                        log("❌ انقضى وقت الانتظار (10 دقائق) والمذيع لم يعد أو الرابط انقطع نهائياً. سيتم إنهاء البث.")
+                    if consecutive_fails >= 6:
                         if ffmpeg_proc: kill_process_tree(ffmpeg_proc.pid)
                         ffmpeg_proc = None
                         was_streaming = False
                         if current_broadcast_id:
                             finalize_current_broadcast(current_broadcast_id)
                             current_broadcast_id = None
+                            current_stream_key = None
             time.sleep(30)
         except Exception as e:
-            log(f"❌ خطأ غير متوقع في اللوب: {e}")
+            log(f"❌ خطأ في حلقة المراقبة: {e}")
             time.sleep(30)
 
 app = Flask(__name__)