Update app.py

app.py

@@ -220,3 +220,70 @@ async def download_hls_video(request: Request):
     download_url = f"{base_url}file/{encoded_filename}"
     gc.collect()
     return {"url": download_url}
+    
+
+@app.post("/maxs")
+async def download_high_quality_video(request: Request):
+    user_ip = get_user_ip(request)
+    
+    if rate_limiter.is_rate_limited(user_ip):
+        current_count = rate_limiter.get_current_count(user_ip)
+        raise HTTPException(
+            status_code=429,
+            detail={
+                "error": "You have exceeded the maximum number of requests per day. Please try again tomorrow.",
+                "url": "https://t.me/chrunoss"
+            }
+        )
+        
+    data = await request.json()
+    
+    video_url = data.get('url')
+    if "t.me" in video_url or "chrunos.com" in video_url:
+        return {"error": f"{video_url} is not supported", "url": "https://t.me/chrunoss"}
+        
+    quality = data.get('quality', '720')  # Default to 720 if not specified
+    logger.info(f'input: {video_url}, {quality}')
+
+    # Check if the requested quality is above 1080p
+    if int(quality) > 720:
+        error_message = "Quality above 720p is for Premium Members Only. Please check the URL for more information."
+        help_url = "https://chrunos.com/premium-shortcuts/"  # Replace with your actual URL
+        return {"error": error_message, "url": help_url}
+
+    timestamp = datetime.now().strftime('%Y%m%d%H%M%S')
+    output_template = str(Path(global_download_dir) / f'%(title).70s_{timestamp}.%(ext)s')
+
+    # Convert quality string to height
+    height_map = {
+        '480': 480,
+        '720': 720,
+        '1080': 1080
+    }
+    max_height = height_map.get(quality, 1080)  # Use the quality variable correctly
+
+    # Determine format string based on quality
+    format_str = f'bestvideo[height<={max_height}][vcodec^=avc]+bestaudio/best'
+
+    ydl_opts = {
+        'format': format_str,
+        'outtmpl': output_template,
+        'quiet': True,
+        'no_warnings': True,
+        'noprogress': True,
+        'merge_output_format': 'mp4'
+    }
+
+    await run_in_threadpool(lambda: yt_dlp.YoutubeDL(ydl_opts).download([video_url]))
+
+    downloaded_files = list(Path(global_download_dir).glob(f"*_{timestamp}.mp4"))
+    if not downloaded_files:
+        return {"error": "Download failed. Report error on Telegram", "url": "https://t.me/chrunoss"}
+
+    downloaded_file = downloaded_files[0]
+    encoded_filename = urllib.parse.quote(downloaded_file.name)
+    download_url = f"{BASE_URL}/file/{encoded_filename}"   
+
+    gc.collect()
+
+    return {"url": download_url}