Upload app_main.py

app_main.py

@@ -71,13 +71,11 @@ def _search_all(topic, limit=40):
 # AGGRESSIVELY remove ALL old '/' routes from entire chain
 # This ensures our new '/' route is the ONLY one serving
 # ============================================================
-# Remove from app.router.routes (APIRoute objects)
 app.router.routes = [r for r in app.router.routes if not (
     (getattr(r, 'path', None) == '/' and 'GET' in getattr(r, 'methods', set())) or
     (getattr(r, 'path', None) == '/api/hashtag/sources' and 'GET' in getattr(r, 'methods', set())) or
     (getattr(r, 'path', None) in ('/api/short/comments', '/api/short/comment'))
 )]
-# Also remove from app.routes (includes mounts)
 app.routes[:] = [r for r in app.routes if not (
     hasattr(r, 'path') and getattr(r, 'path', None) == '/' and 
     hasattr(r, 'methods') and 'GET' in getattr(r, 'methods', set())
@@ -207,6 +205,29 @@ def api_match_detail_by_url(url: str = Query(...)):
     """Get match detail by full bongda.com.vn URL."""
     return JSONResponse(fetch_match_detail_by_url(url))
 
+# ============================================================
+# VTV CHANNELS API
+# ============================================================
+from vtv_scraper import get_vtv_channels_for_frontend, XEMTV_CHANNELS, fetch_vtv_stream
+
+@app.get('/api/vtv/channels')
+def api_vtv_channels():
+    """Get all VTV channel stream URLs."""
+    channels = get_vtv_channels_for_frontend()
+    # Add fallback URLs for each channel
+    for ch in channels:
+        name = ch['name']
+        ch['fallback_url'] = XEMTV_CHANNELS.get(name, 'https://hd.xemtv.net/')
+    return JSONResponse({'channels': channels})
+
+@app.get('/api/vtv/stream/{channel_name}')
+def api_vtv_stream(channel_name: str):
+    """Get stream URL for a specific VTV channel."""
+    url = fetch_vtv_stream(channel_name.upper())
+    if url:
+        return JSONResponse({'url': url})
+    return JSONResponse({'url': None, 'fallback': XEMTV_CHANNELS.get(channel_name.upper(), 'https://hd.xemtv.net/')})
+
 def _wc2026_bg_refresh():
     time.sleep(10)
     while True: