Update app.py

app.py

@@ -31,7 +31,7 @@ def log(msg):
         f.write(line + "\n")
 
 # ------------------------------------------------------------
-# حفظ الكوكيز
+# حفظ وفحص الكوكيز
 # ------------------------------------------------------------
 def save_cookies():
     if TIKTOK_COOKIES:
@@ -41,7 +41,21 @@ def save_cookies():
         with open("/tmp/tiktok_cookies_adult.txt", "w") as f:
             f.write(TIKTOK_COOKIES_ADULT)
 
-save_cookies()
+def check_cookies_validity(file_path):
+    """التحقق من أن الكوكيز بصيغة صحيحة وتحتوي على جلسة نشطة"""
+    if not os.path.exists(file_path):
+        return False
+    try:
+        with open(file_path, "r", encoding="utf-8") as f:
+            content = f.read()
+        # فحص هل الملف يحتوي على التوكن الأساسي لتيك توك
+        if "sessionid" in content or "tt_chain_token" in content:
+            return True
+        else:
+            return False
+    except Exception as e:
+        log(f"❌ خطأ أثناء فحص الكوكيز: {e}")
+        return False
 
 # ------------------------------------------------------------
 # أدوات مساعدة
@@ -106,20 +120,14 @@ def start_stream(stream_key, stream_url):
         "-hide_banner", "-loglevel", "warning",
         "-re",
         "-thread_queue_size", "2048",
-        "-fflags", "+genpts+igndts",          # طوابع زمنية جديدة وتجاهل التالف
+        "-fflags", "+genpts+igndts",
         "-i", stream_url,
-
-        # فيديو: نسخ مباشر
         "-c:v", "copy",
-
-        # صوت: ترميز AAC خفيف مع تصحيح التزامن فقط
         "-c:a", "aac",
         "-b:a", "192k",
         "-ar", "44100",
         "-af", "aresample=async=1:first_pts=0",
         "-async", "1",
-
-        # إعادة اتصال محسنة (مستقرة)
         "-reconnect", "1",
         "-reconnect_streamed", "1",
         "-reconnect_at_eof", "1",
@@ -140,7 +148,6 @@ def start_stream(stream_key, stream_url):
 # ------------------------------------------------------------
 def build_youtube_client():
     try:
-        # محاولة تحميل توكن موجود
         if os.path.exists(TOKEN_FILE):
             with open(TOKEN_FILE, "rb") as f:
                 creds = pickle.load(f)
@@ -152,7 +159,6 @@ def build_youtube_client():
                     pickle.dump(creds, f)
                 return build('youtube', 'v3', credentials=creds)
 
-        # إنشاء جديد من المتغير البيئي
         creds_json = os.getenv("YT_CREDENTIALS_JSON")
         if not creds_json:
             return None
@@ -164,7 +170,7 @@ def build_youtube_client():
             token_uri=data.get("token_uri"),
             client_id=data.get("client_id"),
             client_secret=data.get("client_secret"),
-            scopes=data.get("scopes", ["https://www.googleapis.com/auth/youtube.force-ssl"])
+            scopes=data.get("scopes", ["https://www.googleapis.com/auth/youtube.force-ssl", "https://www.googleapis.com/auth/youtube.readonly"])
         )
         if creds.expired and creds.refresh_token:
             creds.refresh(Request())
@@ -175,6 +181,22 @@ def build_youtube_client():
         log(f"❌ فشل بناء عميل YouTube: {e}")
         return None
 
+def log_youtube_channel_name(yt):
+    """جلب اسم قناة اليوتيوب المرتبطة بالتوكن وطباعتها"""
+    try:
+        request = yt.channels().list(part="snippet", mine=True)
+        response = request.execute()
+        if "items" in response and len(response["items"]) > 0:
+            channel_name = response["items"][0]["snippet"]["title"]
+            log(f"📺 تم بنجاح الاتصال بقناة اليوتيوب: 【 {channel_name} 】")
+            return channel_name
+        else:
+            log("⚠️ التوكن يعمل ولكن لم يتم العثور على قناة يوتيوب مرتبطة به!")
+            return None
+    except Exception as e:
+        log(f"❌ فشل جلب اسم القناة: {e}")
+        return None
+
 def create_live_stream(yt):
     try:
         stream_insert = yt.liveStreams().insert(
@@ -207,7 +229,6 @@ def bind_stream_to_broadcast(yt, broadcast_id, stream_id):
         return False
 
 def finalize_all_broadcasts():
-    """إنهاء جميع البثوث النشطة لبداية نظيفة"""
     try:
         yt = build_youtube_client()
         if not yt:
@@ -226,7 +247,6 @@ def finalize_all_broadcasts():
         log(f"❌ خطأ في التنظيف: {e}")
 
 def create_new_broadcast():
-    """إنشاء بث جديد كامل (API) وإرجاع المفتاح والمعرف"""
     try:
         yt = build_youtube_client()
         if not yt:
@@ -342,7 +362,6 @@ def monitor_loop():
 
                     stream_key = None
                     bid = None
-                    # المحاولة الأولى: YouTube API
                     stream_key, bid = create_new_broadcast()
                     if not stream_key:
                         log("⚠️ فشل API، استخدام المفتاح الاحتياطي...")
@@ -392,7 +411,30 @@ def monitor_loop():
             time.sleep(30)
 
 if __name__ == "__main__":
-    log("✅ بدء تشغيل المحرك النهائي (مستقر + API)")
+    log("✅ بدء تشغيل المحرك النهائي...")
+    
+    # حفظ الكوكيز وإجراء فحص مبدئي لها
+    save_cookies()
+    if os.path.exists("/tmp/tiktok_cookies.txt"):
+        if check_cookies_validity("/tmp/tiktok_cookies.txt"):
+            log("🎯 فحص الكوكيز: كوكيز الحساب العادي تبدو صالحة (تحتوي على جلسة).")
+        else:
+            log("🚨 فحص الكوكيز: كوكيز الحساب العادي تالفة أو فارغة!")
+            
+    if os.path.exists("/tmp/tiktok_cookies_adult.txt"):
+        if check_cookies_validity("/tmp/tiktok_cookies_adult.txt"):
+            log("🎯 فحص الكوكيز: كوكيز حساب البالغين (+18) تبدو صالحة.")
+        else:
+            log("🚨 فحص الكوكيز: كوكيز حساب البالغين تالفة أو فارغة!")
+
+    # فحص اليوتيوب ومعرفة اسم القناة
+    log("🔍 جاري الاتصال بخوادم اليوتيوب...")
+    yt_client = build_youtube_client()
+    if yt_client:
+        log_youtube_channel_name(yt_client)
+    else:
+        log("❌ لم يتم العثور على توكن يوتيوب صحيح أو حدث خطأ في الاتصال.")
+        
     t = threading.Thread(target=monitor_loop, daemon=True)
     t.start()
     while True: