Add persistent shorts stats/comments API (views, likes, shares, comments)

main.py

@@ -1,5 +1,5 @@
 """VNEWS - FastAPI backend with livescore + xemlaibongda highlights + YouTube FPT shorts"""
-import hashlib, re, time, subprocess, json
+import hashlib, re, time, subprocess, json, os, threading
 import html as html_lib
 from datetime import datetime
 from concurrent.futures import ThreadPoolExecutor, as_completed
@@ -19,6 +19,23 @@ _cache = {}
 _cache_ttl = 300
 _cache_ttl_live = 60
 _cache_ttl_yt = 1800
+SHORT_STATS_FILE = "/data/short_stats.json" if os.path.isdir("/data") else "/app/short_stats.json"
+_short_lock = threading.Lock()
+def _load_short_db():
+    try:
+        if os.path.exists(SHORT_STATS_FILE):
+            with open(SHORT_STATS_FILE,"r",encoding="utf-8") as f:return json.load(f)
+    except:pass
+    return {}
+def _save_short_db(db):
+    try:
+        os.makedirs(os.path.dirname(SHORT_STATS_FILE),exist_ok=True)
+        tmp=SHORT_STATS_FILE+".tmp"
+        with open(tmp,"w",encoding="utf-8") as f:json.dump(db,f,ensure_ascii=False)
+        os.replace(tmp,SHORT_STATS_FILE)
+    except:pass
+
+def _short_default():return {"views":0,"likes":0,"shares":0,"comments":[]}
 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}
 HL_LEAGUES = {"premier-league":{"path":"anh/premier-league","name":"Premier League","emoji":"🏴󠁧󠁢󠁥󠁮󠁧󠁿"},"fa-cup":{"path":"anh/fa-cup","name":"FA Cup","emoji":"🏆"},"bundesliga":{"path":"duc/bundesliga","name":"Bundesliga","emoji":"🇩🇪"},"serie-a":{"path":"italy/serie-a","name":"Serie A","emoji":"🇮🇹"},"la-liga":{"path":"tay-ban-nha/la-liga","name":"La Liga","emoji":"🇪🇸"},"champions-league":{"path":"cup-chau-au/uefa-champions-league","name":"Champions League","emoji":"⭐"},"europa-league":{"path":"cup-chau-au/uefa-europa-league","name":"Europa League","emoji":"🟠"},"world-cup":{"path":"the-gioi/world-cup-qualifiers","name":"World Cup 2026","emoji":"🌍"}}
@@ -246,6 +263,35 @@ def api_livescore_featured():
 # ===== VIDEO APIs =====
 @app.get("/api/shorts")
 def api_shorts():return JSONResponse(_cached("yt_shorts",scrape_shorts,ttl=_cache_ttl_yt))
+@app.get("/api/short-stats")
+def api_short_stats(ids:str=Query(default="")):
+    arr=[x for x in ids.split(",") if x]
+    with _short_lock:
+        db=_load_short_db();out={}
+        for vid in arr:
+            st=db.get(vid) or _short_default()
+            out[vid]={"views":int(st.get("views",0)),"likes":int(st.get("likes",0)),"shares":int(st.get("shares",0)),"comments":st.get("comments",[])[:80]}
+    return JSONResponse({"stats":out})
+
+@app.post("/api/short-action")
+async def api_short_action(request:Request):
+    try:body=await request.json()
+    except:body={}
+    vid=str(body.get("id","")).strip();action=str(body.get("action","")).strip();txt=str(body.get("text","")).strip()
+    if not vid:return JSONResponse({"error":"missing id"},status_code=400)
+    with _short_lock:
+        db=_load_short_db();st=db.get(vid) or _short_default()
+        if action=="view":st["views"]=int(st.get("views",0))+1
+        elif action=="like":st["likes"]=int(st.get("likes",0))+1
+        elif action=="share":st["shares"]=int(st.get("shares",0))+1
+        elif action=="comment" and txt:
+            comments=st.get("comments",[])
+            comments.insert(0,{"text":txt[:180],"ts":int(time.time())})
+            st["comments"]=comments[:80]
+        st["updated"]=int(time.time());db[vid]=st;_save_short_db(db)
+        out={"views":int(st.get("views",0)),"likes":int(st.get("likes",0)),"shares":int(st.get("shares",0)),"comments":st.get("comments",[])[:80]}
+    return JSONResponse({"stats":out})
+
 @app.get("/api/highlights")
 def api_highlights():return JSONResponse(_cached("xemlaibongda_hl",scrape_xemlaibongda,ttl=_cache_ttl))
 @app.get("/api/highlights/leagues")