update

app.py

@@ -3,11 +3,13 @@ from bs4 import BeautifulSoup
 import re
 from datetime import datetime, timedelta, timezone
 import time
-from flask import Flask, Response, request
+from flask import Flask, Response, request, redirect
 from threading import Thread
 from collections import deque
 import json
 from queue import Queue
+import os
+import uuid
 
 BASE = "http://159.69.3.189"
 LOGIN_URL = f"{BASE}/login"
@@ -15,20 +17,37 @@ GET_RANGE_URL = f"{BASE}/portal/sms/received/getsms"
 GET_NUMBER_URL = f"{BASE}/portal/sms/received/getsms/number"
 GET_SMS_URL = f"{BASE}/portal/sms/received/getsms/number/sms"
 
-USERNAME = "rezaciledug35@gmail.com"
-PASSWORD = "Ciledug577"
+TELEGRAM_PROXY_URL = "https://danihitambangetjir.termai.cc/api/proxy"
+CUSTOM_DOMAIN = "https://fourstore-tele.hf.space"
+ACCOUNTS_FILE = "accounts.json"
 
-session = httpx.Client(follow_redirects=True, timeout=30.0)
-sent_cache = set()
-csrf_token = None
-LOGIN_SUCCESS = False
+def load_accounts():
+    if os.path.exists(ACCOUNTS_FILE):
+        try:
+            with open(ACCOUNTS_FILE, 'r') as f:
+                return json.load(f)
+        except:
+            return {}
+    return {}
 
-CUSTOM_DOMAIN = "https://fourstore-tele.hf.space"
+def save_accounts(accounts):
+    with open(ACCOUNTS_FILE, 'w') as f:
+        json.dump(accounts, f, indent=2)
 
-sms_cache = {}
-sms_counter = {}
-range_counter = {}
-otp_logs = deque(maxlen=100)
+accounts = load_accounts()
+for acc_id in accounts:
+    accounts[acc_id]["session"] = None
+    accounts[acc_id]["csrf"] = None
+    accounts[acc_id]["status"] = False
+    accounts[acc_id]["otp_logs"] = []
+    accounts[acc_id]["sent_cache"] = []
+    accounts[acc_id]["sms_cache"] = {}
+    accounts[acc_id]["sms_counter"] = {}
+    accounts[acc_id]["range_counter"] = {}
+    accounts[acc_id]["last_cleanup"] = time.time()
+
+app = Flask('')
+app.secret_key = "fourstore-secret-key-123"
 sse_clients = []
 
 def get_wib_time():
@@ -38,153 +57,147 @@ def get_search_date():
     wib = get_wib_time()
     return (wib - timedelta(days=1)).strftime("%Y-%m-%d") if wib.hour < 7 else wib.strftime("%Y-%m-%d")
 
-def login():
-    global csrf_token, LOGIN_SUCCESS
+def login_account(account_id, username, password):
     try:
-        print("\n" + "="*50)
-        print("🔐 PROSES LOGIN DIMULAI")
-        print("="*50)
-        
+        session = httpx.Client(follow_redirects=True, timeout=30.0)
         r = session.get(LOGIN_URL, timeout=30)
-        print(f"📊 Status code: {r.status_code}")
-        
         soup = BeautifulSoup(r.text, "html.parser")
         token = soup.find("input", {"name": "_token"})
-        
         if not token:
-            print("❌ CSRF Token TIDAK DITEMUKAN!")
-            return False
-            
-        csrf_token = token.get("value")
-        print(f"✅ CSRF Token: {csrf_token[:20]}...")
+            return False, "Token tidak ditemukan"
         
+        csrf_token = token.get("value")
         r = session.post(LOGIN_URL, data={
             "_token": csrf_token,
-            "email": USERNAME,
-            "password": PASSWORD
+            "email": username,
+            "password": password
         }, timeout=30)
         
         if "dashboard" in r.text.lower() or "logout" in r.text.lower():
-            LOGIN_SUCCESS = True
-            print("✅✅✅ LOGIN BERHASIL! ✅✅✅")
-            return True
+            accounts[account_id]["session"] = session
+            accounts[account_id]["csrf"] = csrf_token
+            accounts[account_id]["status"] = True
+            accounts[account_id]["last_login"] = time.time()
+            save_accounts(accounts)
+            return True, "Login berhasil"
         else:
-            LOGIN_SUCCESS = False
-            print("❌❌❌ LOGIN GAGAL! ❌❌❌")
-            return False
-            
+            return False, "Login gagal"
     except Exception as e:
-        LOGIN_SUCCESS = False
-        print(f"❌ EXCEPTION: {str(e)}")
+        return False, str(e)
+
+def tg_send(account_id, msg):
+    try:
+        account = accounts.get(account_id)
+        if not account or not account.get("bot_token") or not account.get("chat_id"):
+            return False
+        
+        url = f"{TELEGRAM_PROXY_URL}?url=https://api.telegram.org/bot{account['bot_token']}/sendMessage"
+        payload = {
+            "chat_id": account['chat_id'],
+            "text": msg,
+            "parse_mode": "Markdown"
+        }
+        httpx.post(url, json=payload, timeout=30)
+        return True
+    except:
         return False
 
-def get_ranges_with_count():
+def clean_country(rng):
+    return re.sub(r"\s*\d+$", "", rng).strip() if rng else "UNKNOWN"
+
+def mask_number(number):
+    if not number: return "UNKNOWN"
+    clean = re.sub(r"[^\d+]", "", number)
+    if len(clean) <= 6: return clean
+    return f"{clean[:4]}****{clean[-3:]}"
+
+def map_service(raw):
+    if not raw: return "UNKNOWN"
+    s = raw.lower().strip()
+    if 'whatsapp' in s: return "WHATSAPP"
+    if 'telegram' in s: return "TELEGRAM"
+    if 'google' in s or 'gmail' in s: return "GOOGLE"
+    if 'facebook' in s or 'fb' in s: return "FACEBOOK"
+    if 'instagram' in s or 'ig' in s: return "INSTAGRAM"
+    if 'tiktok' in s: return "TIKTOK"
+    if 'temu' in s: return "TEMU"
+    return raw.upper()
+
+def extract_otp(text):
+    if not text: return None
+    m = re.search(r"\b(\d{3}[- ]?\d{3})\b", text)
+    if m:
+        return m.group(0).replace("-", "").replace(" ", "")
+    m = re.search(r"\b(\d{4,6})\b", text) 
+    if m:
+        return m.group(0)
+    digits = re.findall(r'\d+', text)
+    for d in digits:
+        if 4 <= len(d) <= 6:
+            return d
+    return None
+
+def get_ranges_with_count(account_id):
+    account = accounts.get(account_id)
+    if not account or not account.get("session") or not account.get("csrf"):
+        return []
+    
     try:
-        if not LOGIN_SUCCESS or not csrf_token:
-            return []
-            
         date = get_search_date()
-        print(f"\n🔍 AMBIL RANGE - Tanggal: {date}")
-        
-        r = session.post(GET_RANGE_URL, data={
-            "_token": csrf_token,
+        r = account["session"].post(GET_RANGE_URL, data={
+            "_token": account["csrf"],
             "from": date,
             "to": date
         }, timeout=15)
-        
+
         soup = BeautifulSoup(r.text, "html.parser")
         ranges_data = []
-        
-        items = soup.select(".item")
-        print(f"📦 Total items: {len(items)}")
-        
-        for item in items:
-            try:
-                card = item.select_one(".card[onclick]")
-                if card:
-                    onclick = card.get("onclick", "")
-                    match = re.search(r"getDetials\('(.+?)'\)", onclick)
-                    if match:
-                        rng = match.group(1)
-                    else:
-                        name_div = item.select_one(".col-sm-4")
-                        rng = name_div.get_text(strip=True) if name_div else "UNKNOWN"
-                else:
-                    name_div = item.select_one(".col-sm-4")
-                    rng = name_div.get_text(strip=True) if name_div else "UNKNOWN"
-                
-                count_p = item.select_one(".col-3 .mb-0.pb-0")
-                count = 0
-                if count_p:
-                    try:
-                        count = int(count_p.get_text(strip=True))
-                    except:
-                        count = 0
-                
-                ranges_data.append({
-                    "name": rng,
-                    "count": count
-                })
-                print(f"  ✅ {rng} - {count} SMS")
-                
-            except Exception as e:
-                print(f"  ❌ Error parse: {e}")
-                continue
-        
+
+        for item in soup.select(".item"):
+            name_div = item.select_one(".col-sm-4")
+            if not name_div: continue
+            rng = name_div.get_text(strip=True)
+
+            count_p = item.select_one(".col-3 .mb-0.pb-0")
+            count = int(count_p.get_text(strip=True)) if count_p else 0
+
+            ranges_data.append({
+                "name": rng,
+                "count": count
+            })
+
         return ranges_data
-        
-    except Exception as e:
-        print(f"❌ Error get_ranges: {e}")
+    except:
         return []
 
-def get_numbers_with_count(rng):
+def get_numbers_with_count(account_id, rng):
+    account = accounts.get(account_id)
+    if not account or not account.get("session") or not account.get("csrf"):
+        return []
+    
     try:
-        if not LOGIN_SUCCESS or not csrf_token:
-            return []
-            
         date = get_search_date()
-        print(f"\n    📞 AMBIL NOMOR: {rng}")
-        
-        r = session.post(GET_NUMBER_URL, data={
-            "_token": csrf_token,
+        r = account["session"].post(GET_NUMBER_URL, data={
+            "_token": account["csrf"],
             "start": date,
             "end": date,
             "range": rng
         }, timeout=15)
-        
+
         soup = BeautifulSoup(r.text, "html.parser")
         numbers_data = []
-        
-        # METHOD 1: Extract dari onclick attribute
+
         for div in soup.find_all("div", onclick=True):
             onclick = div.get("onclick", "")
-            match = re.search(r"getDetialsNumber\w+\('(\d+)',\s*'(\d+)'\)", onclick)
+            match = re.search(r"getDetialsNumber\w*\('?(\d+)'?", onclick)
+            if not match:
+                match = re.search(r"open_(\d+)", onclick)
+            if not match:
+                match = re.search(r"'(\d+)'", onclick)
+            
             if match:
                 num = match.group(1)
-                id_number = match.group(2)
-                
-                parent = div.find_parent("div", class_="card")
-                count = 0
-                if parent:
-                    p_tag = parent.find("p", class_="mb-0 pb-0")
-                    if p_tag:
-                        try:
-                            count = int(p_tag.get_text(strip=True))
-                        except:
-                            count = 0
-                
-                numbers_data.append({
-                    "number": num,
-                    "count": count
-                })
-                print(f"        ✅ {mask_number(num)} - {count} SMS")
-        
-        # METHOD 2: Extract dari teks div
-        if len(numbers_data) == 0:
-            for div in soup.find_all("div", class_="col-sm-4"):
-                text = div.get_text(strip=True)
-                if re.match(r'^\d{10,}$', text):
-                    num = text
+                if num and len(num) > 5:
                     parent = div.find_parent("div", class_="card")
                     count = 0
                     if parent:
@@ -194,109 +207,68 @@ def get_numbers_with_count(rng):
                                 count = int(p_tag.get_text(strip=True))
                             except:
                                 count = 0
-                    
+
                     numbers_data.append({
                         "number": num,
                         "count": count
                     })
-                    print(f"        ✅ {mask_number(num)} - {count} SMS")
-        
+
         return numbers_data
-        
-    except Exception as e:
-        print(f"    ❌ Error get_numbers: {e}")
+    except:
         return []
 
-def get_sms_fast(rng, number):
+def get_sms_fast(account_id, rng, number):
+    account = accounts.get(account_id)
+    if not account or not account.get("session") or not account.get("csrf"):
+        return []
+    
     try:
-        if not LOGIN_SUCCESS or not csrf_token:
-            return []
-            
         date = get_search_date()
         cache_key = f"{rng}-{number}"
         
-        if cache_key in sms_cache:
-            timestamp, results = sms_cache[cache_key]
+        if cache_key in account["sms_cache"]:
+            timestamp, results = account["sms_cache"][cache_key]
             if time.time() - timestamp < 5:
                 return results
-        
-        print(f"      📨 AMBIL SMS: {mask_number(number)}")
-        print(f"      📤 Range: '{rng}'")
-        
-        r = session.post(GET_SMS_URL, data={
-            "_token": csrf_token,
+
+        r = account["session"].post(GET_SMS_URL, data={
+            "_token": account["csrf"],
             "start": date,
             "end": date,
             "Number": number,
             "Range": rng
-        }, timeout=30)
-        
+        }, timeout=20)
+
         soup = BeautifulSoup(r.text, "html.parser")
         results = []
-        
-        cards = soup.select("div.card.card-body")
-        
-        for card in cards:
+
+        for card in soup.select("div.card.card-body"):
             try:
                 service = "UNKNOWN"
                 service_div = card.select_one("div.col-sm-4")
                 if service_div:
                     raw = service_div.get_text(strip=True)
                     service = map_service(raw)
-                
+
                 msg_p = card.find("p", class_="mb-0 pb-0")
                 if msg_p:
                     sms = msg_p.get_text(strip=True)
                     otp = extract_otp(sms)
                     if otp:
                         results.append((service, sms, otp))
-                        print(f"        ✅ OTP: {otp} - {service}")
             except:
                 continue
-        
-        sms_cache[cache_key] = (time.time(), results)
+
+        account["sms_cache"][cache_key] = (time.time(), results)
         return results
-        
-    except Exception as e:
-        print(f"      ❌ Error get_sms: {e}")
+    except:
         return []
 
-def extract_otp(text):
-    if not text: return None
-    
-    # Cari pola 3 digit - 3 digit (530-736)
-    m = re.search(r"\b(\d{3}[- ]?\d{3})\b", text)
-    if m:
-        return m.group(0).replace("-", "").replace(" ", "")
+def add_otp_log(account_id, country, number, service, otp, sms):
+    account = accounts.get(account_id)
+    if not account:
+        return
     
-    # Cari pola 4-6 digit biasa
-    m = re.search(r"\b(\d{4,6})\b", text) 
-    if m:
-        return m.group(0)
-    
-    return None
-
-def clean_country(rng):
-    return re.sub(r"\s*\d+$", "", rng).strip() if rng else "UNKNOWN"
-
-def mask_number(number):
-    if not number: return "UNKNOWN"
-    clean = re.sub(r"[^\d+]", "", number)
-    if len(clean) <= 6: return clean
-    return f"{clean[:4]}****{clean[-3:]}"
-
-def map_service(raw):
-    if not raw: return "UNKNOWN"
-    s = raw.lower().strip()
-    if 'whatsapp' in s: return "WHATSAPP"
-    if 'telegram' in s: return "TELEGRAM"
-    if 'google' in s or 'gmail' in s: return "GOOGLE"
-    if 'facebook' in s or 'fb' in s: return "FACEBOOK"
-    if 'instagram' in s or 'ig' in s: return "INSTAGRAM"
-    if 'tiktok' in s: return "TIKTOK"
-    return raw.upper()
-
-def add_otp_log(country, number, service, otp, sms):
     wib = get_wib_time()
     log_entry = {
         "time": wib.strftime("%H:%M:%S"),
@@ -304,10 +276,20 @@ def add_otp_log(country, number, service, otp, sms):
         "number": number,
         "service": service,
         "otp": otp,
-        "sms": sms[:80] + "..." if len(sms) > 80 else sms
+        "sms": sms[:80] + "..." if len(sms) > 80 else sms,
+        "account_id": account_id,
+        "account_username": account.get("username", "Unknown")
     }
-    otp_logs.appendleft(log_entry)
+    
+    if "otp_logs" not in account:
+        account["otp_logs"] = []
+    
+    account["otp_logs"].insert(0, log_entry)
+    if len(account["otp_logs"]) > 100:
+        account["otp_logs"] = account["otp_logs"][:100]
+    
     broadcast_sse(log_entry)
+    save_accounts(accounts)
     return log_entry
 
 def broadcast_sse(data):
@@ -321,27 +303,46 @@ def broadcast_sse(data):
     for q in dead:
         sse_clients.remove(q)
 
-app = Flask('')
-
 @app.route('/')
 def home():
-    wib = get_wib_time()
-    search_date = get_search_date()
+    all_logs = []
+    for acc_id, acc in accounts.items():
+        if acc.get("otp_logs"):
+            for log in acc["otp_logs"]:
+                log_copy = log.copy()
+                log_copy["account_username"] = acc.get("username", "Unknown")
+                all_logs.append(log_copy)
+    
+    all_logs = sorted(all_logs, key=lambda x: x.get("time", ""), reverse=True)
+    
     search_query = request.args.get('q', '').lower()
     filter_service = request.args.get('service', '')
+    filter_account = request.args.get('account', '')
     
-    filtered_logs = list(otp_logs)
     if search_query:
-        filtered_logs = [log for log in filtered_logs if 
-                        search_query in log['country'].lower() or 
-                        search_query in log['number'].lower() or 
-                        search_query in log['otp'].lower() or 
-                        search_query in log['sms'].lower()]
-    
+        all_logs = [log for log in all_logs if 
+                    search_query in log.get('country', '').lower() or 
+                    search_query in log.get('number', '').lower() or 
+                    search_query in log.get('otp', '').lower() or 
+                    search_query in log.get('sms', '').lower()]
+
     if filter_service:
-        filtered_logs = [log for log in filtered_logs if log['service'] == filter_service]
+        all_logs = [log for log in all_logs if log.get('service') == filter_service]
+    
+    if filter_account:
+        all_logs = [log for log in all_logs if log.get('account_id') == filter_account]
+    
+    all_services = list(set([log.get('service') for log in all_logs if log.get('service')]))
     
-    all_services = list(set([log['service'] for log in otp_logs]))
+    accounts_list = []
+    for acc_id, acc in accounts.items():
+        accounts_list.append({
+            "id": acc_id,
+            "username": acc.get("username", "Unknown"),
+            "status": acc.get("status", False),
+            "bot": "✅" if acc.get("bot_token") else "❌",
+            "chat": acc.get("chat_id", "-")[:5] + "..." if acc.get("chat_id") and len(acc.get("chat_id")) > 5 else acc.get("chat_id", "-")
+        })
     
     html = f"""
     <!DOCTYPE html>
@@ -349,56 +350,60 @@ def home():
     <head>
         <meta charset="UTF-8">
         <meta name="viewport" content="width=device-width, initial-scale=1.0">
-        <title>OTP DASHBOARD · FOURSTORE</title>
+        <title>OTP MULTI ACCOUNT · FOURSTORE</title>
         <link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap" rel="stylesheet">
         <style>
             * {{ margin: 0; padding: 0; box-sizing: border-box; }}
             body {{ font-family: 'Inter', sans-serif; background: #0a0c10; color: #e4e6eb; padding: 24px; }}
-            .container {{ max-width: 1400px; margin: 0 auto; }}
+            .container {{ max-width: 1600px; margin: 0 auto; }}
             .header {{ background: linear-gradient(145deg, #1a1f2c, #0f131c); border-radius: 24px; padding: 28px; margin-bottom: 28px; border: 1px solid #2d3540; }}
-            .header-top {{ display: flex; justify-content: space-between; align-items: center; margin-bottom: 24px; }}
+            .header-top {{ display: flex; justify-content: space-between; align-items: center; margin-bottom: 24px; flex-wrap: wrap; gap: 15px; }}
             .title h1 {{ font-size: 28px; font-weight: 700; background: linear-gradient(135deg, #00f2fe, #4facfe); -webkit-background-clip: text; -webkit-text-fill-color: transparent; }}
             .title p {{ color: #8b949e; font-size: 14px; }}
-            .status-badge {{ padding: 10px 24px; border-radius: 100px; font-weight: 600; font-size: 14px; 
-                          background: {'#0a4d3c' if LOGIN_SUCCESS else '#4a2c2c'}; 
-                          color: {'#a0f0d0' if LOGIN_SUCCESS else '#ffb3b3'}; 
-                          border: 1px solid {'#1a6e5a' if LOGIN_SUCCESS else '#6e3a3a'}; }}
             .stats-grid {{ display: grid; grid-template-columns: repeat(4, 1fr); gap: 20px; margin-top: 20px; }}
             .stat-card {{ background: #1a1f2c; padding: 20px; border-radius: 20px; border: 1px solid #2d3540; }}
             .stat-label {{ color: #8b949e; font-size: 13px; text-transform: uppercase; letter-spacing: 0.5px; margin-bottom: 8px; }}
             .stat-value {{ font-size: 32px; font-weight: 700; color: #00f2fe; }}
+            
+            .add-account-form {{ background: #1a1f2c; padding: 20px; border-radius: 16px; margin-bottom: 30px; border: 1px solid #2d3540; }}
+            .form-grid {{ display: grid; grid-template-columns: repeat(auto-fit, minmax(200px, 1fr)); gap: 15px; }}
+            .form-input {{ background: #0a0c10; border: 1px solid #2d3540; padding: 12px 16px; border-radius: 12px; color: #e4e6eb; width: 100%; }}
+            .form-input:focus {{ outline: none; border-color: #00f2fe; }}
+            .btn {{ background: #00f2fe; color: #0a0c10; border: none; padding: 12px 24px; border-radius: 12px; font-weight: 600; cursor: pointer; transition: all 0.2s; }}
+            .btn:hover {{ background: #00d8e4; transform: translateY(-2px); }}
+            .btn-danger {{ background: #ff4d4d; color: white; }}
+            .btn-small {{ padding: 6px 12px; font-size: 12px; }}
+            
+            .account-grid {{ display: grid; grid-template-columns: repeat(auto-fit, minmax(280px, 1fr)); gap: 20px; margin-bottom: 30px; }}
+            .account-card {{ background: #1a1f2c; border-radius: 16px; padding: 20px; border: 1px solid #2d3540; position: relative; }}
+            .account-card.online {{ border-color: #00f2fe; box-shadow: 0 0 15px #00f2fe20; }}
+            .account-status {{ position: absolute; top: 20px; right: 20px; width: 12px; height: 12px; border-radius: 50%; }}
+            .status-online {{ background: #00f2fe; box-shadow: 0 0 10px #00f2fe; }}
+            .status-offline {{ background: #ff4d4d; }}
+            .account-actions {{ display: flex; gap: 8px; margin-top: 15px; flex-wrap: wrap; }}
+            
             .search-section {{ background: #0f131c; border-radius: 20px; padding: 20px; margin-bottom: 24px; border: 1px solid #2d3540; display: flex; gap: 16px; align-items: center; flex-wrap: wrap; }}
             .search-box {{ flex: 2; min-width: 280px; position: relative; }}
             .search-icon {{ position: absolute; left: 16px; top: 14px; color: #8b949e; }}
             .search-input {{ width: 100%; padding: 14px 20px 14px 48px; background: #1a1f2c; border: 1px solid #2d3540; border-radius: 100px; color: #e4e6eb; font-size: 15px; }}
-            .search-input:focus {{ outline: none; border-color: #00f2fe; background: #1e2433; box-shadow: 0 0 0 3px #00f2fe20; }}
-            .filter-box {{ flex: 1; min-width: 180px; }}
+            .filter-box {{ flex: 1; min-width: 150px; }}
             .filter-select {{ width: 100%; padding: 14px 20px; background: #1a1f2c; border: 1px solid #2d3540; border-radius: 100px; color: #e4e6eb; font-size: 15px; cursor: pointer; }}
-            .clear-btn {{ padding: 14px 28px; background: #2d3a4a; border: none; border-radius: 100px; color: white; font-size: 14px; font-weight: 600; cursor: pointer; text-decoration: none; display: inline-block; }}
-            .clear-btn:hover {{ background: #3d4a5a; }}
-            .result-count {{ color: #8b949e; font-size: 13px; margin-left: 8px; }}
-            .otp-section {{ background: #0f131c; border-radius: 24px; padding: 28px; border: 1px solid #2d3540; }}
-            .section-title {{ font-size: 18px; font-weight: 600; color: #e4e6eb; margin-bottom: 20px; display: flex; align-items: center; gap: 10px; }}
-            .section-title span {{ background: #00f2fe20; padding: 6px 12px; border-radius: 100px; font-size: 12px; color: #00f2fe; }}
-            table {{ width: 100%; border-collapse: collapse; }}
+            
+            .otp-section {{ background: #0f131c; border-radius: 24px; padding: 28px; border: 1px solid #2d3540; overflow-x: auto; }}
+            table {{ width: 100%; border-collapse: collapse; min-width: 1000px; }}
             th {{ text-align: left; padding: 16px 12px; background: #1a1f2c; color: #00f2fe; font-weight: 600; font-size: 13px; text-transform: uppercase; border-bottom: 2px solid #2d3540; }}
             td {{ padding: 16px 12px; border-bottom: 1px solid #262c38; font-size: 14px; }}
-            .otp-badge {{ background: #002b36; color: #00f2fe; font-family: monospace; font-size: 16px; font-weight: 700; padding: 6px 14px; border-radius: 100px; border: 1px solid #00f2fe40; display: inline-block; user-select: all; cursor: pointer; }}
-            .otp-badge:hover {{ background: #003d4a; border-color: #00f2fe; transform: scale(1.05); }}
+            .otp-badge {{ background: #002b36; color: #00f2fe; font-family: monospace; font-size: 16px; font-weight: 700; padding: 6px 14px; border-radius: 100px; border: 1px solid #00f2fe40; cursor: pointer; user-select: all; }}
             .service-badge {{ background: #2d3a4a; padding: 6px 14px; border-radius: 100px; font-size: 12px; font-weight: 600; display: inline-block; }}
-            .service-badge.whatsapp {{ background: #25D36620; color: #25D366; border: 1px solid #25D36640; }}
-            .service-badge.telegram {{ background: #26A5E420; color: #26A5E4; border: 1px solid #26A5E440; }}
-            .service-badge.google {{ background: #EA433520; color: #EA4335; border: 1px solid #EA433540; }}
-            .service-badge.facebook {{ background: #4267B220; color: #4267B2; border: 1px solid #4267B240; }}
-            .service-badge.instagram {{ background: #E4405F20; color: #E4405F; border: 1px solid #E4405F40; }}
-            .service-badge.tiktok {{ background: #00000020; color: #ffffff; border: 1px solid #ffffff40; }}
-            .number {{ font-family: monospace; color: #e4e6eb; }}
-            .empty-state {{ text-align: center; padding: 60px; color: #8b949e; }}
-            .highlight {{ background: #00f2fe30; border-radius: 4px; padding: 0 2px; }}
+            .account-badge {{ background: #4a3a2d; padding: 4px 10px; border-radius: 20px; font-size: 11px; display: inline-block; }}
+            .whatsapp {{ background: #25D36620; color: #25D366; border: 1px solid #25D36640; }}
+            .telegram {{ background: #26A5E420; color: #26A5E4; border: 1px solid #26A5E440; }}
+            .google {{ background: #EA433520; color: #EA4335; border: 1px solid #EA433540; }}
+            .facebook {{ background: #4267B220; color: #4267B2; border: 1px solid #4267B240; }}
+            .temu {{ background: #FF6B6B20; color: #FF6B6B; border: 1px solid #FF6B6B40; }}
             .new-row {{ animation: fadeIn 0.3s ease; background: linear-gradient(90deg, #00f2fe10, transparent); }}
-            .toast {{ position: fixed; bottom: 24px; right: 24px; background: #00f2fe; color: #000; padding: 14px 28px; border-radius: 100px; font-weight: 600; animation: slideIn 0.3s ease; z-index: 9999; box-shadow: 0 8px 20px rgba(0,242,254,0.3); }}
             @keyframes fadeIn {{ from {{ opacity: 0; transform: translateY(-10px); }} to {{ opacity: 1; transform: translateY(0); }} }}
-            @keyframes slideIn {{ from {{ opacity: 0; transform: translateX(30px); }} to {{ opacity: 1; transform: translateX(0); }} }}
+            .toast {{ position: fixed; bottom: 24px; right: 24px; background: #00f2fe; color: #000; padding: 14px 28px; border-radius: 100px; font-weight: 600; z-index: 9999; }}
         </style>
     </head>
     <body>
@@ -406,46 +411,64 @@ def home():
             <div class="header">
                 <div class="header-top">
                     <div class="title">
-                        <h1>OTP MONITOR · FOURSTORE</h1>
+                        <h1>OTP MULTI ACCOUNT · FOURSTORE</h1>
                         <p>{CUSTOM_DOMAIN}</p>
                     </div>
-                    <div class="status-badge">
-                        {'● ONLINE' if LOGIN_SUCCESS else '○ OFFLINE'}
+                    <div class="stats-grid">
+                        <div class="stat-card"><div class="stat-label">Total Akun</div><div class="stat-value">{len(accounts)}</div></div>
+                        <div class="stat-card"><div class="stat-label">Akun Online</div><div class="stat-value">{sum(1 for a in accounts.values() if a.get('status'))}</div></div>
+                        <div class="stat-card"><div class="stat-label">Total OTP</div><div class="stat-value">{sum(len(a.get('sent_cache', [])) for a in accounts.values())}</div></div>
+                        <div class="stat-card"><div class="stat-label">WIB</div><div class="stat-value" id="wib-time">{get_wib_time().strftime('%H:%M:%S')}</div></div>
                     </div>
                 </div>
-                <div class="stats-grid">
-                    <div class="stat-card"><div class="stat-label">Total OTP</div><div class="stat-value" id="total-otp">{len(sent_cache)}</div></div>
-                    <div class="stat-card"><div class="stat-label">Today</div><div class="stat-value" id="today-otp">{len(otp_logs)}</div></div>
-                    <div class="stat-card"><div class="stat-label">WIB</div><div class="stat-value" id="wib-time">{wib.strftime('%H:%M:%S')}</div></div>
-                    <div class="stat-card"><div class="stat-label">Date</div><div class="stat-value">{search_date}</div></div>
-                </div>
+            </div>
+            
+            <div class="add-account-form">
+                <h3 style="margin-bottom: 15px;">➕ Tambah Akun Baru</h3>
+                <form action="/add_account" method="POST" class="form-grid">
+                    <input type="text" name="username" placeholder="Username/Email" class="form-input" required>
+                    <input type="password" name="password" placeholder="Password" class="form-input" required>
+                    <input type="text" name="bot_token" placeholder="Bot Token (opsional)" class="form-input">
+                    <input type="text" name="chat_id" placeholder="Chat ID (opsional)" class="form-input">
+                    <button type="submit" class="btn">Tambah Akun</button>
+                </form>
+            </div>
+            
+            <div class="account-grid">
+                {generate_account_cards(accounts_list)}
             </div>
             
             <div class="search-section">
                 <div class="search-box">
                     <span class="search-icon">🔍</span>
-                    <form action="/" method="get" style="margin: 0;" id="searchForm">
-                        <input type="text" class="search-input" name="q" placeholder="Cari negara, nomor, OTP, atau SMS..." value="{request.args.get('q', '')}" autocomplete="off">
+                    <form action="/" method="get" id="searchForm">
+                        <input type="text" class="search-input" name="q" placeholder="Cari OTP..." value="{request.args.get('q', '')}">
                     </form>
                 </div>
                 <div class="filter-box">
-                    <select class="filter-select" name="service" onchange="window.location.href='/?' + (document.getElementById('searchForm').q.value ? 'q=' + document.getElementById('searchForm').q.value + '&' : '') + 'service=' + this.value">
+                    <select class="filter-select" name="service" onchange="window.location.href=updateQuery('service', this.value)">
                         <option value="">📋 Semua Service</option>
                         {''.join([f'<option value="{s}" {"selected" if filter_service == s else ""}>📱 {s}</option>' for s in sorted(all_services)])}
                     </select>
                 </div>
-                <a href="/" class="clear-btn">✕ Clear</a>
-                <span class="result-count">📊 {len(filtered_logs)} results</span>
+                <div class="filter-box">
+                    <select class="filter-select" name="account" onchange="window.location.href=updateQuery('account', this.value)">
+                        <option value="">👤 Semua Akun</option>
+                        {''.join([f'<option value="{a["id"]}" {"selected" if filter_account == a["id"] else ""}>👤 {a["username"][:15]}</option>' for a in accounts_list])}
+                    </select>
+                </div>
+                <a href="/" class="btn btn-small">Reset</a>
+                <span class="result-count">📊 {len(all_logs)} hasil</span>
             </div>
             
             <div class="otp-section">
-                <div class="section-title">📨 OTP TERBARU <span>LIVE</span></div>
-                <div style="overflow-x: auto;">
-                    <table>
-                        <thead><tr><th>WIB</th><th>Country</th><th>Number</th><th>Service</th><th>OTP</th><th>Message</th></tr></thead>
-                        <tbody id="otp-table-body">{generate_filtered_rows(filtered_logs, search_query)}</tbody>
-                    </table>
-                </div>
+                <h3 style="margin-bottom: 20px;">📨 OTP TERBARU <span style="background:#00f2fe20; padding:4px 12px; border-radius:100px; font-size:12px;">LIVE</span></h3>
+                <table>
+                    <thead><tr><th>WIB</th><th>Akun</th><th>Country</th><th>Number</th><th>Service</th><th>OTP</th><th>Message</th></tr></thead>
+                    <tbody id="otp-table-body">
+                        {generate_otp_rows(all_logs, search_query)}
+                    </tbody>
+                </table>
             </div>
         </div>
         
@@ -456,49 +479,46 @@ def home():
                 eventSource.onmessage = function(e) {{
                     try {{
                         const data = JSON.parse(e.data);
-                        if (data.otp) {{
-                            addRow(data);
-                            updateStats();
-                        }}
-                    }} catch (err) {{}}
+                        if (data.otp) location.reload();
+                    }} catch(err) {{}}
                 }};
                 eventSource.onerror = function() {{ setTimeout(connectSSE, 3000); }};
             }}
             
-            function addRow(data) {{
-                const tbody = document.getElementById('otp-table-body');
-                if (tbody.children.length === 1 && tbody.children[0].innerHTML.includes('Tidak ada hasil')) tbody.innerHTML = '';
-                const row = tbody.insertRow(0);
-                row.className = 'new-row';
-                const serviceClass = data.service.toLowerCase().replace(' ', '');
-                row.innerHTML = `<td style="color: #00f2fe;">${{data.time}}</td><td>${{data.country}}</td><td><span class="number">${{data.number}}</span></td><td><span class="service-badge ${{serviceClass}}">${{data.service}}</span></td><td><span class="otp-badge" onclick="copyOTP('${{data.otp}}')">${{data.otp}}</span></td><td><div style="max-width: 350px; overflow: hidden; text-overflow: ellipsis;" title="${{data.sms}}">${{data.sms}}</div></td>`;
-                while (tbody.children.length > 50) tbody.removeChild(tbody.lastChild);
+            function updateQuery(key, value) {{
+                const url = new URL(window.location.href);
+                if (value) url.searchParams.set(key, value);
+                else url.searchParams.delete(key);
+                return url.toString();
+            }}
+            
+            function loginAccount(accountId) {{
+                fetch('/login_account/' + accountId, {{method: 'POST'}})
+                    .then(() => location.reload());
+            }}
+            
+            function logoutAccount(accountId) {{
+                fetch('/logout_account/' + accountId, {{method: 'POST'}})
+                    .then(() => location.reload());
             }}
             
             function copyOTP(otp) {{
                 navigator.clipboard.writeText(otp).then(() => {{
-                    const toast = document.createElement('div'); toast.className = 'toast'; toast.textContent = '✅ OTP copied!';
-                    document.body.appendChild(toast); setTimeout(() => toast.remove(), 2000);
+                    const toast = document.createElement('div');
+                    toast.className = 'toast';
+                    toast.textContent = '✅ OTP copied!';
+                    document.body.appendChild(toast);
+                    setTimeout(() => toast.remove(), 2000);
                 }});
             }}
             
-            function updateStats() {{
-                const totalEl = document.getElementById('total-otp');
-                const todayEl = document.getElementById('today-otp');
-                if (totalEl) totalEl.textContent = parseInt(totalEl.textContent || 0) + 1;
-                if (todayEl) todayEl.textContent = parseInt(todayEl.textContent || 0) + 1;
-            }}
-            
             function updateTime() {{
-                const now = new Date(); now.setHours(now.getHours() + 7);
+                const now = new Date();
+                now.setHours(now.getHours() + 7);
                 const wibEl = document.getElementById('wib-time');
                 if (wibEl) wibEl.textContent = now.toISOString().substr(11, 8);
             }}
             
-            document.querySelector('.search-input')?.addEventListener('keypress', function(e) {{
-                if (e.key === 'Enter') document.getElementById('searchForm').submit();
-            }});
-            
             connectSSE();
             setInterval(updateTime, 1000);
         </script>
@@ -507,36 +527,108 @@ def home():
     """
     return html
 
-def generate_filtered_rows(filtered_logs, search_query=""):
-    if not filtered_logs:
-        return '<tr><td colspan="6" class="empty-state"><h3>🔍 Tidak ada hasil</h3><p>Coba kata kunci lain atau reset filter</p></td></tr>'
+def generate_account_cards(accounts_list):
+    html = ""
+    for acc in accounts_list:
+        status_class = "online" if acc["status"] else "offline"
+        html += f"""
+        <div class="account-card {status_class}">
+            <div class="account-status status-{status_class}"></div>
+            <h4>{acc['username'][:20]}{'...' if len(acc['username']) > 20 else ''}</h4>
+            <p style="margin-top:8px; color:#8b949e;">Bot: {acc['bot']} | Chat: {acc['chat']}</p>
+            <div class="account-actions">
+                <button onclick="loginAccount('{acc['id']}')" class="btn btn-small">Login</button>
+                <button onclick="logoutAccount('{acc['id']}')" class="btn btn-small btn-danger">Logout</button>
+                <a href="/delete_account/{acc['id']}" class="btn btn-small btn-danger" onclick="return confirm('Hapus akun?')">Hapus</a>
+            </div>
+        </div>
+        """
+    if not accounts_list:
+        html = "<div style='grid-column:1/-1; text-align:center; padding:40px; color:#8b949e;'>Belum ada akun. Tambah akun di atas!</div>"
+    return html
+
+def generate_otp_rows(logs, search_query):
+    if not logs:
+        return '<tr><td colspan="7" style="text-align:center; padding:60px; color:#8b949e;">🔍 Belum ada OTP</td></tr>'
     
     rows = ""
-    for entry in filtered_logs[:50]:
-        country = entry["country"]
-        number = entry["number"]
-        otp = entry["otp"]
-        sms = entry["sms"]
+    for log in logs[:100]:
+        country = log.get('country', '')
+        number = log.get('number', '')
+        otp = log.get('otp', '')
+        sms = log.get('sms', '')
+        service = log.get('service', 'UNKNOWN')
+        account = log.get('account_username', 'Unknown')[:15]
         
         if search_query:
-            country = re.sub(f'({re.escape(search_query)})', r'<span class="highlight">\1</span>', country, flags=re.I)
+            country = re.sub(f'({re.escape(search_query)})', r'<span class="highlight" style="background:#00f2fe30; border-radius:4px;">\1</span>', country, flags=re.I)
             number = re.sub(f'({re.escape(search_query)})', r'<span class="highlight">\1</span>', number, flags=re.I)
             otp = re.sub(f'({re.escape(search_query)})', r'<span class="highlight">\1</span>', otp, flags=re.I)
-            sms = re.sub(f'({re.escape(search_query)})', r'<span class="highlight">\1</span>', sms, flags=re.I)
         
-        service_class = entry["service"].lower().replace(' ', '')
+        service_class = service.lower().replace(' ', '')
         rows += f'''
-        <tr>
-            <td style="color: #00f2fe;">{entry["time"]}</td>
+        <tr class="new-row">
+            <td style="color:#00f2fe;">{log.get('time', '')}</td>
+            <td><span class="account-badge">{account}</span></td>
             <td>{country}</td>
             <td><span class="number">{number}</span></td>
-            <td><span class="service-badge {service_class}">{entry["service"]}</span></td>
-            <td><span class="otp-badge" onclick="copyOTP('{entry["otp"]}')">{otp}</span></td>
-            <td><div style="max-width: 350px; overflow: hidden; text-overflow: ellipsis;" title="{entry["sms"]}">{sms}</div></td>
+            <td><span class="service-badge {service_class}">{service}</span></td>
+            <td><span class="otp-badge" onclick="copyOTP('{otp}')">{otp}</span></td>
+            <td><div style="max-width:300px; overflow:hidden; text-overflow:ellipsis;" title="{log.get('sms', '')}">{log.get('sms', '')}</div></td>
         </tr>
         '''
     return rows
 
+@app.route('/add_account', methods=['POST'])
+def add_account_route():
+    account_id = str(uuid.uuid4())[:8]
+    accounts[account_id] = {
+        "id": account_id,
+        "username": request.form['username'],
+        "password": request.form['password'],
+        "bot_token": request.form.get('bot_token', ''),
+        "chat_id": request.form.get('chat_id', ''),
+        "session": None,
+        "csrf": None,
+        "status": False,
+        "otp_logs": [],
+        "sent_cache": [],
+        "sms_cache": {},
+        "sms_counter": {},
+        "range_counter": {},
+        "last_cleanup": time.time(),
+        "created_at": time.time()
+    }
+    save_accounts(accounts)
+    return redirect('/')
+
+@app.route('/delete_account/<account_id>')
+def delete_account_route(account_id):
+    if account_id in accounts:
+        del accounts[account_id]
+        save_accounts(accounts)
+    return redirect('/')
+
+@app.route('/login_account/<account_id>', methods=['POST'])
+def login_account_route(account_id):
+    if account_id in accounts:
+        acc = accounts[account_id]
+        success, msg = login_account(account_id, acc['username'], acc['password'])
+        if success:
+            # Start thread untuk akun ini
+            thread = Thread(target=run_account_scraper, args=(account_id,), daemon=True)
+            thread.start()
+    return redirect('/')
+
+@app.route('/logout_account/<account_id>', methods=['POST'])
+def logout_account_route(account_id):
+    if account_id in accounts:
+        accounts[account_id]["status"] = False
+        accounts[account_id]["session"] = None
+        accounts[account_id]["csrf"] = None
+        save_accounts(accounts)
+    return redirect('/')
+
 @app.route('/stream')
 def stream():
     def generate():
@@ -550,105 +642,108 @@ def stream():
                 sse_clients.remove(q)
     return Response(generate(), mimetype="text/event-stream")
 
-def run_server():
-    app.run(host='0.0.0.0', port=7860, debug=False, threaded=True)
-
-Thread(target=run_server, daemon=True).start()
-
-def main():
-    print("\n" + "="*60)
-    print("  🔥 OTP BOT - FOURSTORE HUGGING FACE")
-    print("  ⚡ PORT: 7860")
-    print(f"  🌐 DOMAIN: {CUSTOM_DOMAIN}")
-    print("  📋 TANPA INTEGRASI TELEGRAM")
-    print("="*60 + "\n")
-    
-    login_attempts = 0
-    while login_attempts < 5:
-        if login():
-            break
-        login_attempts += 1
-        print(f"⏳ Login gagal, percobaan ke-{login_attempts}/5...")
-        time.sleep(3)
+def run_account_scraper(account_id):
+    account = accounts.get(account_id)
+    if not account:
+        return
     
-    last_cleanup = time.time()
-    loop_count = 0
+    print(f"🚀 Starting scraper for {account['username']}")
     
-    while True:
+    while account.get("status"):
         try:
-            loop_count += 1
-            print(f"\n{'='*50}")
-            print(f"🔄 LOOP KE-{loop_count}")
-            print(f"{'='*50}")
-            
-            if not LOGIN_SUCCESS or not csrf_token:
-                print("⚠️ Session expired, login ulang...")
-                login()
-                time.sleep(2)
-                continue
+            if time.time() - account.get("last_cleanup", 0) > 300:
+                account["sms_cache"] = {}
+                account["sms_counter"] = {}
+                account["range_counter"] = {}
+                account["last_cleanup"] = time.time()
+                print(f"🧹 Cache cleared for {account['username']}")
             
-            if time.time() - last_cleanup > 300:
-                sms_cache.clear()
-                sms_counter.clear()
-                range_counter.clear()
-                print("🧹 Cache cleared (5 menit)")
-                last_cleanup = time.time()
-            
-            ranges_data = get_ranges_with_count()
-            
-            if not ranges_data:
-                print("⚠️ TIDAK ADA DATA RANGE!")
-                time.sleep(5)
-                continue
+            ranges_data = get_ranges_with_count(account_id)
             
             for range_item in ranges_data:
+                if not account.get("status"):
+                    break
+                    
                 rng = range_item["name"]
                 current_count = range_item["count"]
-                prev_count = range_counter.get(rng, 0)
+                prev_count = account["range_counter"].get(rng, 0)
                 
                 if current_count > prev_count:
                     country = clean_country(rng)
-                    print(f"\n🔥 RANGE BERUBAH: {country}")
-                    print(f"   📊 {prev_count} → {current_count} SMS (baru: {current_count - prev_count})")
-                    range_counter[rng] = current_count
+                    account["range_counter"][rng] = current_count
                     
-                    numbers_data = get_numbers_with_count(rng)
+                    numbers_data = get_numbers_with_count(account_id, rng)
                     
                     for number_item in numbers_data:
+                        if not account.get("status"):
+                            break
+                            
                         num = number_item["number"]
                         num_count = number_item["count"]
                         key = f"{rng}-{num}"
-                        prev_num_count = sms_counter.get(key, 0)
+                        prev_num_count = account["sms_counter"].get(key, 0)
                         
                         if num_count > prev_num_count:
-                            print(f"   📱 Nomor: {mask_number(num)}")
-                            print(f"      📨 {prev_num_count} → {num_count} SMS (baru: {num_count - prev_num_count})")
-                            sms_counter[key] = num_count
+                            account["sms_counter"][key] = num_count
                             
-                            all_sms = get_sms_fast(rng, num)
+                            all_sms = get_sms_fast(account_id, rng, num)
                             new_sms = all_sms[prev_num_count:]
                             
                             for service, sms, otp in new_sms:
                                 if otp:
                                     sms_id = f"{rng}-{num}-{otp}"
-                                    if sms_id not in sent_cache:
+                                    if sms_id not in account["sent_cache"]:
                                         masked = mask_number(num)
-                                        sent_cache.add(sms_id)
-                                        add_otp_log(country, masked, service, otp, sms)
-                                        print(f"      ✅ OTP: {otp} - {service}")
+                                        msg = f"🔔 *NEW OTP*\n🌍 {country}\n📞 `{masked}`\n💬 {service}\n🔐 `{otp}`\n\n{sms[:300]}"
+                                        if tg_send(account_id, msg):
+                                            if "sent_cache" not in account:
+                                                account["sent_cache"] = []
+                                            account["sent_cache"].append(sms_id)
+                                            if len(account["sent_cache"]) > 1000:
+                                                account["sent_cache"] = account["sent_cache"][-1000:]
+                                            add_otp_log(account_id, country, masked, service, otp, sms)
                     
-                    print(f"   ✅ Selesai proses {country}")
                     time.sleep(0.5)
             
-            print("\n⏳ Tidur 2 detik...")
             time.sleep(2)
             
         except Exception as e:
-            print(f"❌ Error: {e}")
-            time.sleep(3)
+            print(f"❌ Error in scraper for {account['username']}: {e}")
+            time.sleep(5)
+
+def run_server():
+    app.run(host='0.0.0.0', port=7860, debug=False, threaded=True)
+
+# Start server thread
+Thread(target=run_server, daemon=True).start()
+
+# Start scraper untuk semua akun yang sudah login
+def main():
+    print("\n" + "="*60)
+    print("  🔥 OTP MULTI ACCOUNT - FOURSTORE")
+    print("  ⚡ PORT: 7860")
+    print(f"  🌐 DOMAIN: {CUSTOM_DOMAIN}")
+    print("  📁 Data tersimpan di accounts.json")
+    print("="*60 + "\n")
+    
+    # Login semua akun yang punya status True
+    for acc_id, acc in accounts.items():
+        if acc.get("status"):
+            success, msg = login_account(acc_id, acc['username'], acc['password'])
+            if success:
+                thread = Thread(target=run_account_scraper, args=(acc_id,), daemon=True)
+                thread.start()
+                print(f"✅ {acc['username']} online")
+            else:
+                print(f"❌ {acc['username']} offline: {msg}")
+    
+    # Keep main thread alive
+    while True:
+        time.sleep(60)
 
 if __name__ == "__main__":
     try:
         main()
     except KeyboardInterrupt:
-        print("\n🛑 BOT STOPPED")
+        print("\n🛑 BOT STOPPED")
+        save_accounts(accounts)