Update src/streamlit_app.py

src/streamlit_app.py

@@ -95,7 +95,9 @@ def save_users_registry(users_list):
     with open(registry_file, 'w', encoding='utf-8') as f: json.dump(users_list, f)
     sync_file_to_cloud(registry_file)
 
-# ✅ معالج التواريخ الذكي لتجاهل الأصفار وفهم كل الصيغ (مثل 17.2.2027)
+# ==========================================
+# 📅 معالج التواريخ الذكي
+# ==========================================
 def parse_timestamp(ts):
     if not ts or str(ts).strip() == "": return "Unlimited"
     ts_str = str(ts).strip()
@@ -130,12 +132,6 @@ def calculate_days_left(exp_date_str_or_ts):
 def save_admin(chat_id):
     with open(ADMIN_FILE, "w") as f: f.write(str(chat_id))
 
-def get_admin():
-    try:
-        if os.path.exists(ADMIN_FILE): return int(open(ADMIN_FILE, "r").read().strip())
-    except: pass
-    return None
-
 def load_servers():
     file_name = get_user_servers_file()
     sync_file_from_cloud(file_name)
@@ -218,13 +214,6 @@ def normalize_search_text(text):
     t = str(text).lower()
     t = re.sub(r'\b(بين|بي ان|be in)\b', 'bein', t)
     t = re.sub(r'\b(sports|sport|سبورت|رياضة|رياضه)\b', 'sport', t)
-    t = re.sub(r'\b(ام بي سي)\b', 'mbc', t)
-    t = re.sub(r'\b(اس اس سي)\b', 'ssc', t)
-    t = re.sub(r'\b(الفجر|فجر)\b', 'fajr', t)
-    t = re.sub(r'\b(اون تايم|on time|on sport|اون سبورت|اون)\b', 'ontime', t)
-    t = re.sub(r'\b(ابو ظبي|أبوظبي|ابوظبي)\b', 'abu dhabi', t)
-    t = re.sub(r'\b(الكاس|كاس|كأس|kass)\b', 'alkass', t)
-    t = re.sub(r'\b(دبي)\b', 'dubai', t)
     t = re.sub(r'[^a-z0-9\sأ-ي]', '', t)
     return t
 
@@ -264,21 +253,15 @@ def parse_any_link(url):
             rest = re.split(r'/(?:live|movie|series)/', url, 1)[1]
             rest_clean = re.sub(r'/+', '/', rest).strip('/')
             parts = rest_clean.split('/')
-            if len(parts) >= 2:
-                return host, parts[0], parts[1]
+            if len(parts) >= 2: return host, parts[0], parts[1]
     except: pass
     return None, None, None
 
-def clean_camouflage(text):
-    return re.sub(r'[@#]+', '', text)
+def clean_camouflage(text): return re.sub(r'[@#]+', '', text)
 
-# ==========================================
-# 🚀 الساحب الذكي الشامل (ربط 1 URL لعدة MACs)
-# ==========================================
 def extract_all_links_from_text(text):
     accounts = []
     seen = set()
-
     clean_text = re.sub(r'(https?)\s*:\s*//\s*([a-zA-Z0-9.-]+)\s*\.\s*([a-zA-Z]+)', r'\1://\2.\3', text)
 
     for link in re.findall(r'(https?://[^\s<>"\'\|]+)', clean_text, re.IGNORECASE):
@@ -299,11 +282,9 @@ def extract_all_links_from_text(text):
         if h_m and u_m and p_m:
             h, u, p = h_m.group(1).rstrip('/'), clean_camouflage(u_m.group(1)), clean_camouflage(p_m.group(1))
             uid_str = f"x_{h}_{u}"
-            if uid_str not in seen:
-                accounts.append({'type': 'xtream', 'host': h, 'user': u, 'pass': p, '_uid': str(uuid.uuid4())[:8]}); seen.add(uid_str)
+            if uid_str not in seen: accounts.append({'type': 'xtream', 'host': h, 'user': u, 'pass': p, '_uid': str(uuid.uuid4())[:8]}); seen.add(uid_str)
 
     lines = [line.strip() for line in clean_text.split('\n') if line.strip()]
-    
     current_mac_host = None
     mac_patt = re.compile(r'([0-9A-Fa-f]{2}[:\-][0-9A-Fa-f]{2}[:\-][0-9A-Fa-f]{2}[:\-][0-9A-Fa-f]{2}[:\-][0-9A-Fa-f]{2}[:\-][0-9A-Fa-f]{2})', re.IGNORECASE)
     url_patt = re.compile(r'(https?://[^\s]+)')
@@ -311,13 +292,11 @@ def extract_all_links_from_text(text):
     for line in lines:
         u_m = url_patt.search(line.replace(" ", ""))
         if u_m and 'username=' not in line: current_mac_host = u_m.group(1).rstrip('/')
-
         m_m = mac_patt.search(line)
         if m_m and current_mac_host:
             m = m_m.group(1).upper().replace('-', ':')
             uid_str = f"m_{current_mac_host}_{m}"
-            if uid_str not in seen:
-                accounts.append({'type': 'mac', 'host': current_mac_host, 'mac': m, '_uid': str(uuid.uuid4())[:8]}); seen.add(uid_str); seen.add(current_mac_host+m)
+            if uid_str not in seen: accounts.append({'type': 'mac', 'host': current_mac_host, 'mac': m, '_uid': str(uuid.uuid4())[:8]}); seen.add(uid_str); seen.add(current_mac_host+m)
 
     direct_links = re.findall(r'(https?://[^\s<>"\'\|]+)', clean_text, re.IGNORECASE)
     for link in direct_links:
@@ -325,21 +304,19 @@ def extract_all_links_from_text(text):
         if link not in seen and 'username=' not in link and not re.search(r'/(?:live|movie|series)/', link) and 'get.php?' not in link:
             if any(x in link.lower() for x in ['.m3u8', '.ts', '.m3u', 'mpegts', '/stream/', 'amazonaws', '.dev', '.top', 'ok.ru', 'token=', 'index.', '/play/']):
                 uid_str = f"d_{link}"
-                if uid_str not in seen:
-                    accounts.append({'type': 'direct', 'url': link, '_uid': str(uuid.uuid4())[:8]}); seen.add(uid_str); seen.add(link)
+                if uid_str not in seen: accounts.append({'type': 'direct', 'url': link, '_uid': str(uuid.uuid4())[:8]}); seen.add(uid_str); seen.add(link)
     return accounts
 
 # ==========================================
-# 📡 صائد التواريخ الشامل (MAC Date Hunter)
+# 📡 محرك فحص بورتالات الماك الاستثنائي
 # ==========================================
 def smart_mac_session(mac, change_ua=False):
     session = requests.Session()
-    ua = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0.0.0" if change_ua else "Mozilla/5.0 (QtEmbedded; U; Linux; C) AppleWebKit/533.3 (KHTML, like Gecko) MAG322 stbapp/5.0.1"
+    ua = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36" if change_ua else "Mozilla/5.0 (QtEmbedded; U; Linux; C) AppleWebKit/533.3 (KHTML, like Gecko) MAG322 stbapp/5.0.1"
     session.headers.update({"User-Agent": ua, "Cookie": f"mac={mac}; stb_lang=en; timezone=Europe/London;"})
     retry_strategy = Retry(total=1, status_forcelist=[429, 500, 502, 503, 504], allowed_methods=["HEAD", "GET", "OPTIONS"], backoff_factor=0.5)
-    adapter = HTTPAdapter(max_retries=retry_strategy)
-    session.mount("http://", adapter)
-    session.mount("https://", adapter)
+    session.mount("http://", HTTPAdapter(max_retries=retry_strategy))
+    session.mount("https://", HTTPAdapter(max_retries=retry_strategy))
     return session
 
 def clean_mac_address(mac): return mac.replace(':', '')
@@ -347,13 +324,13 @@ def clean_mac_address(mac): return mac.replace(':', '')
 def test_mac_portal(host, mac):
     session = smart_mac_session(mac)
     conns, is_working, exp = "0 / 1", False, "Unlimited"
-
     try:
         r_hs = session.get(f"{host}/portal.php?type=stb&action=handshake&mac={mac}", timeout=5, verify=False).json()
-        if r_hs.get('js') and 'token' in r_hs['js']: session.headers.update({"Authorization": f"Bearer {r_hs['js']['token']}"})
-        
-        prof = session.get(f"{host}/portal.php?type=stb&action=get_profile&mac={mac}", timeout=5, verify=False).json().get('js', {})
-        if prof:
+        if r_hs.get('js') and isinstance(r_hs['js'], dict) and 'token' in r_hs['js']: session.headers.update({"Authorization": f"Bearer {r_hs['js']['token']}"})
+        prof_req = session.get(f"{host}/portal.php?type=stb&action=get_profile&mac={mac}", timeout=5, verify=False).json()
+        if 'js' in prof_req and prof_req['js'] == []: return False, "Unlimited", "N/A"
+        prof = prof_req.get('js', {})
+        if prof and isinstance(prof, dict):
             is_working = True
             conns = f"{prof.get('active_cons', '0')} / {prof.get('max_connections', '1')}"
             for key in ['phone', 'expire_billing_date', 'expiry', 'expire', 'end_date', 'expiration', 'expiration_date', 'account_balance']:
@@ -366,12 +343,13 @@ def test_mac_portal(host, mac):
     if exp == "Unlimited":
         mac_clean = clean_mac_address(mac)
         endpoints = [
-            f"/portal.php?action=get_main_info&type=account_info&mac={mac}",
+            f"/portal.php?action=get_main_info&type=account_info&mac={mac}&JsHttpRequest=1-xml",
+            f"/portal.php?action=get_agreement_info&type=account_info&mac={mac}&JsHttpRequest=1-xml",
+            f"/portal.php?action=get_payment_info&type=account_info&mac={mac}&JsHttpRequest=1-xml",
             f"/stalker_portal/server/api.php?action=get_subscription_info&mac={mac_clean}",
             f"/stalker_portal/api/v2/player/get_subscription_info?mac={mac_clean}",
             f"/server/api.php?action=get_subscription_info&mac={mac_clean}"
         ]
-        possible_keys = ['phone', 'expire_billing_date', 'expiry', 'expire', 'end_date', 'expiration', 'expiration_date']
         for ep in endpoints:
             try:
                 resp = session.get(f"{host.rstrip('/')}{ep}", timeout=5, verify=False)
@@ -381,19 +359,18 @@ def test_mac_portal(host, mac):
                     if json_match: raw = json_match.group(1)
                     try:
                         data = json.loads(raw)
+                        if 'js' in data and data['js'] == []: continue
                         js_data = data.get('js', data) if isinstance(data, dict) else data
                         if isinstance(js_data, dict):
-                            for key in possible_keys:
+                            for key in ['phone', 'expire_billing_date', 'expiry', 'expire', 'end_date', 'expiration', 'expiration_date']:
                                 if key in js_data and js_data[key] and str(js_data[key]) not in ["0", "0000-00-00 00:00:00", "0000-00-00", "null", "none"]:
-                                    exp = parse_timestamp(str(js_data[key]))
-                                    return True, exp, conns
-                    except:
-                        date_match = re.search(r'(\d{1,4}[-/\.]\d{1,2}[-/\.]\d{1,4})|([A-Z][a-z]+ \d{1,2}, \d{4})', raw)
-                        if date_match: exp = parse_timestamp(date_match.group(0)); return True, exp, conns
+                                    return True, parse_timestamp(str(js_data[key])), conns
+                    except: pass
+                    date_match = re.search(r'(\d{4}-\d{2}-\d{2})|([A-Z][a-z]+ \d{1,2}, \d{4})', raw)
+                    if date_match: return True, parse_timestamp(date_match.group(0)), conns
             except: continue
     return True, exp, conns
 
-# 🔥 تطوير extract_mac_to_m3u_logic (نظام الذكاء المتعدد) 🔥
 def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلام+مسلسلات)", add_ua=False, ext_choice=".m3u8"):
     session = smart_mac_session(mac)
     try:
@@ -401,17 +378,15 @@ def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلا
         if hs.get('js') and 'token' in hs['js']: session.headers.update({"Authorization": f"Bearer {hs['js']['token']}"})
     except: pass
     
-    st.write("🔄 جاري الاتصال بالبورتال واستخراج التصنيفات...")
     try: genres = session.get(f"{portal}/portal.php?type=itv&action=get_genres&mac={mac}&JsHttpRequest=1-xml", timeout=20, verify=False).json().get("js", [])
-    except: return False, "❌ فشل الاتصال بالبورتال، السيرفر بطيء جداً.", 0
-    if not genres: return False, "❌ لم يتم العثور على تصنيفات (حاول تغيير الماك).", 0
+    except: return False, "❌ فشل الاتصال بالبورتال.", 0
+    if not genres: return False, "❌ لم يتم العثور على تصنيفات.", 0
     
     m3u_lines = ["#EXTM3U", "# Generated by Shalaby VIP Panel\n"]
     total_channels = 0
     ua_suffix = "|User-Agent=IPTVSmartersPro" if add_ua else ""
     ext_val = "m3u8" if ext_choice == ".m3u8" else "ts" if ext_choice == ".ts" else ""
 
-    # المستوى الأول: اختبار حماية البورتال
     strategy = "create_link"
     first_genre_id = genres[0].get('id') if genres else None
     if first_genre_id:
@@ -421,7 +396,6 @@ def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلا
                 test_cmd = test_data[0].get("cmd", "") or test_data[0].get("id")
                 test_link = session.get(f"{portal}/portal.php?type=itv&action=create_link&cmd={urllib.parse.quote(str(test_cmd))}&mac={mac}", timeout=5, verify=False).json()
                 if test_link.get("js") and test_link["js"].get("id") is None:
-                    # Fallback Protocol: تجربة Token/Session جديدة
                     session = smart_mac_session(mac, change_ua=True)
                     test_link_2 = session.get(f"{portal}/portal.php?type=itv&action=create_link&cmd={urllib.parse.quote(str(test_cmd))}&mac={mac}", timeout=5, verify=False).json()
                     if test_link_2.get("js") and test_link_2["js"].get("id") is None: strategy = "raw_fallback"
@@ -447,12 +421,10 @@ def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلا
                         name, cid, cmd_str = ch.get("name", "Unknown"), ch.get("id"), str(ch.get("cmd", ""))
                         if not cid or cid in seen: continue
                         seen.add(cid); added = True
-                        
                         if strategy == "create_link": stream_url = f"{portal}/portal.php?type=itv&action=create_link&cmd={urllib.parse.quote(cmd_str)}&mac={mac}"
-                        else: # Raw Link Hunting
+                        else:
                             stream_url = f"{portal}/play/live.php?mac={mac}&stream={cid}"
                             if ext_val: stream_url += f"&extension={ext_val}"
-                            
                         logo = ch.get("logo", "")
                         if mode == "⚽ رياضة فقط VIP":
                             if is_arabic_sport(name, g_name): res_sports.append({"name": f"{name} [{sn}]", "group": categorize_vip_sport(name, sn), "logo": get_vip_logo(name) or logo, "url": stream_url})
@@ -469,8 +441,7 @@ def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلا
                 else: m3u_lines.extend(res_l); total_channels += len(res_l)
         if mode == "⚽ رياضة فقط VIP" and sports_channels:
             sports_channels.sort(key=get_vip_sort_key)
-            for ch in sports_channels:
-                m3u_lines.append(f'#EXTINF:-1 tvg-logo="{ch["logo"]}" group-title="{ch["group"]}",{ch["name"]}\n{ch["url"]}{ua_suffix}'); total_channels += 1
+            for ch in sports_channels: m3u_lines.append(f'#EXTINF:-1 tvg-logo="{ch["logo"]}" group-title="{ch["group"]}",{ch["name"]}\n{ch["url"]}{ua_suffix}'); total_channels += 1
 
     if mode in ["🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"]:
         try:
@@ -483,9 +454,8 @@ def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلا
                         vod_data = session.get(f"{portal}/portal.php?type=vod&action=get_ordered_list&category={c_id}&p={p}&mac={mac}&JsHttpRequest=1-xml", timeout=10, verify=False).json().get("js", {}).get("data", [])
                         if not vod_data: break
                         for vod in vod_data:
-                            name, vid, logo = vod.get("name", "Unknown Movie"), vod.get("cmd", "") or vod.get("id"), vod.get("screenshot_uri", "")
-                            stream_url = f"{portal}/play/vod.php?mac={mac}&stream={vid}&extension=mp4"
-                            m3u_lines.append(f'#EXTINF:-1 tvg-logo="{logo}" group-title="Movies - {c_name}",{name}\n{stream_url}{ua_suffix}'); total_channels += 1
+                            stream_url = f"{portal}/play/vod.php?mac={mac}&stream={vod.get('cmd', '') or vod.get('id')}&extension=mp4"
+                            m3u_lines.append(f'#EXTINF:-1 tvg-logo="{vod.get("screenshot_uri", "")}" group-title="Movies - {c_name}",{vod.get("name", "Unknown Movie")}\n{stream_url}{ua_suffix}'); total_channels += 1
                         p += 1
                     except: break
         except: pass
@@ -501,18 +471,17 @@ def extract_mac_to_m3u_logic(portal, mac, mode="🍿 الكل (لايف+أفلا
                         ser_data = session.get(f"{portal}/portal.php?type=series&action=get_ordered_list&category={c_id}&p={p}&mac={mac}&JsHttpRequest=1-xml", timeout=10, verify=False).json().get("js", {}).get("data", [])
                         if not ser_data: break
                         for ser in ser_data:
-                            name, sid, logo = ser.get("name", "Unknown Series"), ser.get("id"), ser.get("screenshot_uri", "")
-                            stream_url = f"{portal}/play/series.php?mac={mac}&stream={sid}&extension=mp4"
-                            m3u_lines.append(f'#EXTINF:-1 tvg-logo="{logo}" group-title="Series - {c_name}",{name}\n{stream_url}{ua_suffix}'); total_channels += 1
+                            stream_url = f"{portal}/play/series.php?mac={mac}&stream={ser.get('id')}&extension=mp4"
+                            m3u_lines.append(f'#EXTINF:-1 tvg-logo="{ser.get("screenshot_uri", "")}" group-title="Series - {c_name}",{ser.get("name", "Unknown Series")}\n{stream_url}{ua_suffix}'); total_channels += 1
                         p += 1
                     except: break
         except: pass
 
-    if total_channels == 0: return False, "❌ لم يتم العثور على قنوات.", 0
+    if total_channels == 0: return False, "❌ لم يتم العثور على قنوات محتوى صالحة.", 0
     return True, "\n".join(m3u_lines), total_channels
 
 # ==========================================
-# ✅ الفحص الذكي (Xtream + Direct) + قناص البنج الفعلي
+# ✅ الفحص الذكي وقناص البنج الفعلي (تخطي الوهمي)
 # ==========================================
 def check_server_smart(host, user, pwd):
     headers = get_headers()
@@ -533,41 +502,35 @@ def check_server_smart(host, user, pwd):
     except: pass
     return None
 
-# 🔥 قناص البنج الفعلي (يتخطى البنج الوهمي) 🔥
 def test_live_stream_ping(host, user, pw):
     try:
         api_url = f"{host.rstrip('/')}/player_api.php?username={user}&password={pw}&action=get_live_streams"
         r = requests.get(api_url, headers=get_headers(), timeout=5, verify=False).json()
         if isinstance(r, list) and len(r) > 0:
-            stream_id = r[0].get('stream_id')
-            test_url = f"{host.rstrip('/')}/live/{user}/{pw}/{stream_id}.ts"
+            test_url = f"{host.rstrip('/')}/live/{user}/{pw}/{r[0].get('stream_id')}.ts"
             res = requests.get(test_url, headers=get_headers(), stream=True, timeout=5, verify=False)
             status = res.status_code
             if status in [200, 302, 206]:
                 chunk = next(res.iter_content(chunk_size=128), b"")
                 res.close()
-                if b"<html" in chunk.lower() or b"error" in chunk.lower()[:20]: return False, "❌ السيرفر يعيد صفحة خطأ (بث متوقف)."
+                if b"<html" in chunk.lower() or b"error" in chunk.lower()[:20]: return False, "❌ السيرفر يعيد صفحة خطأ (البث متوقف)."
                 return True, "✅ يعمل بقوة."
             res.close()
             return False, f"❌ متوقف (كود {status})."
-        return False, "⚠️ الحساب يعمل لكن لا توجد قنوات لايف."
+        return False, "⚠️ الحساب يعمل لكن قنوات اللايف فارغة."
     except: return False, "❌ فشل الاتصال."
 
 def advanced_direct_link_test(url):
-    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36', 'Accept': '*/*'}
+    headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36'}
     try:
         res = requests.get(url, headers=headers, stream=True, timeout=5, verify=False, allow_redirects=True)
         if res.status_code in [200, 206, 302, 304]:
             chunk = next(res.iter_content(chunk_size=2048), b"")
             res.close() 
             text_chunk = chunk.decode('utf-8', errors='ignore').strip()
-            if text_chunk.startswith("#EXTM3U") or "#EXTINF" in text_chunk:
-                count = max(1, text_chunk.count("#EXTINF"))
-                return True, True, count
-            lower_chunk = text_chunk.lower()
-            if "<html" in lower_chunk and not any(x in url for x in ['.dev', '.workers', '.top']): return False, False, 0
+            if text_chunk.startswith("#EXTM3U") or "#EXTINF" in text_chunk: return True, True, max(1, text_chunk.count("#EXTINF"))
+            if "<html" in text_chunk.lower() and not any(x in url for x in ['.dev', '.workers', '.top']): return False, False, 0
             return True, False, 0
-        res.close()
     except: pass
     return False, False, 0
 
@@ -581,34 +544,20 @@ def process_single_account_sync(a):
             if info:
                 d = calculate_days_left(info.get('exp_date'))
                 ping_ok, _ = test_live_stream_ping(a['host'], a['user'], a['pass'])
-                formats = info.get('formats', 'HLS (m3u8), TS')
-                a.update({
-                    'days': d, 'type_auth': info.get('source', 'Xtream'),
-                    'created_at': parse_timestamp(info.get('created_at')),
-                    'exp_date': parse_timestamp(info.get('exp_date')),
-                    'status': 'يعمل بقوة' if ping_ok else 'متصل (البث متوقف)',
-                    'ping_ok': ping_ok, 'formats': formats, 'conns': info.get('conns', 'N/A')
-                })
+                a.update({'days': d, 'type_auth': info.get('source', 'Xtream'), 'created_at': parse_timestamp(info.get('created_at')), 'exp_date': parse_timestamp(info.get('exp_date')), 'status': 'يعمل بقوة' if ping_ok else 'متصل (البث متوقف)', 'ping_ok': ping_ok, 'formats': info.get('formats', 'HLS, TS'), 'conns': info.get('conns', 'N/A')})
                 return a
         elif a['type'] == 'mac':
             prof_ok, exp, conns = test_mac_portal(a['host'], a['mac'])
             if prof_ok:
-                d = calculate_days_left(exp)
-                a.update({
-                    'days': d, 'type_auth': 'Portal MAC',
-                    'created_at': '-', 'exp_date': exp,
-                    'status': 'يعمل بقوة', 'ping_ok': True, 'formats': 'Stalker/MAG', 'conns': conns
-                })
-            else:
-                a.update({'days': 'MAC', 'type_auth': 'Portal MAC', 'created_at': '-', 'exp_date': '-', 'status': 'لا يعمل', 'ping_ok': False, 'formats': 'Unknown', 'conns': 'N/A'})
+                a.update({'days': calculate_days_left(exp), 'type_auth': 'Portal MAC', 'created_at': '-', 'exp_date': exp, 'status': 'يعمل بقوة', 'ping_ok': True, 'formats': 'Stalker/MAG', 'conns': conns})
+            else: a.update({'days': 'MAC', 'type_auth': 'Portal MAC', 'created_at': '-', 'exp_date': '-', 'status': 'لا يعمل', 'ping_ok': False, 'formats': 'Unknown', 'conns': 'N/A'})
             return a
         elif a['type'] == 'direct':
             ping_ok, is_playlist, ch_count = advanced_direct_link_test(a['url'])
             if ping_ok:
                 if is_playlist: a.update({'host': 'Playlist M3U', 'days': 'Direct', 'type_auth': 'Playlist', 'status': 'قائمة تشغيل تعمل', 'ping_ok': True, 'formats': 'm3u8/ts', 'ch_count': ch_count})
                 else: a.update({'host': 'Direct Link', 'days': 'Direct', 'type_auth': 'Stream', 'status': 'بث مباشر يعمل', 'ping_ok': True, 'formats': 'ts/m3u8'})
-            else:
-                a.update({'host': 'Direct Link', 'days': 'Direct', 'type_auth': 'Stream', 'status': 'لا يعمل', 'ping_ok': False, 'formats': 'Unknown'})
+            else: a.update({'host': 'Direct Link', 'days': 'Direct', 'type_auth': 'Stream', 'status': 'لا يعمل', 'ping_ok': False, 'formats': 'Unknown'})
             return a
     except: pass
     return None
@@ -630,17 +579,14 @@ async def run_async_scan(accs, progress_bar, status_msg, live_placeholder, conte
             if result:
                 valid_found.append(result)
                 valid_found.sort(key=live_sort_key, reverse=True)
-
                 with live_placeholder.container():
                     for srv in valid_found:
                         ping_icon = "🟢" if srv.get('ping_ok') else "🔴"
-                        days_val = srv.get('days', 0)
-                        days_str = f"{days_val} يوم" if str(days_val).isdigit() else str(days_val)
+                        days_str = f"{srv.get('days', 0)} يوم" if str(srv.get('days', 0)).isdigit() else str(srv.get('days', 0))
                         if srv.get('type') == 'direct': st.success(f"{ping_icon} {srv['status']} | 🌐 `{srv['url']}` | ⏳ {days_str}")
                         elif srv.get('type') == 'mac': st.success(f"{ping_icon} {srv['status']} | 🌐 `{srv['host']}` | 💳 `{srv['mac']}` | ⏳ {days_str}")
                         else: st.success(f"{ping_icon} {srv['status']} | 🌐 `{srv['host']}` | 👤 `{srv['user']}` | ⏳ {days_str}")
-                
-                try: 
+                try:
                     if result.get('type') == 'xtream': save_to_global_vips({'host': result['host'], 'user': result['user'], 'pass': result['pass'], 'days': result.get('days')})
                     elif result.get('type') == 'mac': save_to_global_vips({'host': result['host'], 'mac': result['mac'], 'days': result.get('days'), 'type': 'mac'})
                 except: pass
@@ -657,19 +603,76 @@ def safe_async_run(coro):
             asyncio.set_event_loop(new_loop)
             result[0] = new_loop.run_until_complete(coro)
         t = threading.Thread(target=_run)
-        t.start()
-        t.join()
+        t.start(); t.join()
         return result[0]
     else: return asyncio.run(coro)
 
-def live_sort_key(x):
-    ping_status = 1 if x.get('ping_ok', False) else 0
-    days = x.get('days', 0)
-    days_val = float('inf') if str(days).lower() in ['unlimited', 'direct', 'mac', 'none', 'null', '-'] else int(days) if str(days).isdigit() else -1
-    return (ping_status, days_val)
+def extract_sports_unified(host, user, pwd, skip_clean=False, ext=".m3u8"):
+    domain_parts = host.split('//')[-1].split(':')[0].split('.')
+    valid_parts = [p for p in domain_parts if p.lower() not in ['com', 'net', 'org', 'info', 'tv'] and len(p)>2]
+    sn = re.sub(r'[^a-zA-Z0-9]', '', valid_parts[0].capitalize() if valid_parts else domain_parts[0].capitalize())
+    try:
+        r = requests.get(f"{host}/player_api.php?username={user}&password={pwd}", headers=get_headers(), timeout=12, verify=False).json()
+        info = r.get('user_info', {})
+        if info.get('status') != 'Active': return False, f"❌ متوقف: {sn}"
+        save_server_to_db(host, user, pwd, calculate_days_left(info.get('exp_date')), auth_type='Xtream', created_at=parse_timestamp(info.get('created_at')), exp_date=parse_timestamp(info.get('exp_date')))
+        streams = requests.get(f"{host}/player_api.php?username={user}&password={pwd}&action=get_live_streams", timeout=25, verify=False).json()
+        cats = requests.get(f"{host}/player_api.php?username={user}&password={pwd}&action=get_live_categories", timeout=25, verify=False).json()
+        cat_map = {i['category_id']: i['category_name'] for i in cats}
+        new_chans = []
+        for s in streams:
+            name, cat = str(s.get('name', '')), str(cat_map.get(s.get('category_id'), "Other"))
+            if is_arabic_sport(name, cat):
+                ch_id = f"ch_{s.get('stream_id')}_{re.sub(r'\W','',host.lower())}_{re.sub(r'\W','',user.lower())}"
+                new_chans.append({"id": ch_id, "name": f"{name} [{sn}]", "group": categorize_vip_sport(name, sn), "logo": get_vip_logo(name) or s.get("stream_icon", ""), "url": f"{host}/live/{user}/{pwd}/{s.get('stream_id')}{ext}", "userAgent": "IPTVSmartersPro"})
+        if not new_chans: return False, f"⚠️ لا يوجد باقات رياضية في {sn}"
+        db = load_db(); merged = {c['id']: c for c in db}
+        for c in new_chans: merged[c['id']] = c
+        final = list(merged.values()); final.sort(key=get_vip_sort_key); save_db(final)
+        return True, f"✅ تم سحب {len(new_chans)} باقة من [{sn}]"
+    except: return False, f"❌ خطأ اتصال في {sn}"
+
+def custom_api_extractor(host, user, pw, mode, ext_choice, add_ua):
+    output_file = f"Extracted_VIP_{user}.m3u"
+    extracted_count = 0
+    live_ext = "" if ext_choice == "بدون صيغة" else ext_choice
+    ua_suffix = "|User-Agent=IPTVSmartersPro" if add_ua else ""
+    host = host.rstrip('/')
+    with open(output_file, 'w', encoding='utf-8') as f:
+        f.write("#EXTM3U\n")
+        if mode == "⚽ رياضة فقط VIP":
+            try:
+                streams = requests.get(f"{host}/player_api.php?username={user}&password={pw}&action=get_live_streams", timeout=25, verify=False).json()
+                cats = requests.get(f"{host}/player_api.php?username={user}&password={pw}&action=get_live_categories", timeout=25, verify=False).json()
+                cat_map = {i['category_id']: i['category_name'] for i in cats}
+                sn = host.split('//')[-1].split('.')[0].capitalize()
+                vip_ch = []
+                for s in streams:
+                    if is_arabic_sport(str(s.get('name','')), str(cat_map.get(s.get('category_id'), ''))):
+                        vip_ch.append({"name": f"{s.get('name')} [{sn}]", "group": categorize_vip_sport(s.get('name'), sn), "logo": get_vip_logo(s.get('name')) or s.get("stream_icon", ""), "url": f"{host}/live/{user}/{pw}/{s.get('stream_id')}{live_ext}"})
+                vip_ch.sort(key=get_vip_sort_key)
+                for ch in vip_ch: f.write(f'#EXTINF:-1 tvg-logo="{ch["logo"]}" group-title="{ch["group"]}",{ch["name"]}\n{ch["url"]}{ua_suffix}\n'); extracted_count += 1
+            except: pass
+        else:
+            if mode in ["📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"]:
+                try:
+                    data = requests.get(f"{host}/player_api.php?username={user}&password={pw}&action=get_live_streams", timeout=25, verify=False).json()
+                    for ch in data: f.write(f'#EXTINF:-1 tvg-logo="{ch.get("stream_icon", "")}" group-title="Live TV",{ch.get("name")}\n{host}/live/{user}/{pw}/{ch.get("stream_id")}{live_ext}{ua_suffix}\n'); extracted_count += 1
+                except: pass
+            if mode in ["🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"]:
+                try:
+                    data = requests.get(f"{host}/player_api.php?username={user}&password={pw}&action=get_vod_streams", timeout=25, verify=False).json()
+                    for mov in data: f.write(f'#EXTINF:-1 tvg-logo="{mov.get("stream_icon", "")}" group-title="Movies",{mov.get("name")}\n{host}/movie/{user}/{pw}/{mov.get("stream_id")}.{mov.get("container_extension", "mp4")}{ua_suffix}\n'); extracted_count += 1
+                except: pass
+            if mode == "🍿 الكل (لايف+أفلام+مسلسلات)":
+                try:
+                    data = requests.get(f"{host}/player_api.php?username={user}&password={pw}&action=get_series", timeout=25, verify=False).json()
+                    for ser in data: f.write(f'#EXTINF:-1 tvg-logo="{ser.get("cover", "")}" group-title="Series",{ser.get("name")}\n{host}/series/{user}/{pw}/{ser.get("series_id")}{live_ext}{ua_suffix}\n'); extracted_count += 1
+                except: pass
+    return extracted_count > 0, output_file, extracted_count
 
 # ==========================================
-# 🎨 واجهة الكروت الموحدة (Header مُحسّن)
+# 🎨 واجهة الكروت الذكية الفائقة (Super UX Header)
 # ==========================================
 def render_server_card(server, idx, context="tab1"):
     t = server.get('type')
@@ -678,308 +681,160 @@ def render_server_card(server, idx, context="tab1"):
     uid_str = server.get('_uid', str(uuid.uuid4())[:8])
     base_k = f"{context}_{idx}_{uid_str}"
     
-    force_open = False
-    if f"file_{base_k}" in st.session_state or f"ping_res_{base_k}" in st.session_state or f"prep_err_{base_k}" in st.session_state or f"preview_url_{base_k}" in st.session_state or f"preview_err_{base_k}" in st.session_state:
-        force_open = True
-
+    force_open = f"file_{base_k}" in st.session_state or f"ping_res_{base_k}" in st.session_state or f"prep_err_{base_k}" in st.session_state or f"preview_url_{base_k}" in st.session_state
     ping_icon = "🟢" if server.get('ping_ok') else "🔴"
-    status_str = server.get('status', 'نشط')
     
-    # 🌟 Header Section: كل البيانات بالخارج لسهولة الـ Copy
-    if t == 'direct':
-        title = f"{ping_icon} {status_str} | 🌐 {server.get('url', '')} | ⏳ {days_str}"
-    elif t == 'mac':
-        title = f"{ping_icon} {status_str} | 🌐 {server.get('host', '')} | 💳 {server.get('mac', '')} | 👥 {server.get('conns', '0 / 1')} | 🛑 {server.get('exp_date', 'Unlimited')} | ⏳ {days_str}"
-    else:
-        title = f"{ping_icon} {status_str} | 🌐 {server.get('host', '')} | 👤 {server.get('user', '')} | 🔑 {server.get('pass', '')} | 👥 {server.get('conns', 'N/A')} | 🛑 {server.get('exp_date', 'Unlimited')} | ⏳ {days_str}"
+    if t == 'direct': title = f"{ping_icon} {server['status']} | 🌐 {server.get('url', '')} | ⏳ {days_str}"
+    elif t == 'mac': title = f"{ping_icon} {server['status']} | 🌐 {server.get('host', '')} | 💳 {server.get('mac', '')} | 👥 {server.get('conns', '0/1')} | 🛑 {server.get('exp_date', 'Unlimited')} | ⏳ {days_str}"
+    else: title = f"{ping_icon} {server['status']} | 🌐 {server.get('host', '')} | 👤 {server.get('user', '')} | 🔑 {server.get('pass', '')} | 👥 {server.get('conns', 'N/A')} | 🛑 {server.get('exp_date', 'Unlimited')} | ⏳ {days_str}"
         
     title += "\u200B" * st.session_state.reset_exp
     
     with st.expander(title, expanded=force_open):
-        # 🔥 داخل البطاقة: رابط M3U المباشر في أول سطر 🔥
         if t == 'xtream':
             formatted_m3u_url = f"{server['host'].rstrip('/')}/get.php?username={server['user']}&password={server['pass']}&type=m3u_plus"
-            st.text_input("🔗 الرابط المباشر للمشغل (M3U_PLUS) - للنسخ السريع:", value=formatted_m3u_url, key=f"link_m3u_{base_k}")
+            st.text_input("🔗 رابط M3U المباشر للمشغل الخارجي (للنسخ السريع):", value=formatted_m3u_url, key=f"link_m3u_{base_k}")
             st.markdown("---")
-            st.markdown(f"### ⚙️ خيارات السحب والتشغيل:")
-
+            st.markdown(f"### ⚙️ خيارات التحكم والسحب:")
         elif t == 'direct':
-            st.text_input("🔗 الرابط المباشر - للنسخ السريع:", value=server.get('url', ''), key=f"link_{base_k}")
+            st.text_input("🔗 رابط الملف التنزيلي السريع:", value=server.get('url', ''), key=f"link_{base_k}")
             st.markdown("---")
-            st.markdown(f"### ⚙️ خيارات التشغيل:")
-            
-        elif t == 'mac':
-            st.markdown(f"### ⚙️ خيارات سحب الماك الذكية:")
+            st.markdown(f"### ⚙️ خيارات التشغيل المعاينة:")
 
-        # ================== أزرار التحكم ==================
         if t == 'direct':
             col_p1, col_p2 = st.columns(2)
             with col_p1:
-                if server.get('type_auth') == 'Playlist':
-                    if st.button("📥 سحب القنوات (قائمة التشغيل)", key=f"prep_{base_k}"):
-                        with st.spinner("جاري سحب المحتوى..."):
-                            try:
-                                txt = requests.get(server['url'], headers=get_headers(), timeout=10, verify=False).text
-                                st.session_state[f"file_{base_k}"] = txt.encode('utf-8')
-                                st.session_state[f"count_{base_k}"] = txt.count("#EXTINF")
-                                st.session_state[f"filename_{base_k}"] = f"Playlist_{uid_str}.m3u"
-                                st.rerun()
-                            except: st.error("❌ فشل الاتصال وسحب القائمة.")
+                if server.get('type_auth') == 'Playlist' and st.button("📥 سحب القنوات (M3U Playlist)", key=f"prep_{base_k}"):
+                    with st.spinner("جاري سحب المحتوى..."):
+                        try:
+                            # 🛡️ تخطي حماية سيرفرات Cloudflare Workers بالتنكر كمتصفح Chrome 🛡️
+                            browser_headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 Chrome/120.0.0.0 Safari/537.36', 'Accept': '*/*'}
+                            txt = requests.get(server['url'], headers=browser_headers, timeout=15, verify=False).text
+                            st.session_state[f"file_{base_k}"], st.session_state[f"count_{base_k}"], st.session_state[f"filename_{base_k}"] = txt.encode('utf-8'), txt.count("#EXTINF"), f"Playlist_{uid_str}.m3u"
+                            st.rerun()
+                        except: st.error("❌ فشل سحب روابط القائمة المباشرة. السيرفر يرفض الاتصال.")
             with col_p2:
-                if st.button("📺 خيارات المعاينة", key=f"preview_{base_k}"):
-                    st.session_state[f"preview_url_{base_k}"] = server.get('url', '')
-                    st.rerun()
+                if st.button("📺 تشغيل معاينة القناة المباشرة", key=f"preview_{base_k}"): st.session_state[f"preview_url_{base_k}"] = server.get('url', ''); st.rerun()
                     
         elif t == 'mac':
             col_mode, col_ext, col_ua, col_btn = st.columns([3, 2, 2, 2])
-            mac_mode = col_mode.selectbox("🎯 المحتوى:", ["⚽ رياضة فقط VIP", "📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"], key=f"mode_{base_k}")
-            mac_ext = col_ext.selectbox("صيغة البث:", [".m3u8", ".ts", "بدون صيغة"], index=0, key=f"ext_{base_k}")
-            mac_ua = col_ua.checkbox("إضافة حماية UA", value=False, key=f"ua_{base_k}")
-            
-            if col_btn.button("📥 تجهيز السحب", key=f"prep_btn_{base_k}"):
-                with st.spinner("جاري سحب قنوات الماك الذكي (يُرجى الانتظار)..."):
+            mac_mode = col_mode.selectbox("🎯 قسم المحتوى الباقات:", ["⚽ رياضة فقط VIP", "📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"], key=f"mode_{base_k}")
+            mac_ext = col_ext.selectbox("صيغة مشغل البث الفعلي:", [".m3u8", ".ts", "بدون صيغة"], index=0, key=f"ext_{base_k}")
+            mac_ua = col_ua.checkbox("حماية التخطي UA", value=False, key=f"ua_{base_k}")
+            if col_btn.button("📥 بدء سحب الماك", key=f"prep_btn_{base_k}"):
+                with st.spinner("جاري الاختراق وسحب القنوات بالتوازي..."):
                     ok, res_text, count = extract_mac_to_m3u_logic(server['host'], server['mac'], mac_mode, mac_ua, mac_ext)
-                    if ok:
-                        st.session_state[f"file_{base_k}"] = res_text.encode('utf-8')
-                        st.session_state[f"count_{base_k}"] = count
-                        st.session_state[f"filename_{base_k}"] = f"MAC_{server['mac'].replace(':','')}.m3u"
-                        if f"prep_err_{base_k}" in st.session_state: del st.session_state[f"prep_err_{base_k}"]
+                    if ok: st.session_state[f"file_{base_k}"], st.session_state[f"count_{base_k}"], st.session_state[f"filename_{base_k}"] = res_text.encode('utf-8'), count, f"MAC_{server['mac'].replace(':','')}.m3u"
                     else: st.session_state[f"prep_err_{base_k}"] = res_text
                     st.rerun()
 
         elif t == 'xtream':
             col_ping, col_preview = st.columns(2)
             with col_ping:
-                if st.button("📡 فحص البث الفعلي بدقة", key=f"ping_{base_k}"):
-                    with st.spinner("جاري اختبار سحب الداتا الفعلي..."):
+                if st.button("📡 فحص دقة البث الفعلي (GET البايتات)", key=f"ping_{base_k}"):
+                    with st.spinner("جاري فحص سلامة داتا الفيديو للبث..."):
                         ok, msg = test_live_stream_ping(server['host'], server['user'], server['pass'])
-                        st.session_state[f"ping_res_{base_k}"] = (ok, msg)
-                        st.rerun()
+                        st.session_state[f"ping_res_{base_k}"] = (ok, msg); st.rerun()
             with col_preview:
-                if st.button("📺 خيارات معاينة البث", key=f"preview_btn_{base_k}"):
-                    with st.spinner("جاري جلب رابط البث للمعاينة..."):
+                if st.button("📺 جلب داتا مشغل المعاينة", key=f"preview_btn_{base_k}"):
+                    with st.spinner("جاري توليد مسار المشغل..."):
                         try:
-                            api_url = f"{server['host'].rstrip('/')}/player_api.php?username={server['user']}&password={server['pass']}&action=get_live_streams"
-                            r_streams = requests.get(api_url, headers={'User-Agent': 'IPTVSmartersPro'}, timeout=5, verify=False).json()
-                            if isinstance(r_streams, list) and len(r_streams) > 0:
-                                s_id = r_streams[0].get('stream_id')
-                                play_url = f"{server['host'].rstrip('/')}/live/{server['user']}/{server['pass']}/{s_id}.m3u8"
-                                st.session_state[f"preview_url_{base_k}"] = play_url
-                            else: st.session_state[f"preview_err_{base_k}"] = "لم يتم العثور على قنوات للمعاينة."
-                        except: st.session_state[f"preview_err_{base_k}"] = "فشل الاتصال لجلب البث."
+                            r_streams = requests.get(f"{server['host'].rstrip('/')}/player_api.php?username={server['user']}&password={server['pass']}&action=get_live_streams", headers=get_headers(), timeout=5, verify=False).json()
+                            if isinstance(r_streams, list) and len(r_streams) > 0: st.session_state[f"preview_url_{base_k}"] = f"{server['host'].rstrip('/')}/live/{server['user']}/{server['pass']}/{r_streams[0].get('stream_id')}.m3u8"
+                            else: st.session_state[f"preview_err_{base_k}"] = "لم نجد قنوات للمعاينة الفورية."
+                        except: st.session_state[f"preview_err_{base_k}"] = "فشل توليد اتصال المعاينة."
                     st.rerun()
 
             if f"ping_res_{base_k}" in st.session_state:
                 ok, msg = st.session_state[f"ping_res_{base_k}"]
                 if ok: st.success(msg)
                 else: st.error(msg)
-            if f"preview_err_{base_k}" in st.session_state:
-                st.error(st.session_state[f"preview_err_{base_k}"])
-
-            def custom_api_extractor_sync(host, user, pw, mode, ext_choice, add_ua):
-                headers = {'User-Agent': 'IPTVSmartersPro', 'Accept': '*/*'}
-                output_file = f"Extracted_VIP_{user}.m3u"
-                extracted_count = 0
-                live_ext = "" if ext_choice == "بدون صيغة" else ext_choice
-                ua_suffix = "|User-Agent=IPTVSmartersPro" if add_ua else ""
-                if host.endswith('/'): host = host[:-1]
-                
-                with open(output_file, 'w', encoding='utf-8') as f:
-                    f.write("#EXTM3U\n")
-                    if mode == "⚽ رياضة فقط VIP":
-                        api_url = f"{host}/player_api.php?username={user}&password={pw}"
-                        try:
-                            streams = requests.get(f"{api_url}&action=get_live_streams", timeout=25, verify=False).json()
-                            cats = requests.get(f"{host}/player_api.php?username={user}&password={pw}&action=get_live_categories", headers=headers, timeout=25, verify=False).json()
-                            cat_map = {i['category_id']: i['category_name'] for i in cats}
-                            domain_parts = host.split('//')[-1].split(':')[0].split('.')
-                            valid_parts = [p for p in domain_parts if p.lower() not in ['com', 'net', 'org', 'info', 'tv'] and len(p)>2]
-                            sn = re.sub(r'[^a-zA-Z0-9]', '', valid_parts[0].capitalize() if valid_parts else "Server")
-                            vip_channels = []
-                            for s in streams:
-                                name, cat = str(s.get('name', '')), str(cat_map.get(s.get('category_id'), "Other"))
-                                if is_arabic_sport(name, cat):
-                                    chic_name = f"{name} [{sn}]"
-                                    vip_channels.append({"name": chic_name, "group": categorize_vip_sport(name, sn), "logo": get_vip_logo(name) or s.get("stream_icon", ""), "url": f"{host}/live/{user}/{pw}/{s.get('stream_id')}{live_ext}"})
-                            vip_channels.sort(key=get_vip_sort_key)
-                            for ch in vip_channels:
-                                f.write(f'#EXTINF:-1 tvg-logo="{ch["logo"]}" group-title="{ch["group"]}",{ch["name"]}\n{ch["url"]}{ua_suffix}\n'); extracted_count += 1
-                        except: pass
-                    else:
-                        if mode in ["📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"]:
-                            try:
-                                with urllib.request.urlopen(urllib.request.Request(f"{host}/player_api.php?username={user}&password={pw}&action=get_live_streams", headers=headers), timeout=30) as resp:
-                                    data = json.loads(resp.read().decode('utf-8'))
-                                    if isinstance(data, list):
-                                        for ch in data: f.write(f'#EXTINF:-1 tvg-logo="{ch.get("stream_icon", "")}" group-title="Live TV",{ch.get("name", "Unknown Live")}\n{host}/live/{user}/{pw}/{ch.get("stream_id", "")}{live_ext}{ua_suffix}\n'); extracted_count += 1
-                            except: pass
-                        if mode in ["🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"]:
-                            try:
-                                with urllib.request.urlopen(urllib.request.Request(f"{host}/player_api.php?username={user}&password={pw}&action=get_vod_streams", headers=headers), timeout=30) as resp:
-                                    data = json.loads(resp.read().decode('utf-8'))
-                                    if isinstance(data, list):
-                                        for mov in data: f.write(f'#EXTINF:-1 tvg-logo="{mov.get("stream_icon", "")}" group-title="Movies",{mov.get("name", "Unknown Movie")}\n{host}/movie/{user}/{pw}/{mov.get("stream_id", "")}.{mov.get("container_extension", "mp4")}{ua_suffix}\n'); extracted_count += 1
-                            except: pass
-                        if mode == "🍿 الكل (لايف+أفلام+مسلسلات)":
-                            try:
-                                with urllib.request.urlopen(urllib.request.Request(f"{host}/player_api.php?username={user}&password={pw}&action=get_series", headers=headers), timeout=30) as resp:
-                                    data = json.loads(resp.read().decode('utf-8'))
-                                    if isinstance(data, list):
-                                        for ser in data: f.write(f'#EXTINF:-1 tvg-logo="{ser.get("cover", "")}" group-title="Series",{ser.get("name", "Unknown Series")} (Series)\n{host}/series/{user}/{pw}/{ser.get("series_id", "")}{live_ext}{ua_suffix}\n'); extracted_count += 1
-                            except: pass
-                return True if extracted_count > 0 else False, output_file, extracted_count
-
-            col_mode, col_ext, col_ua, col_btn = st.columns([3, 2, 2, 2])
-            selected_mode = col_mode.selectbox("🎯 المحتوى:", ["⚽ رياضة فقط VIP", "📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"], key=f"mode_{base_k}")
-            selected_ext = col_ext.selectbox("صيغة البث:", [".m3u8", ".ts", "بدون صيغة"], key=f"ext_{base_k}")
-            add_ua = col_ua.checkbox("إضافة حماية UA", value=False, key=f"ua_{base_k}")
-            
-            if col_btn.button("📥 تجهيز السحب", key=f"prep_btn_{base_k}"):
-                with st.spinner("جاري سحب المحتوى..."):
-                    success, file, count = custom_api_extractor_sync(server['host'], server['user'], server['pass'], selected_mode, selected_ext, add_ua)
-                    if success:
-                        st.session_state[f"file_{base_k}"] = open(file, 'rb').read()
-                        st.session_state[f"count_{base_k}"] = count
-                        st.session_state[f"filename_{base_k}"] = f"VIP_{server['user']}_{selected_mode.split()[0]}.m3u"
-                        if f"prep_err_{base_k}" in st.session_state: del st.session_state[f"prep_err_{base_k}"]
-                    else: st.session_state[f"prep_err_{base_k}"] = "❌ فشل السحب أو المحتوى فارغ."
-                    st.rerun() 
-                    
-            if f"prep_err_{base_k}" in st.session_state: st.error(st.session_state[f"prep_err_{base_k}"])
+            if f"preview_err_{base_k}" in st.session_state: st.error(st.session_state[f"preview_err_{base_k}"])
+
+            col_m, col_e, col_u, col_b = st.columns([3, 2, 2, 2])
+            selected_mode = col_m.selectbox("🎯 المحتوى المستهدف:", ["⚽ رياضة فقط VIP", "📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"], key=f"mode_x_{base_k}")
+            selected_ext = col_e.selectbox("صيغة البث المخرج:", [".m3u8", ".ts", "بدون صيغة"], key=f"ext_x_{base_k}")
+            add_ua = col_u.checkbox("إضافة حماية متقدمة UA", value=False, key=f"ua_x_{base_k}")
+            if col_b.button("📥 سحب داتا السيرفر", key=f"prep_btn_x_{base_k}"):
+                with st.spinner("جاري تجهيز وتحميل الملف..."):
+                    success, file, count = custom_api_extractor(server['host'], server['user'], server['pass'], selected_mode, selected_ext, add_ua)
+                    if success: st.session_state[f"file_{base_k}"], st.session_state[f"count_{base_k}"], st.session_state[f"filename_{base_k}"] = open(file, 'rb').read(), count, f"VIP_{server['user']}.m3u"
+                    else: st.session_state[f"prep_err_{base_k}"] = "❌ السيرفر فارغ أو محظور."
+                    st.rerun()
 
-        # واجهة مشغل المعاينة المدمج
         if f"preview_url_{base_k}" in st.session_state:
             p_url = st.session_state[f"preview_url_{base_k}"]
-            import urllib.parse
             hls_demo = f"https://hls-js.netlify.app/demo/?src={urllib.parse.quote(p_url)}"
-            android_intent = f"intent:{p_url}#Intent;action=android.intent.action.VIEW;type=video/*;end"
-            
-            st.info("💡 معاينة المتصفح المدمجة (بالأسفل). إذا لم تعمل بسبب الحماية، استخدم الأزرار لفتح برامج الموبايل:")
-            player_html = f"""
-            <link href="https://vjs.zencdn.net/7.11.4/video-js.css" rel="stylesheet" />
-            <script src="https://vjs.zencdn.net/7.11.4/video.min.js"></script>
-            <video id="my-video" class="video-js vjs-default-skin vjs-big-play-centered" controls preload="auto" width="100%" height="250" data-setup='{{}}'>
-                <source src="{p_url}" type="application/x-mpegURL">
-            </video>
-            """
-            components.html(player_html, height=270)
-            
-            st.markdown(f"""
-            <div style="background-color: #2b2b2b; padding: 15px; border-radius: 8px; text-align: center; border: 1px solid #444; margin-bottom: 15px;">
-                <p style="color: #ff9800; font-weight: bold; font-size: 14px; margin-bottom: 10px;">🛡️ تخطي حماية المتصفح وتشغيل البث الخارجي:</p>
-                <a href="{android_intent}" style="text-decoration: none;">
-                    <button style="background-color: #00cc66; color: white; border: none; padding: 11px 18px; border-radius: 6px; font-weight: bold; cursor: pointer; margin: 5px; box-shadow: 0px 4px 6px rgba(0,0,0,0.2);">
-                        📱 فتح برامج الهاتف (VLC / MX Player)
-                    </button>
-                </a>
-                <a href="{hls_demo}" target="_blank" style="text-decoration: none;">
-                    <button style="background-color: #ff9800; color: white; border: none; padding: 11px 18px; border-radius: 6px; font-weight: bold; cursor: pointer; margin: 5px;">
-                        🌐 مشغل ويب خارجي (Netlify)
-                    </button>
-                </a>
-            </div>
-            """, unsafe_allow_html=True)
-
-        # واجهة عرض وتنزيل الملفات
+            components.html(f"""<link href="https://vjs.zencdn.net/7.11.4/video-js.css" rel="stylesheet" /><script src="https://vjs.zencdn.net/7.11.4/video.min.js"></script><video id="my-video" class="video-js vjs-default-skin vjs-big-play-centered" controls preload="auto" width="100%" height="250"><source src="{p_url}" type="application/x-mpegURL"></video>""", height=270)
+            st.markdown(f"""<div style="background-color: #2b2b2b; padding: 15px; border-radius: 8px; text-align: center; border: 1px solid #444; margin-bottom: 15px;"><a href="intent:{p_url}#Intent;action=android.intent.action.VIEW;type=video/*;end" style="text-decoration: none;"><button style="background-color: #00cc66; color: white; border: none; padding: 11px 18px; border-radius: 6px; font-weight: bold; cursor: pointer; margin: 5px;">📱 تشغيل مشغل خارجي (VLC / MX)</button></a><a href="{hls_demo}" target="_blank" style="text-decoration: none;"><button style="background-color: #ff9800; color: white; border: none; padding: 11px 18px; border-radius: 6px; font-weight: bold; cursor: pointer; margin: 5px;">🌐 مشغل ويب نتلايف خارجي</button></a></div>""", unsafe_allow_html=True)
+
         if f"file_{base_k}" in st.session_state:
-            st.success(f"✅ تم سحب ({st.session_state[f'count_{base_k}']}) عنصر بنجاح!")
-            st.download_button("💾 تحميل كملف خارجي (.m3u)", data=st.session_state[f"file_{base_k}"], file_name=st.session_state[f"filename_{base_k}"], key=f"dl_{base_k}")
-            
-            with st.expander("🔍 بحث ونسخ القنوات المسحوبة (سريع ومضمون)", expanded=True):
+            st.success(f"✅ تم السحب بنجاح! ({st.session_state[f'count_{base_k}']} عنصر)")
+            st.download_button("💾 تحميل ملف السحب الخارجي (.m3u)", data=st.session_state[f"file_{base_k}"], file_name=st.session_state[f"filename_{base_k}"], key=f"dl_{base_k}")
+            with st.expander("🔍 فرز ونسخ سريع لقنوات الملف المسحوب مباشرة", expanded=True):
                 raw_text = st.session_state[f"file_{base_k}"].decode('utf-8', errors='ignore')
-                st.info("💡 اضغط داخل الصندوق لنسخ القنوات. للفلترة استخدم صندوق البحث بالأعلى:")
-                
                 col_s1, col_s2 = st.columns([3, 1])
-                search_q = col_s1.text_input("🔍 ابحث هنا (مثال: bein, ssc, sport):", key=f"sq_{base_k}")
-                search_clicked = col_s2.button("ابحث 🎯", key=f"sbtn_{base_k}")
-                
-                display_text = raw_text 
-                if search_clicked or search_q:
+                search_q = col_s1.text_input("🔍 اكتب كلمة الفرز هنا (مثل bein, ssc):", key=f"sq_{base_k}")
+                display_text = raw_text
+                if col_s2.button("فلترة 🎯", key=f"sbtn_{base_k}") or search_q:
                     if search_q.strip():
-                        lines = raw_text.splitlines()
-                        filtered = ["#EXTM3U"]
+                        lines, filtered = raw_text.splitlines(), ["#EXTM3U"]
                         for i in range(len(lines)):
-                            if lines[i].startswith("#EXTINF"):
-                                if smart_search_match(search_q, lines[i]):
-                                    filtered.append(lines[i])
-                                    if i + 1 < len(lines) and not lines[i+1].startswith("#EXTINF"):
-                                        filtered.append(lines[i+1])
-                        
-                        found_count = (len(filtered) - 1) // 2
-                        if found_count > 0:
-                            st.success(f"🎯 وجدنا ({found_count}) قناة! اضغط داخل المربع الأبيض ⬇️ واختر (تحديد الكل) ثم (نسخ).")
-                            display_text = "\n".join(filtered)
-                        else:
-                            st.error("❌ لم يتم العثور على قنوات بهذا الاسم.")
-                            display_text = ""
-                    else: st.warning("يرجى كتابة كلمة للبحث.")
-                
-                st.text_area("محتوى الملف (اضغط ضغطة مطولة -> تحديد الكل -> نسخ):", value=display_text, height=300, key=f"all_{base_k}")
+                            if lines[i].startswith("#EXTINF") and smart_search_match(search_q, lines[i]):
+                                filtered.append(lines[i])
+                                if i + 1 < len(lines): filtered.append(lines[i+1])
+                        display_text = "\n".join(filtered)
+                        st.success(f"🎯 تم العثور على {(len(filtered)-1)//2} باقة متطابقة.")
+                st.text_area("محتوى الصندوق (تحديد الكل -> نسخ):", value=display_text, height=250, key=f"all_{base_k}")
             
         st.markdown("---")
         if context == "saved":
-            if st.button("🗑️ حذف السيرفر نهائياً", key=f"del_{base_k}"):
+            if st.button("🗑️ حذف الحساب من السجل نهائياً", key=f"del_{base_k}"):
                 svs = load_servers(); svs.pop(idx); save_all_servers_to_db(svs)
-                st.success("تم الحذف بنجاح!"); time.sleep(1); st.rerun()
+                st.success("تم الحذف!"); time.sleep(1); st.rerun()
         else:
-            if t == 'xtream':
-                if st.button("💾 حفظ في قاعدة بياناتي", key=f"save_{base_k}"):
-                    save_server_to_db(server['host'], server['user'], server['pass'], server['days'], auth_type='Xtream', created_at=server.get('created_at'), exp_date=server.get('exp_date'), conns=server.get('conns'))
-                    st.success("✅ تم حفظ السيرفر بنجاح!")
-            elif t == 'mac':
-                if st.button("💾 حفظ في قاعدة بياناتي", key=f"save_{base_k}"):
-                    save_server_to_db(server['host'], server['mac'], 'MAC Auth', server['days'], auth_type='Portal MAC', created_at=server.get('created_at'), exp_date=server.get('exp_date'), mac=server['mac'], conns=server.get('conns'))
-                    st.success("✅ تم حفظ الماك بنجاح!")
+            if t == 'xtream' and st.button("💾 حفظ السيرفر في قاعدة بياناتي", key=f"save_{base_k}"):
+                save_server_to_db(server['host'], server['user'], server['pass'], server['days'], auth_type='Xtream', created_at=server.get('created_at'), exp_date=server.get('exp_date'), conns=server.get('conns'))
+                st.success("✅ تم حفظ السيرفر بنجاح!")
+            elif t == 'mac' and st.button("💾 حفظ الماك في قاعدة بياناتي", key=f"save_{base_k}"):
+                save_server_to_db(server['host'], server['mac'], 'MAC Auth', server['days'], auth_type='Portal MAC', created_at=server.get('created_at'), exp_date=server.get('exp_date'), mac=server['mac'], conns=server.get('conns'))
+                st.success("✅ تم حفظ الماك بنجاح!")
 
 # ==========================================
-# 🤖 تشغيل البوت والواجهة
+# 🤖 التلغرام والواجهة الرسومية الكاملة
 # ==========================================
 @bot.message_handler(commands=['start', 'menu'])
 def send_menu(message):
-    save_admin(message.chat.id)
-    bot.send_message(message.chat.id, "📺 **Shalaby IPTV Tool**\nأهلاً بك يا هندسة!", parse_mode="Markdown")
+    save_admin(message.chat.id); bot.send_message(message.chat.id, "📺 **Shalaby IPTV Tool**\nأهلاً بك يا هندسة في لوحة الإدارة الذكية للتلفزيون!", parse_mode="Markdown")
 
 @bot.message_handler(commands=['allservers'])
 def send_all_servers(message):
     vips = load_global_vips()
-    if not vips:
-        bot.reply_to(message, "📭 الصندوق الأسود فارغ حالياً.")
-        return
+    if not vips: bot.reply_to(message, "📭 الصندوق الأسود فارغ حالياً."); return
     file_path = "All_Hunted_Servers.txt"
     with open(file_path, "w", encoding="utf-8") as f:
-        f.write(f"--- 📦 إجمالي السيرفرات المصادة: {len(vips)} ---\n\n")
+        f.write(f"--- 📦 إجمالي السيرفرات المصادة الشغالة: {len(vips)} ---\n\n")
         for s in vips:
             if s.get('type') == 'mac': f.write(f"Portal: {s.get('host')}\nMAC: {s.get('mac')}\nDays Left: {s.get('days')}\n")
             else: f.write(f"Host: {s.get('host')}\nUser: {s.get('user')}\nPass: {s.get('pass')}\nDays Left: {s.get('days')}\n")
             f.write("-" * 30 + "\n")
-    with open(file_path, "rb") as doc: bot.send_document(message.chat.id, doc, caption=f"🔥 تفضل يا هندسة، إجمالي السيرفرات المصادة ({len(vips)}).")
+    with open(file_path, "rb") as doc: bot.send_document(message.chat.id, doc, caption=f"🔥 تفضل يا هندسة، ملف إجمالي السيرفرات الصالحة المصادة ({len(vips)}).")
 
 @bot.message_handler(func=lambda message: True)
 def handle_all_messages(message):
-    text = message.text
-    accs = extract_all_links_from_text(text)
+    accs = extract_all_links_from_text(message.text)
     if accs:
-        msg = bot.reply_to(message, "🔍 جاري فحص السيرفرات المرسلة...")
+        msg = bot.reply_to(message, "🔍 جاري فحص وتحليل السيرفرات المرسلة من التلغرام...")
         valid = []
         for a in accs:
             if a['type'] == 'xtream':
                 info = check_server_smart(a['host'], a['user'], a['pass'])
-                if info:
-                    days = calculate_days_left(info.get('exp_date'))
-                    days_str = f"{days} يوم" if str(days).isdigit() else str(days)
-                    valid.append(f"✅ `{a['host']}` | 👤 `{a['user']}` | ⏳ {days_str}")
-                    try: save_to_global_vips({'type': 'xtream', 'host': a['host'], 'user': a['user'], 'pass': a['pass'], 'days': days})
-                    except: pass
+                if info: valid.append(f"✅ `{a['host']}` | 👤 `{a['user']}` | ⏳ {calculate_days_left(info.get('exp_date'))} يوم")
             elif a['type'] == 'mac':
                 prof_ok, exp, _ = test_mac_portal(a['host'], a['mac'])
-                if prof_ok:
-                    days = calculate_days_left(exp)
-                    days_str = f"{days} يوم" if str(days).isdigit() else str(days)
-                    valid.append(f"✅ `{a['host']}` | 💳 `{a['mac']}` | ⏳ {days_str}")
-                    try: save_to_global_vips({'type': 'mac', 'host': a['host'], 'mac': a['mac'], 'days': days})
-                    except: pass
-        if valid: bot.edit_message_text(f"🎉 **تم الفحص بنجاح!**\n\n" + "\n".join(valid), chat_id=msg.chat.id, message_id=msg.message_id, parse_mode="Markdown")
-        else: bot.edit_message_text("❌ لم أجد أي سيرفرات تعمل.", chat_id=msg.chat.id, message_id=msg.message_id)
+                if prof_ok: valid.append(f"✅ `{a['host']}` | 💳 `{a['mac']}` | ⏳ {calculate_days_left(exp)} يوم")
+        if valid: bot.edit_message_text(f"🎉 **تم الفحص من الموتور بنجاح!**\n\n" + "\n".join(valid), chat_id=msg.chat.id, message_id=msg.message_id, parse_mode="Markdown")
+        else: bot.edit_message_text("❌ عذراً لم تنجح أي روابط مرسلة.", chat_id=msg.chat.id, message_id=msg.message_id)
 
 def run_bot_thread_init():
     for t in threading.enumerate():
@@ -987,162 +842,108 @@ def run_bot_thread_init():
     def start_polling():
         try: requests.get(f"https://api.telegram.org/bot{TOKEN}/deleteWebhook?drop_pending_updates=True", timeout=5)
         except: pass
-        time.sleep(2)
-        bot.infinity_polling(timeout=20, long_polling_timeout=10, skip_pending=True)
-    t = threading.Thread(target=start_polling, name="TelegramBotThread", daemon=True)
-    t.start()
+        time.sleep(2); bot.infinity_polling(timeout=20, long_polling_timeout=10, skip_pending=True)
+    threading.Thread(target=start_polling, name="TelegramBotThread", daemon=True).start()
 run_bot_thread_init()
 
 st.set_page_config(page_title="Shalaby IPTV Tool", page_icon="📺", layout="wide")
 
 st.markdown("""
 <style> 
-    .block-container { 
-        max-width: 100% !important; 
-        padding-top: 1rem !important; 
-        padding-left: 1rem !important;
-        padding-right: 1rem !important;
-        padding-bottom: 5rem !important; 
-    } 
-    section[data-testid="stSidebar"] {
-        width: 170px !important;
-        min-width: 170px !important;
-        max-width: 170px !important;
-    }
-    .main { overflow: visible !important; text-align: right; direction: rtl; } 
-    h1 { font-size: 1.8rem !important; margin-bottom: 0 !important; padding-bottom: 0.5rem !important; text-align: center; color: #ff4b4b;} 
+    .block-container { max-width: 100% !important; padding: 1rem !important; padding-bottom: 5rem !important; } 
+    section[data-testid="stSidebar"] { width: 170px !important; min-width: 170px !important; }
+    .main { text-align: right; direction: rtl; } 
+    h1 { font-size: 1.8rem !important; text-align: center; color: #ff4b4b;} 
     div[data-baseweb="tab-list"] { display: flex; flex-direction: column; gap: 8px; } 
     div[data-baseweb="tab"] { width: 100%; justify-content: flex-end; background-color: #2b2b2b; border-radius: 8px; padding: 10px !important; border: 1px solid #444;} 
     div[data-baseweb="tab"]:hover { background-color: #ff4b4b; color: white !important;} 
     .stButton>button { width: 100%; border-radius: 8px; font-weight: bold; background-color: #ff4b4b; color: white; margin-top: 5px;} 
-    .stButton>button:hover { background-color: #ff3333; color: white; border-color: #ff3333; }
     
     [data-testid="stExpander"] details summary {
-        background-color: #262730 !important;
-        border-left: 5px solid #ff9800 !important;
-        border-right: none !important;
-        border-radius: 8px !important;
-        padding: 12px !important;
-        margin-bottom: 5px !important;
-        box-shadow: 0px 4px 6px rgba(0,0,0,0.3) !important;
-        transition: all 0.3s ease !important;
-    }
-    [data-testid="stExpander"] details summary p, 
-    [data-testid="stExpander"] details summary span {
-        color: #ffffff !important; 
-        font-weight: bold !important;
-    }
-    [data-testid="stExpander"] details[open] summary {
-        background-color: #333333 !important;
-        border-left: 5px solid #ff9800 !important;
+        background-color: #262730 !important; border-left: 5px solid #ff9800 !important; border-radius: 8px !important; padding: 12px !important; margin-bottom: 5px !important; box-shadow: 0px 4px 6px rgba(0,0,0,0.3) !important;
     }
     [data-testid="stExpander"] details[open] > div {
-        background-color: #1e1e1e !important; 
-        border: 1px solid #444 !important;
-        border-top: none !important;
-        border-radius: 0 0 10px 10px !important;
-        padding: 20px 40px 20px 20px !important; 
-        margin-top: -5px !important;
-        margin-left: 0px !important; 
-        margin-right: 40px !important; 
-        width: calc(100% - 40px) !important; 
-        box-shadow: inset 0 0 10px rgba(0, 0, 0, 0.5) !important;
-    }
-    [data-testid="stExpander"] details[open] > div p,
-    [data-testid="stExpander"] details[open] > div span,
-    [data-testid="stExpander"] details[open] > div label {
-        color: #e0e0e0 !important;
-    }
-    [data-testid="stExpander"] .stTextInput input,
-    [data-testid="stExpander"] .stTextArea textarea {
-        background-color: #2b2b2b !important;
-        color: #ffffff !important;
-        border: 1px solid #555 !important;
+        background-color: #1e1e1e !important; border: 1px solid #444 !important; border-radius: 0 0 10px 10px !important; padding: 20px !important; margin-right: 40px !important; width: calc(100% - 40px) !important;
     }
 </style>
 """, unsafe_allow_html=True)
 
+# نظام الدخول وحفظ الجلسة في المتصفح تلقائياً
 if not st.session_state.logged_in:
-    st.title("🔐 بوابة الدخول - Shalaby IPTV Tool")
-    tab_in, tab_up = st.tabs(["تسجيل دخول", "إنشاء حساب"])
+    st.title("🔐 بوابة الدخول التلقائية - Shalaby IPTV Tool")
+    tab_in, tab_up = st.tabs(["تسجيل دخول بالحساب الحالي", "إنشاء كود مستخدم جديد"])
     with tab_up:
-        new_user = st.text_input("اختر كود / اسم مستخدم جديد:")
-        if st.button("🚀 إنشاء حساب ودخول"):
+        new_user = st.text_input("اختر كود حسابك الجديد:")
+        if st.button("🚀 إنشاء وتفعيل التلقائي"):
             if new_user.strip():
                 users = load_users_registry()
                 if new_user.strip() not in users:
                     users.append(new_user.strip()); save_users_registry(users)
-                    st.session_state.username = new_user.strip(); st.session_state.logged_in = True
+                    st.session_state.username, st.session_state.logged_in = new_user.strip(), True
                     st.query_params["user_auth"] = new_user.strip()
                     components.html(f"""<script>localStorage.setItem("user_auth", "{new_user.strip()}");</script>""", height=0, width=0)
                     time.sleep(0.5); st.rerun()
-                else: st.error("❌ عذراً، هذا الاسم/الكود مستخدم من قبل.")
+                else: st.error("❌ الكود مستخدم من قبل.")
     with tab_in:
-        exist_user = st.text_input("أدخل الكود الخاص بك:")
-        if st.button("🔓 دخول"):
+        exist_user = st.text_input("أدخل كود الدخول الخاص بك:")
+        if st.button("🔓 مصادقة ودخول"):
             if exist_user.strip() in load_users_registry():
-                st.session_state.username = exist_user.strip(); st.session_state.logged_in = True
+                st.session_state.username, st.session_state.logged_in = exist_user.strip(), True
                 st.query_params["user_auth"] = exist_user.strip()
                 components.html(f"""<script>localStorage.setItem("user_auth", "{exist_user.strip()}");</script>""", height=0, width=0)
                 time.sleep(0.5); st.rerun()
-            else: st.error("❌ هذا الحساب غير موجود.")
+            else: st.error("❌ كود الحساب غير مسجل بالمنظومة.")
     st.stop()
 
 with st.sidebar:
-    st.markdown(f"### 👤 مرحباً بك: `{st.session_state.username}`")
-    st.success("✅ لوحة تحكمك جاهزة.")
+    st.markdown(f"### 👤 الحساب المتصل:\n`{st.session_state.username}`")
     if st.button("🚪 تسجيل خروج"):
         components.html("""<script>localStorage.removeItem("user_auth");</script>""", height=0, width=0)
-        st.query_params.clear(); st.session_state.logged_in = False; st.session_state.username = ""; time.sleep(0.5); st.rerun()
+        st.query_params.clear(); st.session_state.logged_in = False; time.sleep(0.5); st.rerun()
 
-st.title("📺 Shalaby IPTV Tool")
+st.title("📺 اللوحة الأسطورية الشاملة - Shalaby VIP Tool")
 st.markdown("---")
 
 tab1, tab2, tab3, tab4, tab5, tab6 = st.tabs([
-    "🧪 سحب سرفرات ذكي", "🗄️ سرفراتي المحفوظة", "🚀 تحديث كل السرفرات لسحبها", "🏭 m3u categories selector", "🔥 Mac to m3u", "✨ Smart m3u list extractor"
+    "🧪 محرك الفحص الصاروخي الذكي", "🗄️ سجل سيرفراتي المحفوظة", "🚀 تجميع وتحديث الماستر داتابيز", "🏭 منقي الباقات للعملاء المخصص", "🔥 فاحص ومحول الماك الفوري", "✨ ساحب القنوات المطور (Playlist Extractor)"
 ])
 
 with tab1:
-    st.markdown("### 🔍 أدخل السيرفرات المبعثرة:")
+    st.markdown("### 🔍 أدخل البيانات أو النصوص المبعثرة للفحص:")
     if 'valid_found_tab1' in st.session_state and st.session_state['valid_found_tab1']:
-        if st.button("🔽 طي/إغلاق جميع السيرفرات وتنظيف الذاكرة", key="close_t1"):
+        if st.button("🔽 غلق جميع الكروت المفتوحة ومسح الذاكرة التفاعلية", key="close_t1"):
             st.session_state.reset_exp += 1
             for k in list(st.session_state.keys()):
                 if k.startswith("file_") or k.startswith("ping_res_") or k.startswith("prep_err_") or k.startswith("preview_"): del st.session_state[k]
             st.rerun()
 
-    bulk_input = st.text_area("النص المبعثر:", height=150)
-    if st.button("🚀 بدء الفحص والاستخراج الذكي"):
-        if not bulk_input.strip(): st.warning("⚠️ الرجاء إدخال نص أولاً.")
+    bulk_input = st.text_area("ضع الروابط أو نصوص الماكات المبعثرة هنا:", height=150)
+    if st.button("🚀 إطلاق موتور فحص Asyncio الشامل"):
+        if not bulk_input.strip(): st.warning("⚠️ يرجى تعبئة الحقل بالنصوص أولاً.")
         else:
             accs = extract_all_links_from_text(bulk_input)
-            total_to_check = len(accs)
-            if total_to_check == 0: st.error("❌ لم يتم العثور على روابط أو سيرفرات صالحة.")
+            if len(accs) == 0: st.error("❌ لم يتم العثور على أ�� روابط أو ماكات صالحة للبناء التقني.")
             else:
-                progress_bar = st.progress(0)
-                status_msg = st.empty()
-                live_placeholder = st.empty()
-                valid_found = safe_async_run(run_async_scan(accs, progress_bar, status_msg, live_placeholder, "t1"))
-                status_msg.success(f"🎉 اكتمل الفحص بصاروخ Asyncio! وجدنا {len(valid_found)} سيرفرات/روابط.")
-                st.session_state['valid_found_tab1'] = valid_found
-                
-                if valid_found:
-                    current_db = load_servers()
-                    for v in valid_found:
-                        if v.get('type') == 'xtream' and not any(s.get('host') == v['host'] and s.get('user') == v['user'] for s in current_db):
-                            current_db.append(v)
-                    save_all_servers_to_db(current_db)
+                p_bar, s_msg, l_placeholder = st.progress(0), st.empty(), st.empty()
+                v_found = safe_async_run(run_async_scan(accs, p_bar, s_msg, l_placeholder, "tab1"))
+                s_msg.success(f"🎉 اكتمل مسح شبكة بايثون بنجاح! تم اصطياد وتحليل {len(v_found)} سيرفر.")
+                st.session_state['valid_found_tab1'] = v_found
+                if v_found:
+                    c_db = load_servers()
+                    for v in v_found:
+                        if v.get('type') == 'xtream' and not any(s.get('host') == v['host'] and s.get('user') == v['user'] for s in c_db): c_db.append(v)
+                    save_all_servers_to_db(c_db)
 
     if 'valid_found_tab1' in st.session_state and st.session_state['valid_found_tab1']:
-        st.markdown("#### ⚙️ الكروت النهائية بعد الفحص والترتيب التلقائي:")
+        st.markdown("#### ⚙️ الحسابات المصادة والجاهزة للنسخ والسحب الفوري:")
         for i, acc in enumerate(st.session_state['valid_found_tab1']): render_server_card(acc, i, context="t1")
 
 with tab2:
-    st.markdown("### 🗄️ لوحة تحكم السيرفرات المحفوظة")
+    st.markdown("### 🗄️ السيرفرات المسجلة في داتابيز حسابك")
     svs = load_servers()
-    if not svs: st.warning("لا يوجد سيرفرات محفوظة.")
+    if not svs: st.warning("لا توجد حسابات محفوظة في السجل الخاص بك حالياً.")
     else:
-        if st.button("🔽 طي/إغلاق جميع السيرفرات وتنظيف الذاكرة", key="close_t2"):
+        if st.button("🔽 تنظيف ذاكرة الكروت المؤقتة بالسجل", key="close_t2"):
             st.session_state.reset_exp += 1
             for k in list(st.session_state.keys()):
                 if k.startswith("file_") or k.startswith("ping_res_") or k.startswith("prep_err_") or k.startswith("preview_"): del st.session_state[k]
@@ -1150,109 +951,82 @@ with tab2:
         for i, s in enumerate(svs): render_server_card(s, i, context="saved")
 
 with tab3:
-    st.markdown("### 🚀 تجميع وتحديث الماستر داتابيز")
-    if st.button("🔄 بدء التحديث الشامل"):
+    st.markdown("### 🚀 موتور تحديث الماستر داتابيز الشامل وتجميع الرياضة")
+    if st.button("🔄 بدء التجميع والدمج المتوازي لكافة السيرفرات"):
         svs = load_servers()
-        if not svs: st.error("❌ لا يوجد سيرفرات محفوظة.")
+        if not svs: st.error("❌ سجل الحسابات فارغ تماماً!")
         else:
-            progress_bar2 = st.progress(0)
+            p_bar3 = st.progress(0)
             for i, s in enumerate(svs):
-                if s.get('type') != 'mac' and s.get('type') != 'direct': extract_sports_unified(s['host'], s['user'], s['pass'], skip_clean=True, ext=".m3u8")
-                progress_bar2.progress((i + 1) / len(svs))
-            f_db = load_db()
-            m3u_file = export_to_m3u(f_db, "My_Saved_Servers.m3u")
-            st.success(f"✅ تم تحديث {len(f_db)} قناة بنجاح!")
-            with open(m3u_file, "rb") as file: st.download_button(label="💾 تحميل اللستة المحدثة", data=file, file_name=f"Updated_Shalaby_{st.session_state.username}.m3u", mime="audio/x-mpegurl")
+                if s.get('type') in ['xtream', 'Xtream API']: extract_sports_unified(s['host'], s['user'], s['pass'], skip_clean=True, ext=".m3u8")
+                p_bar3.progress((i + 1) / len(svs))
+            f_db = load_db(); m3u_file = export_to_m3u(f_db, "My_Saved_Servers.m3u")
+            st.success(f"🎉 تم دمج وفحص وإدراج {len(f_db)} باقة رياضية محدثة بالماستر داتابيز!")
+            with open(m3u_file, "rb") as file: st.download_button("💾 تحميل ملف اللستة الموحدة الشغالة لقنواتك", data=file, file_name=f"Master_Shalaby_{st.session_state.username}.m3u")
 
 with tab4:
-    st.markdown("### 🏭 إنشاء لستة M3U مخصصة للعملاء")
-    all_channels = load_db()
-    if not all_channels: st.warning("⚠️ قاعدة البيانات فارغة. قم بتحديث الكل أولاً من التاب السابق.")
+    st.markdown("### 🏭 صناعة وتخصيص باقات خاصة للعملاء (Custom Selector)")
+    all_ch = load_db()
+    if not all_ch: st.warning("⚠️ قاعدة داتابيز القنوات فارغة، يرجى التجميع أولاً من التاب السابق.")
     else:
-        unique_groups = set()
-        for ch in all_channels: unique_groups.add(ch['group'].replace('[SD]', '').replace('[HD]', '').replace('[FHD]', '').replace('[4K]', '').strip())
-        selected_groups = st.multiselect("📌 اختر الباقات المطلوبة:", sorted(list(unique_groups)), default=sorted(list(unique_groups))[:2] if unique_groups else None)
-        smart_rename = st.checkbox("✨ تفعيل التنظيف الذكي لأسماء الباقات")
-        if st.button("✨ إنشاء اللستة المخصصة"):
-            if not selected_groups: st.error("❌ الرجاء اختيار باقة واحدة على الأقل.")
+        u_groups = set(ch['group'].replace('[SD]','').replace('[HD]','').replace('[FHD]','').replace('[4K]','').strip() for ch in all_ch)
+        sel_g = st.multiselect("📌 حدد الباقات المراد تصديرها للعميل:", sorted(list(u_groups)))
+        smart_ren = st.checkbox("✨ تنظيف وإعادة هيكلة مسميات الجودة تلقائياً")
+        if st.button("🏭 توليد ملف باقة العميل"):
+            if not sel_g: st.error("❌ يرجى اختيار باقة واحدة على الأقل للتصدير.")
             else:
-                with st.spinner("جاري تجهيز الملف..."):
-                    custom_channels = []
-                    for ch in all_channels:
-                        bg = ch['group'].replace('[SD]', '').replace('[HD]', '').replace('[FHD]', '').replace('[4K]', '').strip()
-                        if bg in selected_groups:
-                            if smart_rename: ch['group'] = categorize_vip_sport(ch['name'], re.search(r'\[(.*?)\]', ch['name']).group(1) if re.search(r'\[(.*?)\]', ch['name']) else "")
-                            custom_channels.append(ch)
-                    if custom_channels:
-                        custom_file = export_to_m3u(custom_channels, "Custom_Client_Playlist.m3u")
-                        st.success(f"🎉 تم إنشاء اللستة بنجاح! ({len(custom_channels)} قناة).")
-                        with open(custom_file, "rb") as file: st.download_button(label="📥 تحميل اللستة المخصصة", data=file, file_name=f"Custom_VIP_{st.session_state.username}.m3u", mime="audio/x-mpegurl")
-                    else: st.error("❌ لم يتم العثور على قنوات.")
+                cust_ch = []
+                for ch in all_ch:
+                    if ch['group'].replace('[SD]','').replace('[HD]','').replace('[FHD]','').replace('[4K]','').strip() in sel_g:
+                        if smart_ren: ch['group'] = categorize_vip_sport(ch['name'], re.search(r'\[(.*?)\]', ch['name']).group(1) if re.search(r'\[(.*?)\]', ch['name']) else "VIP")
+                        cust_ch.append(ch)
+                if cust_ch:
+                    c_file = export_to_m3u(cust_ch, "Client.m3u")
+                    st.success(f"🎉 تم توليد قنوات الملف المخصص بنجاح بنجاح! ({len(cust_ch)} قناة)")
+                    with open(c_file, "rb") as file: st.download_button("📥 تحميل ملف العميل الجاهز المخصص", data=file, file_name=f"Client_{st.session_state.username}.m3u")
+                else: st.error("❌ لم نجد قنوات متوافقة مع اختيارك.")
 
 with tab5:
-    st.markdown("### 🔥 اختراق وتحويل الماك إلى M3U")
-    col1, col2 = st.columns(2)
-    with col1: mac_portal = st.text_input("🔗 رابط البورت (Portal URL):", placeholder="http://example.com:8080")
-    with col2: mac_address = st.text_input("💳 الماك أدرس (MAC Address):", placeholder="00:1A:79:XX:XX:XX")
-    
-    col_m, col_e, col_u, col_b = st.columns([3, 2, 2, 2])
-    mac_mode = col_m.selectbox("🎯 المحتوى:", ["⚽ رياضة فقط VIP", "📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"], key="mac_standalone_mode")
-    mac_ext = col_e.selectbox("صيغة البث:", [".m3u8", ".ts", "بدون صيغة"], index=0, key="mac_standalone_ext")
-    mac_ua = col_u.checkbox("إضافة حماية UA", value=False, key="mac_standalone_ua")
-    
-    if col_b.button("🚀 بدء الاختراق والتحويل"):
-        if not mac_portal or not mac_address: st.warning("⚠️ الرجاء إدخال البورت والماك.")
+    st.markdown("### 🔥 فاحص الماك المنفرد والمحول المباشر لملف M3U")
+    col_h, col_m = st.columns(2)
+    m_portal = col_h.text_input("🔗 رابط البورتال (Portal URL):", placeholder="http://domain.xyz:8080")
+    m_addr = col_m.text_input("💳 الماك أدرس (MAC Address):", placeholder="00:1A:79:XX:XX:XX")
+    col_b1, col_b2, col_b3, col_b4 = st.columns([3, 2, 2, 2])
+    standalone_mode = col_b1.selectbox("🎯 فلتر محتوى السحب المطلوب:", ["⚽ رياضة فقط VIP", "📺 لايف فقط", "🎬 لايف + أفلام", "🍿 الكل (لايف+أفلام+مسلسلات)"], key="st_mode")
+    standalone_ext = col_b2.selectbox("صيغة المشاهدة المستهدفة:", [".m3u8", ".ts", "بدون صيغة"], key="st_ext")
+    standalone_ua = col_b3.checkbox("تفعيل حماية وتخطي UA كـ MAG", value=True)
+    if col_b4.button("🚀 فحص وتحويل الماك"):
+        if not m_portal or not m_addr: st.warning("⚠️ الرجاء تعبئة بيانات البورتال والماك معاً.")
         else:
-            mac_portal = mac_portal.strip().rstrip("/")
-            if not mac_portal.startswith("http"): mac_portal = "http://" + mac_portal
-            with st.spinner("🕵️‍♂️ جاري تحليل الحماية واستخراج القنوات..."):
-                success, result, count = extract_mac_to_m3u_logic(mac_portal, mac_address.strip().upper(), mac_mode, mac_ua, mac_ext)
-                if success:
-                    st.success(f"🎉 تمت عملية الاختراق والتحويل بنجاح! ({count} قناة)")
-                    st.download_button(label="📥 تحميل ملف الـ M3U", data=result, file_name=f"Converted_{mac_address.replace(':', '')}_VIP.m3u", mime="audio/x-mpegurl")
-                else: st.error(result)
+            p_clean = "http://" + m_portal.strip().rstrip('/') if not m_portal.strip().startswith("http") else m_portal.strip().rstrip('/')
+            with st.spinner("🕵️‍♂️ جاري كسر الحماية والتحقق من التواريخ وقنوات السيرفر..."):
+                ok, res_text, count = extract_mac_to_m3u_logic(p_clean, m_addr.strip().upper(), standalone_mode, standalone_ua, standalone_ext)
+                if ok:
+                    st.success(f"🎉 نجح التحويل! تم استخراج {count} قناة بكفاءة تامة.")
+                    st.download_button("📥 تحميل ملف الـ M3U الناتج فوراً", data=res_text, file_name=f"Converted_{m_addr.replace(':','')}.m3u")
+                else: st.error(res_text)
 
 with tab6:
-    st.markdown("### ✨ ساحب القنوات المطور (Extractor)")
+    st.markdown("### ✨ ساحب ومحلل محتويات قوائم التشغيل المباشرة (M3U Extractor)")
     if 'valid_found_tab6' in st.session_state and st.session_state['valid_found_tab6']:
-        if st.button("🔽 طي/إغلاق جميع السيرفرات وتنظيف الذاكرة", key="close_t6"):
+        if st.button("🔽 مسح ذاكرة الكروت المؤقتة للتاب", key="close_t6"):
             st.session_state.reset_exp += 1
             for k in list(st.session_state.keys()):
                 if k.startswith("file_") or k.startswith("ping_res_") or k.startswith("prep_err_") or k.startswith("preview_"): del st.session_state[k]
             st.rerun()
 
-    ex_input = st.text_area("📦 النص المبعثر (للسحب):", height=150)
-    if st.button("⚙️ فحص السيرفرات وتجهيزها", key="tab6_btn"):
-        if not ex_input.strip(): st.warning("⚠️ الرجاء إدخال بيانات السيرفر(ات) أولاً.")
+    ex_input = st.text_area("ضع نصوص قوائم التشغيل أو روابط الـ Workers هنا لفرزها:", height=150)
+    if st.button("⚙️ بدء الفرز والمسح الصاروخي"):
+        if not ex_input.strip(): st.warning("⚠️ يرجى إدخال روابط أولاً للفرز.")
         else:
             accs = extract_all_links_from_text(ex_input)
-            if not accs: st.error("❌ لم يتم العثور على روابط أو سيرفرات صالحة.")
+            if not accs: st.error("❌ لم يتم العثور على أي بيانات روابط تشغيل صالحة بالفحص.")
             else:
-                progress_bar = st.progress(0)
-                status_msg = st.empty()
-                live_placeholder_tab6 = st.empty() 
-                valid_accs = safe_async_run(run_async_scan(accs, progress_bar, status_msg, live_placeholder_tab6, "t6"))
-                status_msg.success(f"🎉 اكتمل الفحص بصاروخ Asyncio! وجدنا {len(valid_accs)} سيرفرات/روابط.")
-                st.session_state['valid_found_tab6'] = valid_accs
-                
-                if valid_accs:
-                    current_db = load_servers()
-                    for v in valid_accs:
-                        if v.get('type') == 'xtream' and not any(s.get('host') == v['host'] and s.get('user') == v['user'] for s in current_db):
-                            current_db.append(v)
-                    save_all_servers_to_db(current_db)
+                p_bar6, s_msg6, l_placeholder6 = st.progress(0), st.empty(), st.empty()
+                v_accs = safe_async_run(run_async_scan(accs, p_bar6, s_msg6, l_placeholder6, "t6"))
+                s_msg6.success(f"🎉 اكتمل المسح بنجاح! تم استخراج {len(v_accs)} كارت تشغيل جاهز.")
+                st.session_state['valid_found_tab6'] = v_accs
 
     if 'valid_found_tab6' in st.session_state and st.session_state['valid_found_tab6']:
         st.markdown("#### ⚙️ الكروت النهائية بعد الفحص والترتيب التلقائي:")
         for i, acc in enumerate(st.session_state['valid_found_tab6']): render_server_card(acc, i, context="t6")
-            
-    st.markdown("---")
-    with st.expander("🔬 فحص رابط قناة مفردة (اختبار الشاشة السوداء)"):
-        single_link = st.text_input("🔗 أدخل رابط القناة (m3u8 أو ts):", placeholder="http://host.com/live/user/pass/123.m3u8")
-        if st.button("⚡ فحص استجابة القناة"):
-            if single_link.strip():
-                with st.spinner("جاري فحص القناة..."):
-                    ping_ok, _, _ = advanced_direct_link_test(single_link.strip())
-                    if ping_ok: st.success("✅ القناة تعمل بكفاءة (تسحب بيانات).")
-                    else: st.error("❌ القناة لا تستجيب (قد تكون شاشة سوداء أو محمية بشدة).")
-            else: st.warning("الرجاء إدخال الرابط أولاً.")