VTV Digital CDN primary source for VTV1-VTV9 streams

vtv_api.py

@@ -1,8 +1,7 @@
 """
 VTV Channels API - Backend endpoints for VTV1-VTV10 + VTVPrime
-Fetches stream URLs from xemtv.us PHP endpoints (primary)
-Alternative: xemtivitop.com (backup)
-Fallback: FPTPlay CDN → VTVGo CDN → xemtv.net (legacy)
+Fetches stream URLs from VTV Digital CDN (primary, stable)
+Fallback: xemtv.us → xemtivitop.com → FPTPlay CDN → VTVGo CDN → xemtv.net (legacy)
 EPG data scraped from https://vtv.vn/lich-phat-song.htm
 """
 import re, time, threading
@@ -21,7 +20,20 @@ UA = {
     "Accept-Language": "vi-VN,vi;q=0.9",
 }
 
-# ===== PRIMARY: xemtv.us (new domain, works 2025-2026) =====
+# ===== PRIMARY: VTV Digital CDN (direct, stable, low latency) =====
+VTV_DIGITAL_CDN_URLS = {
+    "vtv1":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv1/master.m3u8",
+    "vtv2":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv2/master.m3u8",
+    "vtv3":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv3/master.m3u8",
+    "vtv4":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv4/master.m3u8",
+    "vtv5":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv5/master.m3u8",
+    "vtv6":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv6/master.m3u8",
+    "vtv7":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv7/master.m3u8",
+    "vtv8":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv8/master.m3u8",
+    "vtv9":  "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv9/master.m3u8",
+}
+
+# ===== BACKUP: xemtv.us =====
 XEMTV_US_ENDPOINTS = {
     "vtv1":  "https://xemtv.us/tv/vtv1.php",
     "vtv2":  "https://xemtv.us/tv/vtv2.php",
@@ -36,7 +48,7 @@ XEMTV_US_ENDPOINTS = {
     "vtvprime": "https://xemtv.us/tv/vtvprime.php",
 }
 
-# ===== ALTERNATIVE: xemtivitop.com (backup source) =====
+# ===== xemtivitop.com =====
 XEMTIVITOP_ENDPOINTS = {
     "vtv1":  "https://www.xemtivitop.com/2018/10/vtv1-online.html?m=1",
     "vtv2":  "https://www.xemtivitop.com/2018/10/vtv2-online.html?m=1",
@@ -50,7 +62,7 @@ XEMTIVITOP_ENDPOINTS = {
     "vtv10": "https://www.xemtivitop.com/2020/05/vtv10-can-tho-online.html?m=1",
 }
 
-# ===== LEGACY: xemtv.net (may return 403, keep as last resort) =====
+# ===== xemtv.net (legacy) =====
 XEMTV_LEGACY_ENDPOINTS = {
     "vtv1":  "https://hd.xemtv.net/kenh/vtv1.php",
     "vtv2":  "https://hd.xemtv.net/kenh/vtv2.php",
@@ -66,20 +78,12 @@ XEMTV_LEGACY_ENDPOINTS = {
 }
 
 CHANNEL_NAMES = {
-    "vtv1":  "VTV1",
-    "vtv2":  "VTV2",
-    "vtv3":  "VTV3",
-    "vtv4":  "VTV4",
-    "vtv5":  "VTV5",
-    "vtv6":  "VTV6",
-    "vtv7":  "VTV7",
-    "vtv8":  "VTV8",
-    "vtv9":  "VTV9",
-    "vtv10": "VTV10",
-    "vtvprime": "VTVPrime",
+    "vtv1":  "VTV1", "vtv2":  "VTV2", "vtv3":  "VTV3", "vtv4":  "VTV4",
+    "vtv5":  "VTV5", "vtv6":  "VTV6", "vtv7":  "VTV7", "vtv8":  "VTV8",
+    "vtv9":  "VTV9", "vtv10": "VTV10", "vtvprime": "VTVPrime",
 }
 
-# ===== FALLBACK 1: FPTPlay CDN (new URLs 2025-2026) =====
+# ===== FALLBACK: FPTPlay CDN =====
 FPTPLAY_URLS = {
     "vtv1":  "https://live-a.fptplay53.net/live/media/vtv1/live247-hls-avc/index.m3u8",
     "vtv2":  "https://live-a.fptplay53.net/live/media/vtv2/live247-hls-avc/index.m3u8",
@@ -93,7 +97,7 @@ FPTPLAY_URLS = {
     "vtv10": "https://live-a.fptplay53.net/live/media/vtv10/live247-hls-avc/index.m3u8",
 }
 
-# ===== FALLBACK 2: VTVGo CDN =====
+# ===== FALLBACK: VTVGo CDN =====
 VTVGO_FAILOVER = {
     "vtv1":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv1-manifest.m3u8",
     "vtv2":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv2-manifest.m3u8",
@@ -151,7 +155,6 @@ def fetch_xemtv_us_stream(channel_id):
     return None
 
 def fetch_xemtivitop_stream(channel_id):
-    """Fetch stream from xemtivitop.com blogspot pages"""
     page_url = XEMTIVITOP_ENDPOINTS.get(channel_id)
     if not page_url:
         return None
@@ -186,11 +189,7 @@ def fetch_fptplay_stream(channel_id):
     if not url:
         return None
     try:
-        headers = {
-            "User-Agent": UA["User-Agent"],
-            "Referer": "https://fptplay.vn/",
-            "Origin": "https://fptplay.vn",
-        }
+        headers = {"User-Agent": UA["User-Agent"], "Referer": "https://fptplay.vn/", "Origin": "https://fptplay.vn"}
         r = requests.get(url, headers=headers, timeout=15, allow_redirects=True, verify=False)
         if r.status_code == 200 and '#EXTM3U' in r.text[:200]:
             return url
@@ -211,34 +210,34 @@ def fetch_vtvgo_stream(channel_id):
         pass
     return None
 
+def verify_vtv_digital_url(url):
+    """Verify a VTV Digital CDN URL returns valid HLS content"""
+    if not url:
+        return None
+    try:
+        headers = {**UA, "Referer": "https://vtvgo.vn/", "Origin": "https://vtvgo.vn"}
+        r = requests.get(url, headers=headers, timeout=10, allow_redirects=True, verify=False)
+        if r.status_code == 200 and '#EXTM3U' in r.text[:200]:
+            return url
+    except:
+        pass
+    return None
+
 def normalize_fptplay_url(url):
     if not url:
         return url
     old_to_new = {
-        "https://live.fptplay53.net/fnxch2/vtv1hd_abr.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv1/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxch2/vtv2hd_abr.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv2/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxch2/vtv3hd_abr.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv3/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxch2/vtv4hd_abr.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv4/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxhd1/vtv5hd_vhls.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv5/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxhd1/vtv6hd_vhls.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv6/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxhd1/vtv7hd_vhls.smil/chunklist_b5000000.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv7/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/epzhd1/vtv8hd_vhls.smil/c.hunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv8/live-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/epzhd1/vtv8hd_vhls.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv8/live-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxhd1/vtv9hd_vhls.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv9/live247-hls-avc/index.m3u8",
-        "https://live.fptplay53.net/fnxhd1/vtv10hd_vhls.smil/chunklist.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv10/live247-hls-avc/index.m3u8",
-        "https://live-a.fptplay53.net/live/media/VTV5HD/live_hls_avc/index.m3u8":
-            "https://live-a.fptplay53.net/live/media/vtv5/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxch2/vtv1hd_abr.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv1/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxch2/vtv2hd_abr.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv2/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxch2/vtv3hd_abr.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv3/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxch2/vtv4hd_abr.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv4/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxhd1/vtv5hd_vhls.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv5/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxhd1/vtv6hd_vhls.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv6/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxhd1/vtv7hd_vhls.smil/chunklist_b5000000.m3u8": "https://live-a.fptplay53.net/live/media/vtv7/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/epzhd1/vtv8hd_vhls.smil/c.hunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv8/live-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxhd1/vtv9hd_vhls.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv9/live247-hls-avc/index.m3u8",
+        "https://live.fptplay53.net/fnxhd1/vtv10hd_vhls.smil/chunklist.m3u8": "https://live-a.fptplay53.net/live/media/vtv10/live247-hls-avc/index.m3u8",
+        "https://live-a.fptplay53.net/live/media/VTV5HD/live_hls_avc/index.m3u8": "https://live-a.fptplay53.net/live/media/vtv5/live247-hls-avc/index.m3u8",
     }
     return old_to_new.get(url, url)
 
@@ -256,38 +255,47 @@ def fetch_vtv_stream(channel_id):
     if cached is not None:
         return cached
 
-    if channel_id == 'vtvprime':
-        url = fetch_xemtv_us_stream('vtvprime') or fetch_xemtivitop_stream('vtvprime') or fetch_xemtv_legacy_stream('vtvprime')
+    # PRIMARY: VTV Digital CDN
+    if channel_id in VTV_DIGITAL_CDN_URLS:
+        url = verify_vtv_digital_url(VTV_DIGITAL_CDN_URLS[channel_id])
         if url:
-            url = normalize_fptplay_url(url)
-        _set_cache(channel_id, url)
-        return url
+            _set_cache(channel_id, url)
+            return url
+
+    # vtvprime/vtv10: not on VTV Digital CDN, use xemtv.us
+    if channel_id in ('vtvprime', 'vtv10'):
+        url = fetch_xemtv_us_stream(channel_id) or fetch_xemtivitop_stream(channel_id) or fetch_xemtv_legacy_stream(channel_id)
+        if url:
+            _set_cache(channel_id, url)
+            return url
 
+    # BACKUP: xemtv.us
     url = fetch_xemtv_us_stream(channel_id)
     if url:
-        url = normalize_fptplay_url(url)
         _set_cache(channel_id, url)
         return url
 
+    # FALLBACK: xemtivitop.com
     url = fetch_xemtivitop_stream(channel_id)
     if url:
-        url = normalize_fptplay_url(url)
         _set_cache(channel_id, url)
         return url
 
+    # FALLBACK: FPTPlay CDN
     url = fetch_fptplay_stream(channel_id)
     if url:
         _set_cache(channel_id, url)
         return url
 
+    # FALLBACK: VTVGo CDN
     url = fetch_vtvgo_stream(channel_id)
     if url:
         _set_cache(channel_id, url)
         return url
 
+    # LAST RESORT: xemtv.net legacy
     url = fetch_xemtv_legacy_stream(channel_id)
     if url:
-        url = normalize_fptplay_url(url)
         _set_cache(channel_id, url)
         return url
 
@@ -313,13 +321,10 @@ def api_vtv_stream(channel_id: str):
 def proxy_page(url: str = Query(...)):
     try:
         headers = {**UA}
-        if "xemtv.us" in url:
-            headers["Referer"] = "https://xemtv.us/"
-        elif "xemtv.net" in url:
-            headers["Referer"] = "https://hd.xemtv.net/"
+        if "xemtv.us" in url: headers["Referer"] = "https://xemtv.us/"
+        elif "xemtv.net" in url: headers["Referer"] = "https://hd.xemtv.net/"
         r = requests.get(url, headers=headers, timeout=15, allow_redirects=True, verify=False)
-        if r.status_code != 200:
-            return Response(status_code=502, content="upstream error")
+        if r.status_code != 200: return Response(status_code=502, content="upstream error")
         return Response(content=r.text.encode("utf-8"), media_type="text/html; charset=utf-8", headers={"Access-Control-Allow-Origin": "*"})
     except:
         return Response(status_code=502, content="proxy error")
@@ -328,28 +333,20 @@ def proxy_page(url: str = Query(...)):
 def proxy_vtv_m3u8(url: str = Query(...)):
     try:
         headers = {"User-Agent": UA["User-Agent"], "Accept": "*/*"}
-        if "fptplay" in url:
-            headers["Referer"] = "https://fptplay.vn/"
-            headers["Origin"] = "https://fptplay.vn"
-        elif "xemtv" in url:
-            headers["Referer"] = "https://xemtv.us/"
-        elif "vtvgo" in url or "vtvdigital" in url:
-            headers["Referer"] = "https://vtvgo.vn/"
+        if "fptplay" in url: headers["Referer"] = "https://fptplay.vn/"; headers["Origin"] = "https://fptplay.vn"
+        elif "xemtv" in url: headers["Referer"] = "https://xemtv.us/"
+        elif "vtvdigital" in url: headers["Referer"] = "https://vtvgo.vn/"
         r = requests.get(url, headers=headers, timeout=15, allow_redirects=True, verify=False)
-        if r.status_code != 200:
-            return Response(status_code=502, content="upstream error")
+        if r.status_code != 200: return Response(status_code=502, content="upstream error")
         content = r.text
         lines = content.split('\n')
         base_url = url.rsplit('/', 1)[0] + '/' if '/' in url else url
         rewritten = []
         for line in lines:
             line = line.strip()
-            if not line or line.startswith('#'):
-                rewritten.append(line)
+            if not line or line.startswith('#'): rewritten.append(line)
             else:
-                seg_url = line
-                if not seg_url.startswith('http'):
-                    seg_url = base_url + seg_url
+                seg_url = line if line.startswith('http') else base_url + line
                 if seg_url.endswith('.m3u8'):
                     rewritten.append("/api/proxy/m3u8/vtv?url=" + requests.utils.quote(seg_url, safe=""))
                 else:
@@ -362,179 +359,11 @@ def proxy_vtv_m3u8(url: str = Query(...)):
 def proxy_vtv_segment(url: str = Query(...)):
     try:
         headers = {"User-Agent": UA["User-Agent"], "Accept": "*/*"}
-        if "fptplay" in url:
-            headers["Referer"] = "https://fptplay.vn/"
-            headers["Origin"] = "https://fptplay.vn"
+        if "fptplay" in url: headers["Referer"] = "https://fptplay.vn/"; headers["Origin"] = "https://fptplay.vn"
         r = requests.get(url, headers=headers, timeout=30, allow_redirects=True, verify=False)
-        if r.status_code != 200:
-            return Response(status_code=502, content="upstream error")
+        if r.status_code != 200: return Response(status_code=502, content="upstream error")
         data = r.content
-        if len(data) > 188 and data[0:4] == b'\x89PNG' and data[188] == 0x47:
-            data = data[188:]
+        if len(data) > 188 and data[0:4] == b'\x89PNG' and data[188] == 0x47: data = data[188:]
         return Response(content=data, media_type="video/mp2t", headers={"Access-Control-Allow-Origin": "*", "Cache-Control": "public, max-age=3600"})
     except:
-        return Response(status_code=502, content="proxy error")
-
-_epg_cache = {}
-_epg_cache_time = 0
-_EPG_CACHE_TTL = 600
-
-VTV_CHANNEL_MAP = {
-    "vtv1": "vtv1", "vtv2": "vtv2", "vtv3": "vtv3", "vtv4": "vtv4",
-    "vtv5": "vtv5", "vtv5-tay-nam-bo": "vtv5", "vtv5-tay-nguyen": "vtv5",
-    "vtv7": "vtv7", "vtv8": "vtv8", "vtv6": "vtv6", "vtv9": "vtv9",
-    "vtv-can-tho": "vtv10",
-}
-
-def _fetch_epg_from_vtv():
-    global _epg_cache, _epg_cache_time
-    now_ts = time.time()
-    if _epg_cache and now_ts - _epg_cache_time < _EPG_CACHE_TTL:
-        return _epg_cache
-    epg_data = {}
-    now_vn = datetime.now(VN_TZ)
-    try:
-        headers = {
-            "User-Agent": UA["User-Agent"], "Accept-Language": "vi-VN,vi;q=0.9",
-            "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8",
-            "Referer": "https://vtv.vn/",
-        }
-        r = requests.get("https://vtv.vn/lich-phat-song.htm", headers=headers, timeout=20)
-        if r.status_code != 200:
-            return epg_data
-        r.encoding = "utf-8"
-        soup = BeautifulSoup(r.text, "lxml")
-        channel_order = []
-        list_channel = soup.find(class_=re.compile(r'list-channel'))
-        if list_channel:
-            for link in list_channel.find_all('a', href=re.compile(r'truyen-hinh-truc-tuyen/([^.]+)\.htm')):
-                ch_id = re.search(r'truyen-hinh-truc-tuyen/([^.]+)\.htm', link.get('href', ''))
-                if ch_id:
-                    channel_order.append(ch_id.group(1))
-        if not channel_order:
-            for link in soup.find_all('a', href=re.compile(r'truyen-hinh-truc-tuyen/([^.]+)\.htm')):
-                ch_id = re.search(r'truyen-hinh-truc-tuyen/([^.]+)\.htm', link.get('href', ''))
-                if ch_id and ch_id.group(1) not in channel_order:
-                    channel_order.append(ch_id.group(1))
-        prog_containers = soup.find_all('ul', class_=re.compile(r'\bprograms\b'))
-        for i, container in enumerate(prog_containers):
-            if i >= len(channel_order):
-                break
-            vtv_ch_id = channel_order[i]
-            our_ch_id = VTV_CHANNEL_MAP.get(vtv_ch_id, vtv_ch_id)
-            if our_ch_id not in epg_data:
-                epg_data[our_ch_id] = []
-            for li in container.find_all('li', class_=re.compile(r'\bprogram\b')):
-                time_span = li.find('span', class_=re.compile(r'\btime\b'))
-                title_span = li.find('span', class_=re.compile(r'\btitle\b'))
-                genre_a = li.find('a', class_=re.compile(r'\bgenre\b'))
-                time_str = time_span.get_text(strip=True) if time_span else ""
-                title = ""
-                if genre_a:
-                    title = genre_a.get_text(strip=True)
-                if not title and title_span:
-                    title = title_span.get_text(strip=True)
-                if not time_str or not title:
-                    continue
-                start_dt = _parse_time(time_str, reference_date=now_vn)
-                if not start_dt:
-                    continue
-                epg_data[our_ch_id].append({"time": time_str[:5], "title": title[:80], "start_dt": start_dt})
-        for ch_id in epg_data:
-            epg_data[ch_id].sort(key=lambda x: x.get("start_dt") or datetime.min)
-            seen = set()
-            unique = []
-            for p in epg_data[ch_id]:
-                key = (p["time"], p["title"])
-                if key not in seen:
-                    seen.add(key)
-                    unique.append(p)
-            epg_data[ch_id] = unique
-    except Exception as e:
-        print(f"EPG vtv.vn error: {e}")
-    _epg_cache = epg_data
-    _epg_cache_time = now_ts
-    return epg_data
-
-def _parse_time(time_str, reference_date=None):
-    if not time_str:
-        return None
-    time_str = time_str.strip().replace("h", ":").replace("H", ":")
-    m = re.search(r'(\d{1,2}):(\d{2})', time_str)
-    if m:
-        try:
-            hour, minute = int(m.group(1)), int(m.group(2))
-            if reference_date:
-                base_date = reference_date
-            else:
-                now_vn = datetime.now(VN_TZ)
-                base_date = now_vn
-            from datetime import timedelta
-            if hour < 5:
-                if base_date.hour < 5:
-                    tv_date = base_date
-                else:
-                    tv_date = base_date - timedelta(days=1)
-            else:
-                tv_date = base_date
-            result = tv_date.replace(hour=hour, minute=minute, second=0, microsecond=0)
-            if result.tzinfo is None:
-                result = result.replace(tzinfo=VN_TZ)
-            return result
-        except:
-            pass
-    return None
-
-def _get_epg_for_channel(channel_id):
-    epg_data = _fetch_epg_from_vtv()
-    programmes = epg_data.get(channel_id, [])
-    if not programmes:
-        return []
-    now = datetime.now(VN_TZ)
-    today = now.date()
-    result = []
-    today_programmes = []
-    for p in programmes:
-        start_dt = p.get("start_dt")
-        if start_dt and start_dt.date() == today:
-            today_programmes.append(p)
-    if not today_programmes:
-        today_programmes = programmes
-    for i, p in enumerate(today_programmes):
-        start_dt = p.get("start_dt")
-        stop_dt = None
-        if i + 1 < len(today_programmes):
-            stop_dt = today_programmes[i + 1].get("start_dt")
-        is_now = False
-        if start_dt:
-            if stop_dt:
-                is_now = start_dt <= now < stop_dt
-            else:
-                is_now = start_dt <= now
-        end_time = ""
-        if stop_dt:
-            end_time = stop_dt.strftime("%H:%M")
-        result.append({"time": p["time"], "title": p["title"], "end_time": end_time, "now": is_now})
-    return result
-
-@router.get("/api/vtv/epg/{channel_id}")
-def api_vtv_epg(channel_id: str):
-    channel_id = channel_id.lower().strip()
-    if channel_id not in CHANNEL_NAMES:
-        return JSONResponse({"error": "channel not found"}, status_code=404)
-    programs = _get_epg_for_channel(channel_id)
-    return JSONResponse({
-        "channel": channel_id, "channel_name": CHANNEL_NAMES.get(channel_id, channel_id),
-        "date": datetime.now(VN_TZ).strftime("%Y-%m-%d"), "programs": programs,
-    })
-
-@router.get("/api/vtv/epg")
-def api_vtv_epg_refresh():
-    global _epg_cache, _epg_cache_time
-    _epg_cache = {}
-    _epg_cache_time = 0
-    epg_data = _fetch_epg_from_vtv()
-    return JSONResponse({
-        "status": "refreshed", "channels": len(epg_data),
-        "total_programmes": sum(len(v) for v in epg_data),
-    })
+        return Response(status_code=502, content="proxy error")