Update mirror.py

mirror.py

@@ -1,6 +1,6 @@
 import sys
 import os
-import subprocess
+import ssl
 import pickle
 from googleapiclient.discovery import build
 from googleapiclient.http import MediaFileUpload
@@ -9,6 +9,9 @@ from google.auth.transport.requests import Request
 TOKEN_FILE = '/app/token.pickle'
 VIDEO_PATH = '/app/mirror_video.mp4'
 
+# Fix SSL issues globally
+ssl._create_default_https_context = ssl._create_unverified_context
+
 def get_credentials():
     creds = None
     if os.path.exists(TOKEN_FILE):
@@ -21,28 +24,30 @@ def get_credentials():
     return creds
 
 def download_from_youtube(video_id, output_path):
+    from pytubefix import YouTube
+    from pytubefix.cli import on_progress
+
     url = f"https://www.youtube.com/watch?v={video_id}"
     print(f"Downloading: {url}")
 
     if os.path.exists(output_path):
         os.remove(output_path)
 
-    result = subprocess.run([
-        'yt-dlp',
-        '-f', 'bestvideo[ext=mp4]+bestaudio[ext=m4a]/best[ext=mp4]/best',
-        '--merge-output-format', 'mp4',
-        '-o', output_path,
-        '--no-playlist',
-        '--extractor-args', 'youtube:player_client=ios',
-        '--user-agent', 'com.google.ios.youtube/19.29.1 (iPhone16,2; U; CPU iOS 17_5_1 like Mac OS X;)',
-        '--add-header', 'X-Youtube-Client-Name:5',
-        '--add-header', 'X-Youtube-Client-Version:19.29.1',
-        url
-    ], capture_output=True, text=True)
-
-    if result.returncode != 0:
-        raise Exception(f"yt-dlp failed: {result.stderr}")
+    yt = YouTube(url, on_progress_callback=on_progress, use_oauth=False, allow_oauth_cache=False)
+    print(f"Title: {yt.title}")
+
+    # Get highest resolution progressive stream (audio+video together)
+    stream = yt.streams.filter(progressive=True, file_extension='mp4').order_by('resolution').last()
+
+    if not stream:
+        # Fallback to any mp4
+        stream = yt.streams.filter(file_extension='mp4').first()
+
+    if not stream:
+        raise Exception("No suitable stream found!")
 
+    print(f"Downloading stream: {stream.resolution} {stream.mime_type}")
+    stream.download(filename=output_path)
     print("Download complete!")
 
 def upload_to_channel_b(title, description):