Upload main.py

main.py

@@ -1,5 +1,5 @@
-"""VNEWS - FastAPI backend: livescore, highlights, VTV channels, World Cup 2026, news"""
-import re, time, json, os, threading
+"""VNEWS - FastAPI backend with livescore + xemlaibongda highlights + VTV channels"""
+import re, time, subprocess, json, os, threading
 import html as html_lib
 from datetime import datetime, timezone, timedelta
 from collections import defaultdict
@@ -35,8 +35,7 @@ def _check_rate_limit(ip: str) -> bool:
 async def rate_limit_middleware(request: Request, call_next):
     if request.url.path.startswith("/api/"):
         ip = request.client.host
-        if not _check_rate_limit(ip):
-            return JSONResponse({"error": "rate limit exceeded"}, status_code=429)
+        if not _check_rate_limit(ip): return JSONResponse({"error": "rate limit exceeded"}, status_code=429)
     return await call_next(request)
 
 # ===== VTV CHANNELS API =====
@@ -49,6 +48,7 @@ BASE_BDP = "https://bongdaplus.vn"
 _cache = {}
 _cache_ttl = 300
 _cache_ttl_live = 60
+_cache_ttl_yt = 1800
 
 PRIORITY_LEAGUES = ["Ngoại Hạng Anh","FA Cup","Champions League","LaLiga","Copa del Rey","Serie A","Bundesliga","Ligue 1","V-League"]
 LEAGUE_IDS = {"nha":27110,"laliga":27233,"seriea":27044,"bundesliga":26891,"ligue1":27212}
@@ -253,17 +253,6 @@ def extract_xemlaibongda_video(url):
         return None
     except: return None
 
-# ===== VTV Nam Bộ Shorts (yt-dlp based) =====
-from yt_scraper import get_vtvnambo_shorts, get_wc_related_shorts
-
-@app.get("/api/shorts/vtvnamo")
-def api_shorts_vtvnamo(count: int = Query(default=50, le=100)):
-    return JSONResponse(get_vtvnambo_shorts(count))
-
-@app.get("/api/shorts/wc")
-def api_shorts_wc(count: int = Query(default=50, le=100)):
-    return JSONResponse(get_wc_related_shorts(count))
-
 # ===== LIVESCORE =====
 @app.get("/api/livescore/live")
 def api_livescore_live(): return JSONResponse({"html":_cached("ls_live",lambda:fetch_bongda_api("/api/fixtures/live"),ttl=_cache_ttl_live)})
@@ -528,4 +517,4 @@ def api_hot_topics():
 
 @app.get("/", response_class=HTMLResponse)
 async def root():
-    return HTMLResponse("<h1>VNEWS v16</h1><p>VTV Digital CDN + xemtivitop.com · Dantri/SKDS removed</p>")
+    return HTMLResponse("<h1>VNEWS v17</h1><p>VTV Digital CDN ssaimh · No shorts Dantri/SKDS · Homepage full content</p>")