Upload vtv_api.py with huggingface_hub

vtv_api.py

@@ -150,17 +150,82 @@ def fetch_xemtv_us_stream(channel_id):
     return None
 
 def fetch_xemtivitop_stream(channel_id):
-    """Fetch stream from xemtivitop.com blogspot pages"""
+    """Fetch stream from xemtivitop.com blogspot pages - follows iframe chain to find m3u8"""
     page_url = XEMTIVITOP_ENDPOINTS.get(channel_id)
     if not page_url:
         return None
     try:
         headers = {**UA, "Referer": "https://www.xemtivitop.com/"}
         r = requests.get(page_url, headers=headers, timeout=15, allow_redirects=True, verify=False)
-        if r.status_code == 200:
-            m3u8 = extract_m3u8_from_html(r.text)
-            if m3u8:
-                return m3u8
+        if r.status_code != 200:
+            return None
+        html = r.text
+        
+        # Try 1: Direct m3u8 in the page
+        m3u8 = extract_m3u8_from_html(html)
+        if m3u8:
+            return m3u8
+        
+        # Try 2: Find blogspot iframe (kenhtivitop.blogspot.com) and extract m3u8 from it
+        import html as html_lib
+        iframe_match = re.search(r'src="(https://kenhtivitop\.blogspot\.com[^"]*)"', html, re.IGNORECASE)
+        if iframe_match:
+            iframe_url = iframe_match.group(1)
+            try:
+                r2 = requests.get(iframe_url, headers={**UA, "Referer": "https://www.xemtivitop.com/"}, timeout=10, allow_redirects=True, verify=False)
+                if r2.status_code == 200:
+                    m3u8 = extract_m3u8_from_html(r2.text)
+                    if m3u8:
+                        return m3u8
+            except:
+                pass
+        
+        # Try 3: Find PHP endpoint (sv2.xemtivitop.com/live/hot/...) and follow chain
+        php_match = re.search(r'src="(https://sv2\.xemtivitop\.com/live/hot/[^"]*)"', html, re.IGNORECASE)
+        if php_match:
+            php_url = php_match.group(1)
+            try:
+                r3 = requests.get(php_url, headers={**UA, "Referer": "https://www.xemtivitop.com/"}, timeout=10, allow_redirects=True, verify=False)
+                if r3.status_code == 200:
+                    # PHP page may contain iframe to lienket.php
+                    link_match = re.search(r'src="(https://sv2\.xemtivitop\.com/lienket\.php[^"]*)"', r3.text, re.IGNORECASE)
+                    if link_match:
+                        lk_url = link_match.group(1)
+                        try:
+                            r4 = requests.get(lk_url, headers={**UA, "Referer": php_url}, timeout=10, allow_redirects=True, verify=False)
+                            if r4.status_code == 200:
+                                # lienket.php may have href.li / vtvgo / tvmanh references
+                                # Check for href.li redirect
+                                href_li = re.search(r'href="https://href\.li/\?(https?://[^"]*)"', r4.text)
+                                if href_li:
+                                    target = href_li.group(1)
+                                    # vtvgo.vn needs auth - return FPTPlay CDN fallback as best effort
+                                    pass
+                                # Check for tvmanh.com iframes
+                                tvmanh_match = re.search(r'src="(https://playtvmanh\.blogspot\.com[^"]*)"', r4.text, re.IGNORECASE)
+                                if not tvmanh_match:
+                                    tvmanh_match = re.search(r'src="(https://playxemtivitop\.blogspot\.com[^"]*)"', r4.text, re.IGNORECASE)
+                                if tvmanh_match:
+                                    try:
+                                        r5 = requests.get(tvmanh_match.group(1), headers={**UA, "Referer": lk_url}, timeout=10, allow_redirects=True, verify=False)
+                                        if r5.status_code == 200:
+                                            m3u8 = extract_m3u8_from_html(r5.text)
+                                            if m3u8:
+                                                return m3u8
+                                    except:
+                                        pass
+                                # Check for direct m3u8 in lienket page
+                                m3u8 = extract_m3u8_from_html(r4.text)
+                                if m3u8:
+                                    return m3u8
+                        except:
+                            pass
+                    # Direct m3u8 in PHP page
+                    m3u8 = extract_m3u8_from_html(r3.text)
+                    if m3u8:
+                        return m3u8
+            except:
+                pass
     except:
         pass
     return None