Upload vtv_api.py

vtv_api.py

@@ -1,746 +1,172 @@
 """
-VTV Channels API - Backend endpoints for VTV1-VTV10 + VTVPrime
-Fetches stream URLs from multiple CDN sources with aggressive extraction and fast failover.
-
-Sources (ordered by stability):
-1. VTV Digital CDN (ssaimh) - FAST check, skip if not responding quickly
-2. xemtv.us PHP endpoints
-3. sv2.xemtivitop.com PHP endpoints (main source for VTV2, VTV3, VTV6, VTV9)
-4. xemtivitop.com blogspot pages
-5. FPTPlay CDN
-6. VTVGo CDN
-7. xemtv.net legacy
+VTV Channels API - Backend for VTV1-VTV10
+Sources: iptv-org/iptv playlist -> longhai/iptv -> FPTPlay CDN -> blogspot -> ssaimh -> VTVGo -> mediacdn
 """
-import re, time, threading, json
-import requests
-from fastapi import APIRouter, Query
-from fastapi.responses import JSONResponse, Response
-from bs4 import BeautifulSoup
-from datetime import datetime, timedelta, timezone
-
-VN_TZ = timezone(timedelta(hours=7))
-
-router = APIRouter()
-
-UA = {
-    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 Safari/537.36",
-    "Accept-Language": "vi-VN,vi;q=0.9",
-    "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8",
-    "Sec-Fetch-Dest": "document",
-    "Sec-Fetch-Mode": "navigate",
-    "Sec-Fetch-Site": "none",
-    "Upgrade-Insecure-Requests": "1",
-}
-
-# ===== VTV Digital CDN (ssaimh) - may have expired token, check quickly =====
-# NOTE: vtv6 CDN URL actually delivered VTV10 (Can Tho). VTV2/VTV3/VTV6/VTV9 removed from CDN.
-VTV_DIGITAL_SSAIMH_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 intentionally omitted from CDN -- uses sv2.xemtivitop.com for real VTV6 signal
-    "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",
-    "vtv10": "https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv6/master.m3u8",
-}
-
-# ===== xemtv.us PHP endpoints =====
-XEMTV_US_ENDPOINTS = {
-    "vtv1":  "https://xemtv.us/tv/vtv1.php",
-    "vtv2":  "https://xemtv.us/tv/vtv2.php",
-    "vtv3":  "https://xemtv.us/tv/vtv3.php",
-    "vtv4":  "https://xemtv.us/tv/vtv4.php",
-    "vtv5":  "https://xemtv.us/tv/vtv5.php",
-    "vtv6":  "https://xemtv.us/tv/vtv6.php",
-    "vtv7":  "https://xemtv.us/tv/vtv7.php",
-    "vtv8":  "https://xemtv.us/tv/vtv8.php",
-    "vtv9":  "https://xemtv.us/tv/vtv9.php",
-    "vtv10": "https://xemtv.us/tv/vtv10.php",
-    "vtvprime": "https://xemtv.us/tv/vtvprime.php",
-}
-
-# ===== sv2.xemtivitop.com PHP endpoints (primary for VTV2, VTV3, VTV6, VTV9) =====
-SV2_XEMTIVITOP_ENDPOINTS = {
-    "vtv1":  "https://sv2.xemtivitop.com/live/hot/vtv1.php",
-    "vtv2":  "https://sv2.xemtivitop.com/live/hot/vtv2.php",
-    "vtv3":  "https://sv2.xemtivitop.com/live/hot/vtv3.php",
-    "vtv4":  "https://sv2.xemtivitop.com/live/hot/vtv4.php",
-    "vtv5":  "https://sv2.xemtivitop.com/live/hot/vtv5.php",
-    "vtv6":  "https://sv2.xemtivitop.com/live/hot/vtv6.php",
-    "vtv7":  "https://sv2.xemtivitop.com/live/hot/vtv7.php",
-    "vtv8":  "https://sv2.xemtivitop.com/live/hot/vtv8.php",
-    "vtv9":  "https://sv2.xemtivitop.com/live/hot/vtv9.php",
-    "vtv10": "https://sv2.xemtivitop.com/live/hot/vtv10.php",
-}
-
-# ===== xemtivitop.com blogspot pages =====
-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",
-    "vtv3":  "https://www.xemtivitop.com/2018/10/vtv3-online.html?m=1",
-    "vtv4":  "https://www.xemtivitop.com/2018/10/vtv4-online.html?m=1",
-    "vtv5":  "https://www.xemtivitop.com/2018/10/vtv5-online.html?m=1",
-    "vtv6":  "https://www.xemtivitop.com/2018/10/vtv6-online.html?m=1",
-    "vtv7":  "https://www.xemtivitop.com/2018/10/vtv7-online.html?m=1",
-    "vtv8":  "https://www.xemtivitop.com/2018/10/vtv8-online.html?m=1",
-    "vtv9":  "https://www.xemtivitop.com/2018/10/vtv9-online.html?m=1",
-    "vtv10": "https://www.xemtivitop.com/2020/05/vtv10-can-tho-online.html?m=1",
-}
-
-# ===== xemtv.net legacy =====
-XEMTV_LEGACY_ENDPOINTS = {
-    "vtv1":  "https://hd.xemtv.net/kenh/vtv1.php",
-    "vtv2":  "https://hd.xemtv.net/kenh/vtv2.php",
-    "vtv3":  "https://hd.xemtv.net/kenh/vtv3.php",
-    "vtv4":  "https://hd.xemtv.net/kenh/vtv4.php",
-    "vtv5":  "https://hd.xemtv.net/kenh/vtv5.php",
-    "vtv6":  "https://hd.xemtv.net/kenh/vtv6.php",
-    "vtv7":  "https://hd.xemtv.net/kenh/vtv7.php",
-    "vtv8":  "https://hd.xemtv.net/kenh/vtv8.php",
-    "vtv9":  "https://hd.xemtv.net/kenh/vtv9.php",
-    "vtv10": "https://hd.xemtv.net/kenh/vtv10.php",
-    "vtvprime": "https://hd.xemtv.net/kenh/vtvprime.php",
-}
-
-CHANNEL_NAMES = {
-    "vtv1":  "VTV1", "vtv2":  "VTV2", "vtv3":  "VTV3", "vtv4":  "VTV4",
-    "vtv5":  "VTV5", "vtv6":  "VTV6", "vtv7":  "VTV7", "vtv8":  "VTV8",
-    "vtv9":  "VTV9", "vtv10": "VTV10", "vtvprime": "VTVPrime",
-}
-
-# ===== 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",
-    "vtv3":  "https://live-a.fptplay53.net/live/media/vtv3/live247-hls-avc/index.m3u8",
-    "vtv4":  "https://live-a.fptplay53.net/live/media/vtv4/live247-hls-avc/index.m3u8",
-    "vtv5":  "https://live-a.fptplay53.net/live/media/vtv5/live247-hls-avc/index.m3u8",
-    "vtv6":  "https://live-a.fptplay53.net/live/media/vtv6/live247-hls-avc/index.m3u8",
-    "vtv7":  "https://live-a.fptplay53.net/live/media/vtv7/live247-hls-avc/index.m3u8",
-    "vtv8":  "https://live-a.fptplay53.net/live/media/vtv8/live-hls-avc/index.m3u8",
-    "vtv9":  "https://live-a.fptplay53.net/live/media/vtv9/live247-hls-avc/index.m3u8",
-    "vtv10": "https://live-a.fptplay53.net/live/media/vtv10/live247-hls-avc/index.m3u8",
-}
-
-# ===== VTVGo CDN =====
-VTVGO_FAILOVER = {
-    "vtv1":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv1-manifest.m3u8",
-    "vtv2":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv2-manifest.m3u8",
-    "vtv3":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv3-manifest.m3u8",
-    "vtv4":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv4-manifest.m3u8",
-    "vtv5":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv5-manifest.m3u8",
-    "vtv6":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv6-manifest.m3u8",
-    "vtv7":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv7-manifest.m3u8",
-    "vtv8":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv8-manifest.m3u8",
-    "vtv9":  "https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv9-manifest.m3u8",
-}
-
-# ===== New backup CDN sources for Vietnamese TV =====
-BACKUP_CDN_URLS = {
-    # acmcdn - alternative Vietnamese CDN
-    "vtv2": "http://tv.mediacdn.vn/live/hls/vtv2.m3u8",
-    "vtv3": "http://tv.mediacdn.vn/live/hls/vtv3.m3u8",
-    "vtv6": "http://tv.mediacdn.vn/live/hls/vtv6.m3u8",
-    "vtv9": "http://tv.mediacdn.vn/live/hls/vtv9.m3u8",
-}
-
-# Which channels have KNOWN working ssaimh CDN (not expired token)
-# VTV1, VTV4, VTV5, VTV7, VTV8 have been reported working
-# VTV2, VTV3, VTV6, VTV9 are problematic on ssaimh
-SSAIMH_WORKING_CHANNELS = {"vtv1", "vtv4", "vtv5", "vtv7", "vtv8", "vtv10"}
-
-_vtv_cache = {}
-_vtv_lock = threading.Lock()
-_CACHE_TTL = 180  # 3 minutes
-
-FAST_TIMEOUT = 5   # Quick check for CDN URLs
-NORMAL_TIMEOUT = 12  # Normal fetch timeout
-
-def _cached(key):
-    with _vtv_lock:
-        if key in _vtv_cache and time.time() - _vtv_cache[key]['t'] < _CACHE_TTL:
-            return _vtv_cache[key]['d']
-    return None
-
-def _set_cache(key, data):
-    with _vtv_lock:
-        _vtv_cache[key] = {'t': time.time(), 'd': data}
-
-def extract_m3u8_aggressive(html):
-    """Aggressively extract m3u8 URL from HTML using ALL possible patterns.
-    Tries 10+ patterns including JS config, iframe recursive, video tag, etc."""
-    if not html:
-        return None
-
-    # Skip HTML comments
-    html = re.sub(r'<!--.*?-->', '', html, flags=re.DOTALL)
-
-    # Pattern 1: file: '...m3u8' (jwplayer/javascript config)
-    m = re.search(r"file\s*:\s*['\"]([^'\"]*\.m3u8[^'\"]*)['\"]", html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 2: file: "..." (double quotes variant)
-    m = re.search(r"file\s*=\s*['\"]([^'\"]*\.m3u8[^'\"]*)['\"]", html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 3: src="...m3u8" 
-    m = re.search(r'src\s*=\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 4: data-src="...m3u8"
-    m = re.search(r'data-src\s*=\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 5: data-lazy-src="...m3u8"
-    m = re.search(r'data-lazy-src\s*=\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 6: player.src("...m3u8") or player.source("...")
-    m = re.search(r'player\.(?:src|source)\s*\(\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 7: hls.loadSource("...")
-    m = re.search(r'(?:hls|video)\.(?:loadSource|src)\s*\(\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 8: source: '...m3u8' (JSON config)
-    m = re.search(r"""['"]source['"]\s*:\s*['"]([^'"]*\.m3u8[^'"]*)['"]""", html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 9: url: '...m3u8' (generic JS config)
-    m = re.search(r"""['"]url['"]\s*:\s*['"]([^'"]*\.m3u8[^'"]*)['"]""", html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 10: bare m3u8 URL in text
-    m = re.search(r"(https?://[^\s\"\"'<>\\]+\.m3u8[^\s\"\"'<>\\]*)", html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 11: <video><source src="...m3u8">
-    m = re.search(r'<source\s+[^>]*src\s*=\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 12: href="...m3u8" (direct link)
-    m = re.search(r'href\s*=\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 13: iframe src="..." - follow it recursively
-    m = re.search(r'<iframe[^>]*src\s*=\s*["\']([^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        iframe_url = m.group(1).strip()
-        if iframe_url and '.php' in iframe_url and len(iframe_url) > 10:
-            try:
-                headers = {
-                    **UA,
-                    "Referer": "https://sv2.xemtivitop.com/",
-                    "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8",
-                }
-                r2 = requests.get(iframe_url, headers=headers, timeout=NORMAL_TIMEOUT, allow_redirects=True, verify=False)
-                if r2.status_code == 200:
-                    result = extract_m3u8_aggressive(r2.text)
-                    if result:
-                        return result
-            except:
-                pass
-
-    # Pattern 14: window.location.href or similar redirect
-    m = re.search(r'(?:window\.)?location\s*[:=]\s*["\']([^"\']*\.m3u8[^"\']*)["\']', html, re.IGNORECASE)
-    if m:
-        url = m.group(1).strip()
-        if len(url) > 20:
-            return url
-
-    # Pattern 15: decodeURIComponent/atob encoded URLs
-    m = re.search(r'(?:decodeURIComponent|atob)\s*\(\s*["\']([A-Za-z0-9+/=]{50,})["\']', html)
-    if m:
-        try:
-            import base64
-            decoded = base64.b64decode(m.group(1)).decode('utf-8', errors='ignore')
-            m2 = re.search(r"(https?://[^\s\"'<>\\]+\.m3u8[^\s\"'<>\\]*)", decoded, re.IGNORECASE)
-            if m2:
-                url = m2.group(1).strip()
-                if len(url) > 20:
-                    return url
-        except:
-            pass
-
+import re,time,threading,requests
+from fastapi import APIRouter,Query
+from fastapi.responses import JSONResponse,Response
+from datetime import datetime
+from concurrent.futures import ThreadPoolExecutor,as_completed
+
+router=APIRouter()
+UA={"User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36"}
+
+FPT={"1":"https://live-a.fptplay53.net/live/media/vtv1/live247-hls-avc/index.m3u8","2":"https://live-a.fptplay53.net/live/media/vtv2/live247-hls-avc/index.m3u8","3":"https://live-a.fptplay53.net/live/media/vtv3/live247-hls-avc/index.m3u8","4":"https://live-a.fptplay53.net/live/media/vtv4/live247-hls-avc/index.m3u8","5":"https://live-a.fptplay53.net/live/media/vtv5/live247-hls-avc/index.m3u8","6":"https://live-a.fptplay53.net/live/media/vtv6/live247-hls-avc/index.m3u8","7":"https://live-a.fptplay53.net/live/media/vtv7/live247-hls-avc/index.m3u8","8":"https://live-a.fptplay53.net/live/media/vtv8/live-hls-avc/index.m3u8","9":"https://live-a.fptplay53.net/live/media/vtv9/live247-hls-avc/index.m3u8","10":"https://live-a.fptplay53.net/live/media/vtv10/live247-hls-avc/index.m3u8"}
+SSA={"1":"https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv1/master.m3u8","4":"https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv4/master.m3u8","5":"https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv5/master.m3u8","7":"https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv7/master.m3u8","8":"https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv8/master.m3u8","10":"https://vtvgolive-ssaimh.vtvdigital.vn/o-QNezId5ssiM7KaV4MfXQ/1781372128/manifest/vtv6/master.m3u8"}
+VGO={"2":"https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv2-manifest.m3u8","3":"https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv3-manifest.m3u8","6":"https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv6-manifest.m3u8","9":"https://vtvgolive-failover.vtvdigital.vn/vtvgo/vtv9-manifest.m3u8"}
+MED={"2":"http://tv.mediacdn.vn/live/hls/vtv2.m3u8","3":"http://tv.mediacdn.vn/live/hls/vtv3.m3u8","6":"http://tv.mediacdn.vn/live/hls/vtv6.m3u8","9":"http://tv.mediacdn.vn/live/hls/vtv9.m3u8"}
+BLG={"2":"https://www.xemtivitop.com/2018/10/vtv2-online.html?m=1","3":"https://www.xemtivitop.com/2018/10/vtv3-online.html?m=1","6":"https://www.xemtivitop.com/2018/10/vtv6-online.html?m=1","9":"https://www.xemtivitop.com/2018/10/vtv9-online.html?m=1"}
+PL={"o":"https://raw.githubusercontent.com/iptv-org/iptv/master/streams/vn.m3u","h":"https://raw.githubusercontent.com/longhai/iptv/master/vtvgo.m3u"}
+CH={"vtv1":"VTV1","vtv2":"VTV2","vtv3":"VTV3","vtv4":"VTV4","vtv5":"VTV5","vtv6":"VTV6","vtv7":"VTV7","vtv8":"VTV8","vtv9":"VTV9","vtv10":"VTV10"}
+SID={"vtv1":"1","vtv2":"2","vtv3":"3","vtv4":"4","vtv5":"5","vtv6":"6","vtv7":"7","vtv8":"8","vtv9":"9","vtv10":"10"}
+
+_cache={};_lock=threading.Lock();_TTL=300
+def _gc(k):
+    with _lock:
+        if k in _cache and time.time()-_cache[k]['t']<_TTL: return _cache[k]['d']
     return None
+def _sc(k,d):
+    with _lock: _cache[k]={'t':time.time(),'d':d}
 
-def verify_hls_url(url, referer="https://vtvgo.vn/", timeout=FAST_TIMEOUT):
-    """Quickly verify a URL returns valid HLS content"""
-    if not url:
-        return None
+def _v(u,ref="https://vtvgo.vn/",t=5):
+    if not u: return None
     try:
-        headers = {
-            **UA,
-            "Referer": referer,
-            "Origin": referer.rstrip("/"),
-            "Accept": "*/*",
-        }
-        r = requests.get(url, headers=headers, timeout=timeout, allow_redirects=True, verify=False)
-        if r.status_code == 200 and '#EXTM3U' in r.text[:500]:
-            return url
-    except:
-        pass
+        r=requests.get(u,headers={**UA,"Referer":ref,"Accept":"*/*"},timeout=t)
+        if r.status_code==200 and ('#EXTM3U' in r.text[:500] or '#EXT-X-STREAM-INF' in r.text[:500]): return u
+    except: pass
     return None
 
-def fetch_url_with_follow(php_url, referer, timeout=NORMAL_TIMEOUT):
-    """Fetch a PHP page, follow redirects, parse html deeply."""
-    try:
-        headers = {
-            **UA,
-            "Referer": referer,
-        }
-        r = requests.get(php_url, headers=headers, timeout=timeout, allow_redirects=True, verify=False)
-        if r.status_code == 200:
-            # Check redirect chain first
-            if r.history:
-                for resp in reversed(r.history):
-                    loc = resp.headers.get('Location', '')
-                    if '.m3u8' in loc and len(loc) > 20:
-                        return loc, "redirect"
-            # Aggressive extraction
-            m3u8 = extract_m3u8_aggressive(r.text)
-            if m3u8:
-                return m3u8, "extracted"
-            # Try multiple iframe following (depth 2)
-            soup = BeautifulSoup(r.text, 'html.parser')
-            seen_iframes = set()
-            for _ in range(3):  # follow iframe chain up to 3 levels
-                iframe = soup.find('iframe', src=True)
-                if not iframe:
-                    break
-                src = iframe.get('src', '').strip()
-                if not src or src in seen_iframes:
-                    break
-                seen_iframes.add(src)
-                if not src.startswith('http'):
-                    # Resolve relative URL
-                    from urllib.parse import urljoin
-                    src = urljoin(php_url, src)
-                try:
-                    headers2 = {**UA, "Referer": referer}
-                    r2 = requests.get(src, headers=headers2, timeout=NORMAL_TIMEOUT, allow_redirects=True, verify=False)
-                    if r2.status_code == 200:
-                        m3u8 = extract_m3u8_aggressive(r2.text)
-                        if m3u8:
-                            return m3u8, "iframe_follow"
-                        soup = BeautifulSoup(r2.text, 'html.parser')
-                except:
-                    break
-        return None, "not_found"
-    except Exception as e:
-        return None, f"error:{str(e)[:50]}"
-
-def fetch_vtv_stream(channel_id):
-    channel_id = channel_id.lower().strip()
-    name_map = {
-        'vtvct': 'vtv10', 'vtv-can-tho': 'vtv10', 'vtv can tho': 'vtv10',
-        'vtv_can_tho': 'vtv10', 'cantho': 'vtv10',
-        'vietnam_vtv1': 'vtv1', 'vietnam_vtv2': 'vtv2', 'vietnam_vtv3': 'vtv3',
-        'vietnam_vtv4': 'vtv4', 'vietnam_vtv5': 'vtv5', 'vietnam_vtv6': 'vtv6',
-        'vietnam_vtv7': 'vtv7', 'vietnam_vtv8': 'vtv8', 'vietnam_vtv9': 'vtv9',
-    }
-    channel_id = name_map.get(channel_id, channel_id)
-    
-    # Check cache
-    cached = _cached(channel_id)
-    if cached is not None:
-        return cached
-
-    result = None
-
-    # ===== PRIORITY 1: VTV Digital CDN (ssaimh) - only for channels known to work =====
-    if channel_id in VTV_DIGITAL_SSAIMH_URLS and channel_id in SSAIMH_WORKING_CHANNELS:
-        result = verify_hls_url(VTV_DIGITAL_SSAIMH_URLS[channel_id], "https://vtvgo.vn/", timeout=FAST_TIMEOUT)
-
-    # ===== PRIORITY 2: vtvprime uses xemtv.us =====
-    if not result and channel_id == 'vtvprime':
-        url, _ = fetch_url_with_follow(XEMTV_US_ENDPOINTS.get(channel_id, ""), "https://xemtv.us/")
-        result = verify_hls_url(url, timeout=NORMAL_TIMEOUT) if url else None
-        if not result:
-            url, _ = fetch_url_with_follow(SV2_XEMTIVITOP_ENDPOINTS.get(channel_id, ""), "https://sv2.xemtivitop.com/")
-            result = verify_hls_url(url, timeout=NORMAL_TIMEOUT) if url else None
-        if not result:
-            url, _ = fetch_url_with_follow(XEMTV_LEGACY_ENDPOINTS.get(channel_id, ""), "https://hd.xemtv.net/")
-            result = verify_hls_url(url, timeout=NORMAL_TIMEOUT) if url else None
-
-    # ===== PRIORITY 3: sv2.xemtivitop.com PHP (main source for VTV2/VTV3/VTV6/VTV9) =====
-    if not result and channel_id in SV2_XEMTIVITOP_ENDPOINTS:
-        php_url = SV2_XEMTIVITOP_ENDPOINTS[channel_id]
-        url, method = fetch_url_with_follow(php_url, "https://sv2.xemtivitop.com/")
-        if url:
-            result = verify_hls_url(url, "https://sv2.xemtivitop.com/", timeout=NORMAL_TIMEOUT) if '.m3u8' in url else url
-            if not result and url:
-                result = url  # use even if not verified (might be non-standard HLS)
-
-    # ===== PRIORITY 4: xemtv.us PHP endpoints =====
-    if not result and channel_id in XEMTV_US_ENDPOINTS:
-        php_url = XEMTV_US_ENDPOINTS[channel_id]
-        url, method = fetch_url_with_follow(php_url, "https://xemtv.us/")
-        if url:
-            result = verify_hls_url(url, "https://xemtv.us/", timeout=NORMAL_TIMEOUT) if '.m3u8' in url else url
-            if not result and url:
-                result = url
+def _ex(h):
+    if not h: return None
+    h=re.sub(r'<!--.*?-->','',h,flags=re.DOTALL)
+    for p in [r"file\s*:\s*['\"]([^'\"]*\.m3u8[^'\"]*)['\"]",r'src\s*=\s*["\']([^"\']*\.m3u8[^"\']*)["\']",r'(https?://[^\s"\'<>]+\.m3u8[^\s"\'<>]*)']:
+        m=re.search(p,h,re.IGNORECASE)
+        if m:
+            u=m.group(1).strip()
+            if len(u)>20: return u
+    return None
 
-    # ===== PRIORITY 5: xemtivitop.com blogspot pages =====
-    if not result and channel_id in XEMTIVITOP_ENDPOINTS:
-        page_url = XEMTIVITOP_ENDPOINTS[channel_id]
+def _pl():
+    u={}
+    def f(name,url):
+        r=[]
         try:
-            headers = {**UA, "Referer": "https://www.xemtivitop.com/"}
-            r = requests.get(page_url, headers=headers, timeout=NORMAL_TIMEOUT, allow_redirects=True, verify=False)
-            if r.status_code == 200:
-                url = extract_m3u8_aggressive(r.text)
-                if url:
-                    result = verify_hls_url(url, "https://www.xemtivitop.com/", timeout=NORMAL_TIMEOUT) if '.m3u8' in url else url
-                    if not result and url:
-                        result = url
-        except:
-            pass
-
-    # ===== FALLBACK 1: FPTPlay CDN =====
-    if not result and channel_id in FPTPLAY_URLS:
-        result = verify_hls_url(FPTPLAY_URLS[channel_id], "https://fptplay.vn/", timeout=NORMAL_TIMEOUT)
-
-    # ===== FALLBACK 2: VTVGo CDN =====
-    if not result and channel_id in VTVGO_FAILOVER:
-        result = verify_hls_url(VTVGO_FAILOVER[channel_id], "https://vtvgo.vn/", timeout=NORMAL_TIMEOUT)
-
-    # ===== FALLBACK 3: Backup CDN sources (mediacdn) =====
-    if not result and channel_id in BACKUP_CDN_URLS:
-        result = verify_hls_url(BACKUP_CDN_URLS[channel_id], "https://tv.mediacdn.vn/", timeout=NORMAL_TIMEOUT)
-
-    # ===== LAST RESORT: xemtv.net legacy =====
-    if not result and channel_id in XEMTV_LEGACY_ENDPOINTS:
-        php_url = XEMTV_LEGACY_ENDPOINTS[channel_id]
-        url, method = fetch_url_with_follow(php_url, "https://hd.xemtv.net/")
-        if url and '.m3u8' in url:
-            result = url
-
-    _set_cache(channel_id, result)
-    return result
-
+            resp=requests.get(url,headers=UA,timeout=15)
+            if resp.status_code!=200: return r
+            for l in resp.text.split('\n'):
+                l=l.strip()
+                if l.startswith('http') and '.m3u8' in l:
+                    c=l.split('|')[0].strip()
+                    for k in CH:
+                        if k in c.lower(): r.append((k,c));break
+        except: pass
+        return r
+    with ThreadPoolExecutor(2) as ex:
+        for fu in as_completed({ex.submit(f,n,url):n for n,url in PL.items()},20):
+            for k,v in fu.result():
+                if k not in u: u[k]=v
+    return u
+
+def _bl(ch):
+    u=BLG.get(SID.get(ch))
+    if not u: return None
+    try:
+        r=requests.get(u,headers={**UA,"Referer":"https://www.xemtivitop.com/"},timeout=12)
+        if r.status_code==200: return _ex(r.text)
+    except: pass
+    return None
 
-# ===================== API ENDPOINTS =====================
+def fetch(ch):
+    ch=ch.lower().strip()
+    m={'vtvct':'vtv10','vtv-can-tho':'vtv10','cantho':'vtv10'}
+    ch=m.get(ch,ch)
+    if ch not in CH: return None
+    c=_gc(ch)
+    if c is not None: return c
+    r=None;s=SID.get(ch)
+    if not r:
+        pl=_pl()
+        if ch in pl: r=_v(pl[ch],t=10)
+    if not r and s in FPT: r=_v(FPT[s],"https://fptplay.vn/",8)
+    if not r and ch in BLG:
+        u=_bl(ch)
+        if u: r=_v(u,t=10)
+    if not r and s in SSA: r=_v(SSA[s],t=5)
+    if not r and s in VGO: r=_v(VGO[s],"https://vtvgo.vn/",8)
+    if not r and s in MED: r=_v(MED[s],"https://tv.mediacdn.vn/",8)
+    _sc(ch,r)
+    return r
 
 @router.get("/api/vtv/streams")
-def api_vtv_streams():
-    result = {}
-    for ch_id in CHANNEL_NAMES:
-        stream_url = fetch_vtv_stream(ch_id)
-        result[ch_id] = {
-            "name": CHANNEL_NAMES[ch_id],
-            "stream_url": stream_url,
-            "status": "ok" if stream_url else "offline"
-        }
-    return JSONResponse(result)
-
-@router.get("/api/vtv/stream/{channel_id}")
-def api_vtv_stream(channel_id: str):
-    stream_url = fetch_vtv_stream(channel_id)
-    if stream_url:
-        return JSONResponse({"stream_url": stream_url, "status": "ok"})
-    return JSONResponse({"error": "stream not found", "status": "offline"}, status_code=404)
-
-@router.get("/api/proxy/page")
-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/"
-        elif "sv2.xemtivitop.com" in url: headers["Referer"] = "https://sv2.xemtivitop.com/"
-        elif "xemtivitop.com" in url: headers["Referer"] = "https://www.xemtivitop.com/"
-        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")
-        return Response(
-            content=r.text.encode("utf-8"),
-            media_type="text/html; charset=utf-8",
-            headers={"Access-Control-Allow-Origin": "*"}
-        )
-    except Exception as e:
-        return Response(status_code=502, content=f"proxy error: {str(e)[:100]}")
+def api_s():
+    res={}
+    with ThreadPoolExecutor(len(CH)) as ex:
+        futs={ex.submit(fetch,c):c for c in CH}
+        for f in as_completed(futs,60):
+            c=futs[f];v=f.result();res[c]={"name":CH[c],"stream_url":v,"status":"ok" if v else "offline"}
+    return JSONResponse(res)
+
+@router.get("/api/vtv/stream/{ch}")
+def api_s2(ch:str):
+    u=fetch(ch)
+    if u: return JSONResponse({"stream_url":u,"status":"ok"})
+    return JSONResponse({"error":"stream not found","status":"offline"},404)
+
+@router.get("/api/vtv/debug/{ch}")
+def api_d(ch:str):
+    ch=ch.lower().strip()
+    if ch not in CH: return JSONResponse({"error":"not found"},404)
+    s=SID.get(ch);res={}
+    if s in FPT: res["fptplay"]=str(_v(FPT[s],"https://fptplay.vn/",8))
+    if s in SSA: res["ssaimh"]=str(_v(SSA[s],t=5))
+    res["blogspot"]=_bl(ch) or "failed"
+    if s in VGO: res["vtvgo"]=str(_v(VGO[s],"https://vtvgo.vn/",8))
+    if s in MED: res["mediacdn"]=str(_v(MED[s],"https://tv.mediacdn.vn/",8))
+    pl=_pl();res["iptv_playlist"]=pl.get(ch,"not_found")
+    return JSONResponse({"channel":ch,"results":res})
 
 @router.get("/api/proxy/m3u8/vtv")
-def proxy_vtv_m3u8(url: str = Query(...)):
+def pm(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 "vtvdigital" in url or "vtvgo" in url:
-            headers["Referer"] = "https://vtvgo.vn/"
-        elif "sv2.xemtivitop" in url:
-            headers["Referer"] = "https://sv2.xemtivitop.com/"
-        elif "mediacdn" in url:
-            headers["Referer"] = "http://tv.mediacdn.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")
-        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)
+        h={"User-Agent":UA["User-Agent"],"Accept":"*/*"}
+        if "fptplay" in url: h["Referer"]="https://fptplay.vn/"
+        r=requests.get(url,headers=h,timeout=15)
+        if r.status_code!=200: return Response(status_code=502,content="upstream error")
+        base=url.rsplit('/',1)[0]+'/';out=[]
+        for l in r.text.split('\n'):
+            l=l.strip()
+            if not l or l.startswith('#'): out.append(l)
             else:
-                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:
-                    rewritten.append("/api/proxy/seg/vtv?url=" + requests.utils.quote(seg_url, safe=""))
-        return Response(
-            content='\n'.join(rewritten).encode("utf-8"),
-            media_type="application/vnd.apple.mpegurl",
-            headers={
-                "Access-Control-Allow-Origin": "*",
-                "Cache-Control": "no-cache"
-            }
-        )
-    except Exception as e:
-        return Response(status_code=502, content=f"proxy error: {str(e)[:100]}")
+                s=l if l.startswith('http') else base+l
+                q=requests.utils.quote(s,safe="")
+                out.append(f"/api/proxy/seg/vtv?url={q}" if not s.endswith('.m3u8') else f"/api/proxy/m3u8/vtv?url={q}")
+        return Response(content='\n'.join(out).encode(),media_type="application/vnd.apple.mpegurl",headers={"Access-Control-Allow-Origin":"*","Cache-Control":"no-cache"})
+    except Exception as e: return Response(status_code=502,content=f"error: {str(e)[:100]}")
 
 @router.get("/api/proxy/seg/vtv")
-def proxy_vtv_segment(url: str = Query(...)):
+def ps(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 "mediacdn" in url:
-            headers["Referer"] = "http://tv.mediacdn.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")
-        data = r.content
-        # Strip PNG wrapper if present (some CDNs wrap MPEG-TS in PNG)
-        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 =====================
-
-_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 _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))
-            base_date = reference_date or datetime.now(VN_TZ)
-            if hour < 5:
-                tv_date = base_date - timedelta(days=1) if base_date.hour >= 5 else base_date
-            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 _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)
-
+        h={"User-Agent":UA["User-Agent"],"Accept":"*/*"}
+        r=requests.get(url,headers=h,timeout=30)
+        if r.status_code!=200: return Response(status_code=502,content="upstream error")
+        d=r.content
+        if len(d)>188 and d[0:4]==b'\x89PNG' and d[188]==0x47: d=d[188:]
+        return Response(content=d,media_type="video/mp2t",headers={"Access-Control-Allow-Origin":"*","Cache-Control":"public,max-age=3600"})
+    except: return Response(status_code=502,content="proxy error")
+
+@router.get("/api/vtv/epg/{ch}")
+def ae(ch:str):
+    ch=ch.lower().strip()
+    if ch not in CH: return JSONResponse({"error":"not found"},404)
     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")
-
-        # Extract channel order from navigation
-        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
-                })
-
-        # Sort and deduplicate programmes
-        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 _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 = [p for p in programmes if p.get("start_dt") and p["start_dt"].date() == today]
-    if not today_programmes:
-        today_programmes = programmes
-
-    for i, p in enumerate(today_programmes):
-        start_dt = p.get("start_dt")
-        stop_dt = today_programmes[i + 1].get("start_dt") if i + 1 < len(today_programmes) else None
-        is_now = bool(start_dt and ((stop_dt and start_dt <= now < stop_dt) or start_dt <= now))
-        end_time = stop_dt.strftime("%H:%M") if stop_dt else ""
-        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)
-    })
+        r=requests.get("https://vtv.vn/lich-phat-song.htm",headers={**UA,"Referer":"https://vtv.vn/"},timeout=20)
+        if r.status_code!=200: return JSONResponse({"programs":[]})
+        from bs4 import BeautifulSoup
+        s=BeautifulSoup(r.text,"html.parser");progs=[]
+        for ul in s.find_all('ul',class_=re.compile(r'programs')):
+            for li in ul.find_all('li',class_=re.compile(r'program')):
+                ts=li.find('span',class_=re.compile(r'time'))
+                tl=li.find('span',class_=re.compile(r'title'))
+                if ts and tl: progs.append({"time":ts.get_text(strip=True)[:5],"title":tl.get_text(strip=True)[:80]})
+        return JSONResponse({"channel":ch,"channel_name":CH.get(ch,ch),"date":datetime.now().strftime("%Y-%m-%d"),"programs":progs})
+    except: return JSONResponse({"error":"epg failed"},502)