Update app.py

app.py

@@ -5,26 +5,22 @@ import threading
 import json
 import pickle
 import psutil
-from datetime import datetime, timezone
+from datetime import datetime, timezone, timedelta
 from google.oauth2.credentials import Credentials
 from google.auth.transport.requests import Request
 from googleapiclient.discovery import build
 from flask import Flask
 
 # ------------------------------------------------------------
-# الإعدادات الأساسية (تتغير ديناميكياً لتفادي تداخل المشاريع)
+# الإعدادات الأساسية
 # ------------------------------------------------------------
 TIKTOK_USERNAME = "@a3dam_111"
-
-# استخراج اسم نقي للملفات لمنع التداخل والاصطدام بين السكربتات الشغالة معاً
-USER_TAG = TIKTOK_USERNAME.replace("@", "").strip()
-
 CUSTOM_STREAM_KEY = os.getenv("CUSTOM_STREAM_KEY", "p3dq-5cex-bc1k-vet7-bsyx")
-FFMPEG_LOG = f"/tmp/ffmpeg_{USER_TAG}.log"
-MONITOR_LOG = f"/tmp/monitor_{USER_TAG}.log"
-LOCK_FILE = f"/tmp/app_monitor_core_{USER_TAG}.lock"
-TOKEN_FILE = f"/tmp/yt_token_{USER_TAG}.pkl"
-BROADCAST_FILE = f"/tmp/current_broadcast_{USER_TAG}.json"
+FFMPEG_LOG = "/tmp/ffmpeg.log"
+MONITOR_LOG = "/tmp/monitor.log"
+LOCK_FILE = "/tmp/app_monitor_core.lock"
+TOKEN_FILE = "/tmp/yt_token.pkl"
+BROADCAST_FILE = "/tmp/current_broadcast.json"
 
 TIKTOK_COOKIES = os.getenv("TIKTOK_COOKIES", "")
 TIKTOK_COOKIES_ADULT = os.getenv("TIKTOK_COOKIES_ADULT", "")
@@ -37,14 +33,14 @@ def log(msg):
         f.write(line + "\n")
 
 # ------------------------------------------------------------
-# حفظ الكوكيز باسم معزول
+# حفظ الكوكيز
 # ------------------------------------------------------------
 def save_cookies():
     if TIKTOK_COOKIES:
-        with open(f"/tmp/tiktok_cookies_{USER_TAG}.txt", "w") as f:
+        with open("/tmp/tiktok_cookies.txt", "w") as f:
             f.write(TIKTOK_COOKIES)
     if TIKTOK_COOKIES_ADULT:
-        with open(f"/tmp/tiktok_cookies_adult_{USER_TAG}.txt", "w") as f:
+        with open("/tmp/tiktok_cookies_adult.txt", "w") as f:
             f.write(TIKTOK_COOKIES_ADULT)
 
 save_cookies()
@@ -62,24 +58,24 @@ def kill_process_tree(pid):
         pass
 
 def get_tiktok_stream_url():
-    cookies_adult = f"/tmp/tiktok_cookies_adult_{USER_TAG}.txt"
-    cookies_normal = f"/tmp/tiktok_cookies_{USER_TAG}.txt"
-    
     try:
         url = f"https://www.tiktok.com/{TIKTOK_USERNAME}/live"
-        cmd = ["streamlink", "--stream-url", url, "best", "--retry-streams", "5", "--retry-open", "3"]
-        if os.path.exists(cookies_adult): cmd.extend(["--cookies", cookies_adult])
-        elif os.path.exists(cookies_normal): cmd.extend(["--cookies", cookies_normal])
+        cmd = ["streamlink", "--stream-url", url, "best,720p,480p", "--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"):
+            cmd.extend(["--cookies", "/tmp/tiktok_cookies.txt"])
         result = subprocess.run(cmd, capture_output=True, text=True, timeout=25)
         if result.returncode == 0 and result.stdout.strip():
             return result.stdout.strip().split("\n")[0]
     except: pass
-    
     try:
         url = f"https://www.tiktok.com/{TIKTOK_USERNAME}/live"
         cmd = ["yt-dlp", "--no-warnings", "--no-check-certificates", "--no-live-from-start", "--no-cache-dir", "--rm-cache-dir", "-f", "best", "--get-url", url]
-        if os.path.exists(cookies_adult): cmd.extend(["--cookies", cookies_adult])
-        elif os.path.exists(cookies_normal): cmd.extend(["--cookies", cookies_normal])
+        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"):
+            cmd.extend(["--cookies", "/tmp/tiktok_cookies.txt"])
         result = subprocess.run(cmd, capture_output=True, text=True, timeout=30)
         if result.returncode == 0 and result.stdout.strip():
             return result.stdout.strip().split("\n")[0]
@@ -88,34 +84,36 @@ def get_tiktok_stream_url():
 
 def start_stream(stream_key, stream_url):
     if not stream_key or not stream_url: return None
-    log("🎬 بدء البث (تزامن كامل الصوت والصورة + تحويل H.264)...")
+    log("🎬 بدء البث (الأبعاد الطولية الحقيقية لمنع الاقتصاص)...")
     rtmp_url = f"rtmp://a.rtmp.youtube.com/live2/{stream_key}"
     
-    # تم حذف سطر killall العام لمنع إغلاق السكربتات الأخرى الشغالة معاً
-    
     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",
         
-        # --- علاج مشكلة عدم تزامن الصوت والصورة عند تقطيع إنترنت المذيع ---
-        "-use_wallclock_as_timestamps", "1", 
-        "-fflags", "+genpts+igndts+discardcorrupt", 
-        "-flags", "+global_header", "-i", stream_url,
+        "-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",
         
-        # تثبيت الـ Framerate على 30 لسد الفجوات الزمنية عند سقوط الإطارات
-        "-c:v", "libx264", "-preset", "ultrafast", "-b:v", "2500k", "-maxrate", "2500k", "-bufsize", "5000k", "-pix_fmt", "yuv420p", "-g", "60", "-r", "30",
-        "-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",
-        "-reconnect", "1", "-reconnect_at_eof", "1", "-reconnect_delay_max", "60", "-rtmp_live", "live", "-max_muxing_queue_size", "2048", "-f", "flv", rtmp_url
+        "-rtmp_live", "live", "-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)
-    log(f"✅ ffmpeg PID: {proc.pid} للمستخدم {TIKTOK_USERNAME}")
+    log(f"✅ ffmpeg PID: {proc.pid}")
     return proc
 
 # ------------------------------------------------------------
-# YouTube API (الفحص والتعرف الذكي عبر البصمة الوصفية)
+# YouTube API
 # ------------------------------------------------------------
 def build_youtube_client():
     try:
@@ -142,33 +140,37 @@ def create_new_broadcast():
         yt = build_youtube_client()
         if not yt: return None, None
         
-        now = datetime.now(timezone.utc)
+        baghdad_tz = timezone(timedelta(hours=3))
+        now = datetime.now(baghdad_tz)
         date_str = now.strftime('%d-%m-%Y %H:%M')
-        title = f"🔥 بث تيك توك أعدام المباشر | {date_str} 🚀"
         
-        # حقن بصمة الحساب السرية داخل الوصف لمنع السكربتات الأخرى من حذفه
+        title = f"🔥 بث تيك توك أعدام المباشر | {date_str} 🚀"
         description = (
-            "أهلاً بكم في البث المباشر المخصص لـ دكتور إعدام.\n"
-            f"معرف الحساب المسؤول: [{TIKTOK_USERNAME}]\n"
+            "أهلاً بكم في البث المباشر المخصص لـ دكتور أعدام.\n"
             "استمتعوا معنا بأجواء البث وتفاعلوا في التعليقات!\n\n"
             "🔔 لا تنسوا الاشتراك في القناة وتفعيل زر التنبيهات ليصلكم كل جديد فور انطلاق البث.\n"
             "شكراً لدعمكم المتواصل!\n\n"
-            "#دكتور_إعدام #بث_مباشر #تيك_توك #TikTokLive #العراق #بث #مباشر #a3dam_111"
+            "#دكتور_إعدام #بث_مباشر #تيك_توك #TikTokLive #الاردن #بث #مباشر #a3dam_111"
         )
         
         insert_body = {
-            "snippet": {"title": title, "description": description, "scheduledStartTime": now.isoformat()},
+            "snippet": {
+                "title": title, 
+                "description": description,
+                "scheduledStartTime": now.isoformat()
+            },
             "status": {"privacyStatus": "public"},
             "contentDetails": {"enableAutoStart": True, "enableAutoStop": False, "latencyPreference": "normal"}
         }
         
         new_broadcast = yt.liveBroadcasts().insert(part="snippet,status,contentDetails", body=insert_body).execute()
         bid = new_broadcast["id"]
-        log(f"✅ بث جديد تم إنشاؤه للـ ID: {bid}")
+        log(f"✅ بث جديد: {bid} | {title}")
         
+        # ملاحظة: يوتيوب يتعرف تلقائياً على البث الطولي بناءً على أبعاد دفق الـ ffmpeg المرسل (1080x1920)
         stream_insert = yt.liveStreams().insert(
             part="snippet,cdn,contentDetails",
-            body={"snippet": {"title": f"TikTok Stream Key {USER_TAG}"}, "cdn": {"ingestionType": "rtmp", "resolution": "1080p", "frameRate": "30fps"}, "contentDetails": {"isReusable": True}}
+            body={"snippet": {"title": "TikTok Stream Key"}, "cdn": {"ingestionType": "rtmp", "resolution": "1080p", "frameRate": "30fps"}, "contentDetails": {"isReusable": True}}
         ).execute()
         stream_id = stream_insert["id"]
         stream_key = stream_insert["cdn"]["ingestionInfo"]["streamName"]
@@ -186,18 +188,13 @@ def finalize_all_broadcasts():
     try:
         yt = build_youtube_client()
         if not yt: return
-        # قراءة الـ snippet لفحص الوصف والتحقق من بصمة المشروع
-        broadcasts = yt.liveBroadcasts().list(mine=True, part="id,status,snippet", maxResults=50).execute()
+        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", "")
-            description = item.get("snippet", {}).get("description", "")
-            
-            # نغلق البث فقط وفقط إذا كان يحمل بصمة هذا المستخدم لعدم تدمير البث الآخر
-            if status in ["ready", "created", "live", "testing"] and f"[{TIKTOK_USERNAME}]" in description:
+            if status in ["ready", "created", "live", "testing"]:
                 try:
                     yt.liveBroadcasts().transition(broadcastStatus="complete", id=bid, part="status").execute()
-                    log(f"🧹 تم تنظيف وإغلاق بث قديم معلق يخص الحساب {TIKTOK_USERNAME}")
                 except: pass
     except: pass
 
@@ -211,21 +208,12 @@ def finalize_current_broadcast(broadcast_id):
     if os.path.exists(BROADCAST_FILE): os.remove(BROADCAST_FILE)
 
 # ------------------------------------------------------------
-# المحرك الرئيسي الآمن والمعزول كلياً
+# المحرك الرئيسي
 # ------------------------------------------------------------
 def monitor_loop():
-    # حذفنا أمر killall الشامل الذي كان يسبب انهيار السكربت الأول عند نهوض الثاني
-    if os.path.exists(LOCK_FILE):
-        try:
-            with open(LOCK_FILE) as f:
-                os.kill(int(f.read().strip()), 0)
-            log(f"🔒 محرك الحساب {TIKTOK_USERNAME} يعمل بالفعل بشكل مستقر.")
-            return
-        except:
-            os.remove(LOCK_FILE)
-
+    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()
     ffmpeg_proc = None
     was_streaming = False
@@ -233,8 +221,6 @@ def monitor_loop():
     current_stream_key = None
     current_broadcast_id = None
     
-    log(f"🚀 تم إطلاق محرك المراقبة الخاص بـ {TIKTOK_USERNAME} بأمان وبصمة منفصلة.")
-    
     while True:
         try:
             stream_url = get_tiktok_stream_url()
@@ -273,6 +259,4 @@ def index(): return "OK"
 if __name__ == "__main__":
     t = threading.Thread(target=monitor_loop, daemon=True)
     t.start()
-    
-    # تنبيه: إذا قمت بتشغيل السكربت الثاني على نفس السيرفر، يرجى تغيير الـ port هنا إلى 781 مثلاً
     app.run(host="0.0.0.0", port=7860, debug=False)