update

app.py

@@ -3,12 +3,33 @@ 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, session as flask_session
 from threading import Thread
 from collections import deque
 import json
 from queue import Queue
 import os
+import uuid
+import sys
+from pymongo import MongoClient
+from pymongo.errors import ConnectionFailure
+from functools import wraps
+
+MONGO_URI = os.environ.get("MONGGODB_URI")
+DB_NAME = "otp_bot"
+COLLECTION_NAME = "accounts"
+
+try:
+    mongo_client = MongoClient(MONGO_URI)
+    db = mongo_client[DB_NAME]
+    accounts_collection = db[COLLECTION_NAME]
+    mongo_client.admin.command('ping')
+    print("✅ MongoDB Connected!")
+except ConnectionFailure as e:
+    print(f"❌ MongoDB Connection Failed: {e}")
+    mongo_client = None
+
+print = lambda *args, **kwargs: __builtins__.print(*args, **kwargs, flush=True)
 
 BASE = "http://159.69.3.189"
 LOGIN_URL = f"{BASE}/login"
@@ -16,25 +37,81 @@ 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 = os.environ.get("USERNAME")
-PASSWORD = os.environ.get("PASSWORD")
-BOT_TOKEN = os.environ.get("BOT_TOKEN")
-CHAT_ID = os.environ.get("CHAT_ID")
-
 TELEGRAM_PROXY_URL = "https://danihitambangetjir.termai.cc/api/proxy"
 CUSTOM_DOMAIN = "https://fourstore-otp.hf.space"
 
-session = httpx.Client(follow_redirects=True, timeout=30.0)
-sent_cache = set()
-csrf_token = None
-LOGIN_SUCCESS = False
+def mask_email(email):
+    if not email or '@' not in email:
+        return email
+    parts = email.split('@')
+    username = parts[0]
+    domain = parts[1]
+    if len(username) <= 3:
+        masked_username = username[0] + '*' * (len(username) - 1)
+    else:
+        masked_username = username[:2] + '*' * (len(username) - 3) + username[-1]
+    return f"{masked_username}@{domain}"
+
+def load_accounts_from_mongodb():
+    accounts_dict = {}
+    try:
+        if mongo_client:
+            cursor = accounts_collection.find({})
+            for doc in cursor:
+                acc_id = doc.pop("_id")
+                doc["session"] = None
+                doc["csrf"] = None
+                doc["status"] = False
+                doc["otp_logs"] = []
+                doc["sent_cache"] = []
+                doc["sms_cache"] = {}
+                doc["sms_counter"] = {}
+                doc["range_counter"] = {}
+                doc["last_cleanup"] = time.time()
+                accounts_dict[acc_id] = doc
+            print(f"📊 Loaded {len(accounts_dict)} accounts from MongoDB")
+    except Exception as e:
+        print(f"❌ Error load from MongoDB: {e}")
+    return accounts_dict
+
+def save_accounts_to_mongodb(accounts_dict):
+    try:
+        if mongo_client:
+            for acc_id, acc in accounts_dict.items():
+                acc_copy = acc.copy()
+                acc_copy.pop("session", None)
+                acc_copy.pop("csrf", None)
+                acc_copy.pop("otp_logs", None)
+                acc_copy.pop("sent_cache", None)
+                acc_copy.pop("sms_cache", None)
+                acc_copy.pop("sms_counter", None)
+                acc_copy.pop("range_counter", None)
+                acc_copy.pop("last_cleanup", None)
+                accounts_collection.update_one(
+                    {"_id": acc_id},
+                    {"$set": acc_copy},
+                    upsert=True
+                )
+            print(f"💾 Accounts saved to MongoDB")
+    except Exception as e:
+        print(f"❌ Error save to MongoDB: {e}")
+
+accounts = load_accounts_from_mongodb()
 
-sms_cache = {}
-sms_counter = {}
-range_counter = {}
-otp_logs = deque(maxlen=100)
+app = Flask('')
+app.secret_key = "fourstore-multi-account-secret"
 sse_clients = []
 
+# Decorator untuk cek owner via session
+def owner_required(f):
+    @wraps(f)
+    def decorated_function(*args, **kwargs):
+        owner_id = flask_session.get('owner_id')
+        if not owner_id:
+            return redirect('/login_owner')
+        return f(*args, **kwargs)
+    return decorated_function
+
 def get_wib_time():
     return datetime.now(timezone.utc) + timedelta(hours=7)
 
@@ -42,42 +119,110 @@ 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, bot_token, chat_id, owner_id):
     try:
-        print("🔐 Login...")
+        masked = mask_email(username)
+        print(f"\n{'='*60}")
+        print(f"🔐 PROSES LOGIN UNTUK: {masked} (ID: {account_id})")
+        print(f"{'='*60}")
+        
+        session = httpx.Client(follow_redirects=True, timeout=30.0)
         r = session.get(LOGIN_URL, timeout=30)
+        
+        if r.status_code != 200:
+            return False, f"HTTP {r.status_code}"
+        
         soup = BeautifulSoup(r.text, "html.parser")
         token = soup.find("input", {"name": "_token"})
         if not token:
-            print("❌ Token tidak ditemukan!")
-            return False
+            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]["username"] = username
+            accounts[account_id]["password"] = password
+            accounts[account_id]["bot_token"] = bot_token
+            accounts[account_id]["chat_id"] = chat_id
+            accounts[account_id]["owner_id"] = owner_id
+            accounts[account_id]["last_login"] = time.time()
+            save_accounts_to_mongodb(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"❌ Login Error: {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:
         date = get_search_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)
@@ -99,14 +244,18 @@ def get_ranges_with_count():
             })
 
         return ranges_data
-    except Exception as 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:
         date = get_search_date()
-        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
@@ -163,21 +312,25 @@ def get_numbers_with_count(rng):
                     })
 
         return numbers_data
-    except Exception as 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:
         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
 
-        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,
@@ -204,64 +357,16 @@ def get_sms_fast(rng, number):
             except:
                 continue
 
-        sms_cache[cache_key] = (time.time(), results)
+        account["sms_cache"][cache_key] = (time.time(), results)
         return results
     except:
         return []
 
-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
+def add_otp_log(account_id, country, number, service, otp, sms):
+    account = accounts.get(account_id)
+    if not account:
+        return
     
-    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"
-    if 'temu' in s: return "TEMU"
-    return raw.upper()
-
-def tg_send(msg):
-    try:
-        url = f"{TELEGRAM_PROXY_URL}?url=https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
-        payload = {
-            "chat_id": CHAT_ID,
-            "text": msg,
-            "parse_mode": "Markdown"
-        }
-        httpx.post(url, json=payload, timeout=30)
-        return True
-    except:
-        return False
-
-def add_otp_log(country, number, service, otp, sms):
     wib = get_wib_time()
     log_entry = {
         "time": wib.strftime("%H:%M:%S"),
@@ -269,9 +374,18 @@ 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": mask_email(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)
     return log_entry
 
@@ -286,175 +400,314 @@ def broadcast_sse(data):
     for q in dead:
         sse_clients.remove(q)
 
-app = Flask('')
+@app.route('/login_owner', methods=['GET', 'POST'])
+def login_owner():
+    if request.method == 'POST':
+        owner_id = request.form.get('owner_id')
+        if owner_id:
+            flask_session['owner_id'] = owner_id
+            return redirect('/')
+    return '''
+    <!DOCTYPE html>
+    <html>
+    <head>
+        <title>Owner Login</title>
+        <style>
+            body { background: #0a0c10; color: #e4e6eb; font-family: Inter, sans-serif; display: flex; justify-content: center; align-items: center; height: 100vh; margin: 0; }
+            .login-box { background: #1a1f2c; padding: 40px; border-radius: 24px; border: 1px solid #2d3540; width: 300px; }
+            h2 { color: #00f2fe; margin-bottom: 20px; }
+            input { width: 100%; padding: 12px; background: #0a0c10; border: 1px solid #2d3540; border-radius: 12px; color: #e4e6eb; margin-bottom: 20px; }
+            button { background: #00f2fe; color: #0a0c10; border: none; padding: 12px; border-radius: 12px; font-weight: 600; cursor: pointer; width: 100%; }
+        </style>
+    </head>
+    <body>
+        <div class="login-box">
+            <h2>Owner Login</h2>
+            <form method="post">
+                <input type="text" name="owner_id" placeholder="Masukkan Owner ID" required>
+                <button type="submit">Login</button>
+            </form>
+        </div>
+    </body>
+    </html>
+    '''
+
+@app.route('/logout_owner')
+def logout_owner():
+    flask_session.pop('owner_id', None)
+    return redirect('/')
 
 @app.route('/')
+@owner_required
 def home():
-    wib = get_wib_time()
-    search_date = get_search_date()
+    owner_id = flask_session.get('owner_id')
+    
+    # Filter accounts berdasarkan owner_id
+    user_accounts = {}
+    for acc_id, acc in accounts.items():
+        if acc.get("owner_id") == owner_id:
+            user_accounts[acc_id] = acc
+    
+    all_logs = []
+    for acc_id, acc in user_accounts.items():
+        if acc.get("otp_logs"):
+            for log in acc["otp_logs"]:
+                log_copy = log.copy()
+                log_copy["account_username"] = mask_email(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_services = list(set([log['service'] for log in otp_logs]))
-
+        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')]))
+    
+    total_otp = sum(len(acc.get('sent_cache', [])) for acc in user_accounts.values())
+    today_otp = len(all_logs)
+    
+    accounts_list = []
+    for acc_id, acc in user_accounts.items():
+        accounts_list.append({
+            "id": acc_id,
+            "username": mask_email(acc.get("username", "Unknown")),
+            "status": acc.get("status", False),
+            "bot_token": "✅" if acc.get("bot_token") else "❌",
+            "chat_id": 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>
     <html lang="en">
     <head>
         <meta charset="UTF-8">
         <meta name="viewport" content="width=device-width, initial-scale=1.0">
-        <title>OTP DASHBOARD · SEARCH</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; }}
+            
+            /* Navbar */
+            .navbar {{ background: #1a1f2c; border-radius: 16px; padding: 16px 24px; margin-bottom: 24px; display: flex; justify-content: space-between; align-items: center; border: 1px solid #2d3540; }}
+            .nav-brand {{ font-size: 20px; font-weight: 700; color: #00f2fe; }}
+            .nav-menu {{ display: flex; gap: 20px; align-items: center; }}
+            .nav-item {{ color: #8b949e; text-decoration: none; padding: 8px 16px; border-radius: 8px; transition: all 0.2s; }}
+            .nav-item:hover {{ background: #2d3540; color: #00f2fe; }}
+            .nav-item.active {{ background: #00f2fe20; color: #00f2fe; border: 1px solid #00f2fe40; }}
+            .owner-badge {{ background: #4a3a2d; padding: 8px 16px; border-radius: 100px; font-size: 14px; }}
+            
             .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'}; }}
+                          background: #0a4d3c; color: #a0f0d0; border: 1px solid #1a6e5a; }}
             .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(300px, 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; }}
-            .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; }}
-            .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; margin-bottom: 20px; }}
-            .section-title span {{ background: #00f2fe20; padding: 6px 12px; border-radius: 100px; font-size: 12px; color: #00f2fe; }}
-            table {{ width: 100%; border-collapse: collapse; }}
+            .clear-btn {{ padding: 8px 16px; background: #2d3a4a; border: none; border-radius: 100px; color: white; font-size: 13px; cursor: pointer; text-decoration: none; }}
+            
+            .otp-section {{ background: #0f131c; border-radius: 24px; padding: 28px; border: 1px solid #2d3540; overflow-x: auto; }}
+            table {{ width: 100%; border-collapse: collapse; min-width: 1100px; }}
             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; cursor: pointer; user-select: all; }}
-            .otp-badge:hover {{ background: #003d4a; border-color: #00f2fe; transform: scale(1.05); }}
             .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; }}
-            .service-badge.temu {{ background: #FF6B6B20; color: #FF6B6B; border: 1px solid #FF6B6B40; }}
+            .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; }}
             .number {{ font-family: monospace; }}
             .empty-state {{ text-align: center; padding: 60px; color: #8b949e; }}
             .highlight {{ background: #00f2fe30; border-radius: 4px; padding: 0 2px; }}
             .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; }}
+            .toast {{ position: fixed; bottom: 24px; right: 24px; background: #00f2fe; color: #000; padding: 14px 28px; border-radius: 100px; font-weight: 600; z-index: 9999; }}
             @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); }} }}
         </style>
     </head>
     <body>
         <div class="container">
+            <!-- Navbar -->
+            <div class="navbar">
+                <div class="nav-brand">OTP MULTI ACCOUNT</div>
+                <div class="nav-menu">
+                    <a href="/" class="nav-item active">🏠 Dashboard</a>
+                    <a href="/accounts" class="nav-item">📋 My Accounts</a>
+                    <a href="/logout_owner" class="nav-item">🚪 Logout</a>
+                    <span class="owner-badge">👤 Owner: {owner_id}</span>
+                </div>
+            </div>
+            
             <div class="header">
                 <div class="header-top">
                     <div class="title">
-                        <h1>OTP MONITOR · SEARCH</h1>
+                        <h1>OTP MULTI ACCOUNT · FOURSTORE</h1>
                         <p>{CUSTOM_DOMAIN}</p>
                     </div>
-                    <div class="status-badge">
-                        {'● ONLINE' if LOGIN_SUCCESS else '○ OFFLINE'}
-                    </div>
+                    <div class="status-badge">● ONLINE</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 class="stat-card"><div class="stat-label">Total Akun</div><div class="stat-value">{len(user_accounts)}</div></div>
+                    <div class="stat-card"><div class="stat-label">Akun Online</div><div class="stat-value">{sum(1 for a in user_accounts.values() if a.get('status'))}</div></div>
+                    <div class="stat-card"><div class="stat-label">Total OTP</div><div class="stat-value">{total_otp}</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="add-account-form">
+                <h3 style="margin-bottom: 15px;">➕ Tambah Akun Baru (Owner ID: {owner_id})</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">
+                    <input type="hidden" name="owner_id" value="{owner_id}">
+                    <button type="submit" class="btn">Tambah & Login Otomatis</button>
+                </form>
+            </div>
+            
+            <!-- Preview Akun (3 teratas) -->
+            <div style="margin-bottom: 20px; display: flex; justify-content: space-between; align-items: center;">
+                <h3>📋 Akun Terbaru</h3>
+                <a href="/accounts" class="btn btn-small">Lihat Semua Akun →</a>
+            </div>
+            <div class="account-grid">
+                {generate_preview_accounts(accounts_list[:3])}
+            </div>
+            
             <div class="search-section">
                 <div class="search-box">
                     <span class="search-icon">🔍</span>
                     <form action="/" method="get" id="searchForm">
-                        <input type="text" class="search-input" name="q" placeholder="Cari negara, nomor, OTP, atau SMS..." value="{request.args.get('q', '')}">
+                        <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="updateFilter('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="updateFilter('account', this.value)">
+                        <option value="">👤 Semua Akun</option>
+                        {''.join([f'<option value="{a["id"]}" {"selected" if filter_account == a["id"] else ""}>👤 {a["username"]}</option>' for a in accounts_list[:10]])}
+                    </select>
+                </div>
+                <a href="/" class="clear-btn">✕ 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>
         
         <script>
             let eventSource;
+            
             function connectSSE() {{
                 eventSource = new EventSource('/stream');
                 eventSource.onmessage = function(e) {{
                     try {{
                         const data = JSON.parse(e.data);
                         if (data.otp) {{
-                            addRow(data);
-                            updateStats();
+                            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 title="${{data.sms}}">${{data.sms}}</div></td>`;
-                while (tbody.children.length > 50) tbody.removeChild(tbody.lastChild);
+            function updateFilter(key, value) {{
+                const url = new URL(window.location.href);
+                if (value) {{
+                    url.searchParams.set(key, value);
+                }} else {{
+                    url.searchParams.delete(key);
+                }}
+                window.location.href = 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);
             }}
@@ -467,36 +720,344 @@ 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</p></td></tr>'
+def generate_preview_accounts(accounts_list):
+    if not accounts_list:
+        return '<div style="grid-column:1/-1; text-align:center; padding:40px; color:#8b949e;">Belum ada akun. Tambah akun di atas!</div>'
+    
+    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']}</h4>
+            <p style="margin-top:8px; color:#8b949e; font-size:12px;">Bot: {acc['bot_token']} | Chat: {acc['chat_id']}</p>
+            <p style="color:#8b949e; font-size:12px;">Status: {'🟢 Online' if acc['status'] else '🔴 Offline'}</p>
+        </div>
+        """
+    return html
+
+@app.route('/accounts')
+@owner_required
+def accounts_page():
+    owner_id = flask_session.get('owner_id')
+    
+    # Filter accounts berdasarkan owner_id
+    user_accounts = {}
+    for acc_id, acc in accounts.items():
+        if acc.get("owner_id") == owner_id:
+            user_accounts[acc_id] = acc
+    
+    accounts_list = []
+    for acc_id, acc in user_accounts.items():
+        accounts_list.append({
+            "id": acc_id,
+            "username": mask_email(acc.get("username", "Unknown")),
+            "status": acc.get("status", False),
+            "bot_token": acc.get("bot_token", "-")[:10] + "..." if len(acc.get("bot_token", "")) > 10 else acc.get("bot_token", "-"),
+            "chat_id": acc.get("chat_id", "-"),
+            "created_at": datetime.fromtimestamp(acc.get("created_at", time.time())).strftime("%Y-%m-%d %H:%M") if acc.get("created_at") else "-",
+            "last_login": datetime.fromtimestamp(acc.get("last_login", 0)).strftime("%Y-%m-%d %H:%M") if acc.get("last_login") else "-",
+            "otp_count": len(acc.get("sent_cache", []))
+        })
+    
+    html = f"""
+    <!DOCTYPE html>
+    <html lang="en">
+    <head>
+        <meta charset="UTF-8">
+        <meta name="viewport" content="width=device-width, initial-scale=1.0">
+        <title>My Accounts · 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; }}
+            
+            .navbar {{ background: #1a1f2c; border-radius: 16px; padding: 16px 24px; margin-bottom: 24px; display: flex; justify-content: space-between; align-items: center; border: 1px solid #2d3540; }}
+            .nav-brand {{ font-size: 20px; font-weight: 700; color: #00f2fe; }}
+            .nav-menu {{ display: flex; gap: 20px; align-items: center; }}
+            .nav-item {{ color: #8b949e; text-decoration: none; padding: 8px 16px; border-radius: 8px; }}
+            .nav-item:hover {{ background: #2d3540; color: #00f2fe; }}
+            .nav-item.active {{ background: #00f2fe20; color: #00f2fe; border: 1px solid #00f2fe40; }}
+            .owner-badge {{ background: #4a3a2d; padding: 8px 16px; border-radius: 100px; font-size: 14px; }}
+            
+            .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; }}
+            .title h1 {{ font-size: 28px; font-weight: 700; background: linear-gradient(135deg, #00f2fe, #4facfe); -webkit-background-clip: text; -webkit-text-fill-color: transparent; }}
+            
+            .accounts-table {{ 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; }}
+            .status-badge {{ display: inline-block; padding: 4px 8px; border-radius: 100px; font-size: 12px; font-weight: 600; }}
+            .status-online {{ background: #0a4d3c; color: #a0f0d0; }}
+            .status-offline {{ background: #4a2c2c; color: #ffb3b3; }}
+            .btn {{ background: #00f2fe; color: #0a0c10; border: none; padding: 6px 12px; border-radius: 8px; font-size: 12px; font-weight: 600; cursor: pointer; text-decoration: none; display: inline-block; }}
+            .btn-danger {{ background: #ff4d4d; color: white; }}
+            .btn-small {{ padding: 4px 8px; font-size: 11px; }}
+            .action-group {{ display: flex; gap: 5px; }}
+        </style>
+    </head>
+    <body>
+        <div class="container">
+            <div class="navbar">
+                <div class="nav-brand">OTP MULTI ACCOUNT</div>
+                <div class="nav-menu">
+                    <a href="/" class="nav-item">🏠 Dashboard</a>
+                    <a href="/accounts" class="nav-item active">📋 My Accounts</a>
+                    <a href="/logout_owner" class="nav-item">🚪 Logout</a>
+                    <span class="owner-badge">👤 Owner: {owner_id}</span>
+                </div>
+            </div>
+            
+            <div class="header">
+                <div class="header-top">
+                    <div class="title">
+                        <h1>📋 My Accounts</h1>
+                        <p style="color:#8b949e; margin-top:8px;">Total: {len(accounts_list)} akun | Online: {sum(1 for a in accounts_list if a['status'])}</p>
+                    </div>
+                    <a href="/" class="btn">+ Tambah Akun Baru</a>
+                </div>
+            </div>
+            
+            <div class="accounts-table">
+                <table>
+                    <thead>
+                        <tr>
+                            <th>No</th>
+                            <th>Username</th>
+                            <th>Status</th>
+                            <th>Bot Token</th>
+                            <th>Chat ID</th>
+                            <th>OTP Count</th>
+                            <th>Created At</th>
+                            <th>Last Login</th>
+                            <th>Actions</th>
+                        </tr>
+                    </thead>
+                    <tbody>
+                        {generate_accounts_rows(accounts_list)}
+                    </tbody>
+                </table>
+            </div>
+        </div>
+        
+        <script>
+            function loginAccount(accountId) {{
+                fetch('/login_account/' + accountId, {{method: 'POST'}})
+                    .then(() => location.reload());
+            }}
+            
+            function logoutAccount(accountId) {{
+                fetch('/logout_account/' + accountId, {{method: 'POST'}})
+                    .then(() => location.reload());
+            }}
+        </script>
+    </body>
+    </html>
+    """
+    return html
+
+def generate_accounts_rows(accounts_list):
+    if not accounts_list:
+        return '<tr><td colspan="9" style="text-align:center; padding:60px; color:#8b949e;">Belum ada akun. Tambah akun di dashboard!</td></tr>'
+    
+    rows = ""
+    for i, acc in enumerate(accounts_list, 1):
+        status_class = "status-online" if acc["status"] else "status-offline"
+        status_text = "🟢 Online" if acc["status"] else "🔴 Offline"
+        
+        rows += f"""
+        <tr>
+            <td>{i}</td>
+            <td>{acc['username']}</td>
+            <td><span class="status-badge {status_class}">{status_text}</span></td>
+            <td>{acc['bot_token']}</td>
+            <td>{acc['chat_id']}</td>
+            <td>{acc['otp_count']}</td>
+            <td>{acc['created_at']}</td>
+            <td>{acc['last_login']}</td>
+            <td>
+                <div class="action-group">
+                    <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 ini?')">Hapus</a>
+                </div>
+            </td>
+        </tr>
+        """
+    return rows
+
+def generate_otp_rows(logs, search_query):
+    if not logs:
+        return '<tr><td colspan="7" class="empty-state">🔍 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')
         
         if search_query:
             country = re.sub(f'({re.escape(search_query)})', r'<span class="highlight">\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 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]
+    username = request.form['username']
+    password = request.form['password']
+    bot_token = request.form.get('bot_token', '')
+    chat_id = request.form.get('chat_id', '')
+    owner_id = request.form.get('owner_id')
+    
+    if not owner_id:
+        owner_id = flask_session.get('owner_id')
+    
+    masked = mask_email(username)
+    print(f"\n➕ TAMBAH AKUN BARU: {masked} (ID: {account_id}) (Owner: {owner_id})")
+    
+    accounts[account_id] = {
+        "id": account_id,
+        "username": username,
+        "password": password,
+        "bot_token": bot_token,
+        "chat_id": chat_id,
+        "owner_id": owner_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_to_mongodb(accounts)
+    print(f"✅ Akun ditambahkan: {masked}")
+    
+    # OTOMATIS LOGIN SETELAH TAMBAH AKUN
+    print(f"🔄 Mencoba login otomatis untuk {masked}...")
+    success, msg = login_account(
+        account_id, 
+        username, 
+        password,
+        bot_token,
+        chat_id,
+        owner_id
+    )
+    
+    if success:
+        print(f"✅✅✅ LOGIN OTOMATIS BERHASIL! Memulai thread scraper...")
+        thread = Thread(target=run_account_scraper, args=(account_id,), daemon=True)
+        thread.start()
+        print(f"✅ Thread scraper dimulai untuk {masked}")
+    else:
+        print(f"❌❌❌ LOGIN OTOMATIS GAGAL: {msg}")
+    
+    return redirect('/')
+
+@app.route('/delete_account/<account_id>')
+@owner_required
+def delete_account_route(account_id):
+    owner_id = flask_session.get('owner_id')
+    
+    if account_id in accounts:
+        # Cek apakah akun ini milik owner yang sedang login
+        if accounts[account_id].get("owner_id") != owner_id:
+            return "Unauthorized", 403
+            
+        username = accounts[account_id].get('username', 'Unknown')
+        masked = mask_email(username)
+        print(f"\n🗑️ HAPUS AKUN: {masked} (ID: {account_id})")
+        del accounts[account_id]
+        if mongo_client:
+            accounts_collection.delete_one({"_id": account_id})
+        print(f"✅ Akun dihapus")
+    
+    return redirect(request.referrer or '/')
+
+@app.route('/login_account/<account_id>', methods=['POST'])
+@owner_required
+def login_account_route(account_id):
+    owner_id = flask_session.get('owner_id')
+    print(f"\n🔔🔔🔔 LOGIN ACCOUNT DIPANGGIL: {account_id} 🔔🔔🔔")
+    
+    if account_id in accounts:
+        # Cek apakah akun ini milik owner yang sedang login
+        if accounts[account_id].get("owner_id") != owner_id:
+            return "Unauthorized", 403
+            
+        acc = accounts[account_id]
+        masked = mask_email(acc.get('username', 'Unknown'))
+        print(f"📋 Data akun: {masked}")
+        print(f"🔐 Mencoba login...")
+        
+        success, msg = login_account(
+            account_id, 
+            acc['username'], 
+            acc['password'],
+            acc.get('bot_token', ''),
+            acc.get('chat_id', ''),
+            owner_id
+        )
+        
+        print(f"📝 Result: {success} - {msg}")
+        
+        if success:
+            print(f"✅✅✅ LOGIN BERHASIL! Memulai thread scraper...")
+            thread = Thread(target=run_account_scraper, args=(account_id,), daemon=True)
+            thread.start()
+            print(f"✅ Thread scraper dimulai untuk {masked}")
+        else:
+            print(f"❌❌❌ LOGIN GAGAL: {msg}")
+    else:
+        print(f"❌ Account ID {account_id} tidak ditemukan!")
+    
+    return redirect(request.referrer or '/')
+
+@app.route('/logout_account/<account_id>', methods=['POST'])
+@owner_required
+def logout_account_route(account_id):
+    owner_id = flask_session.get('owner_id')
+    
+    if account_id in accounts:
+        # Cek apakah akun ini milik owner yang sedang login
+        if accounts[account_id].get("owner_id") != owner_id:
+            return "Unauthorized", 403
+            
+        username = accounts[account_id].get('username', 'Unknown')
+        masked = mask_email(username)
+        print(f"\n🔌 LOGOUT: {masked} (ID: {account_id})")
+        accounts[account_id]["status"] = False
+        accounts[account_id]["session"] = None
+        accounts[account_id]["csrf"] = None
+        save_accounts_to_mongodb(accounts)
+        print(f"✅ Logout berhasil")
+    
+    return redirect(request.referrer or '/')
+
 @app.route('/stream')
 def stream():
     def generate():
@@ -510,99 +1071,143 @@ 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 - HUGGING FACE")
-    print("  ⚡ PORT: 7860")
-    print("  🌐 DOMAIN: fourstore-tele.hf.space")
-    print("  🔑 Using Hugging Face Secrets")
-    print("  🔌 Telegram via Proxy")
-    print("="*60 + "\n")
-
-    if not USERNAME or not PASSWORD:
-        print("❌ ERROR: USERNAME dan PASSWORD harus diisi di Secrets!")
+def run_account_scraper(account_id):
+    account = accounts.get(account_id)
+    if not account:
         return
-
-    for i in range(5):
-        if login():
-            break
-        time.sleep(3)
-
-    last_cleanup = time.time()
-
-    while True:
+    
+    username = account['username']
+    masked = mask_email(username)
+    print(f"\n🚀🚀🚀 STARTING SCRAPER FOR: {masked} 🚀🚀🚀")
+    loop_count = 0
+    
+    while account.get("status"):
+        loop_count += 1
         try:
-            if not LOGIN_SUCCESS or not csrf_token:
-                login()
-                time.sleep(2)
-                continue
-
-            if time.time() - last_cleanup > 300:
-                sms_cache.clear()
-                sms_counter.clear()
-                range_counter.clear()
-                print("🧹 Cache cleared")
-                last_cleanup = time.time()
-
-            ranges_data = get_ranges_with_count()
-            print(f"\n📡 Scan {len(ranges_data)} ranges...")
-
+            print(f"\n{'='*60}")
+            print(f"🔄 [{masked}] LOOP #{loop_count}")
+            print(f"{'='*60}")
+            
+            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"🧹 [{masked}] Cache cleared")
+            
+            ranges_data = get_ranges_with_count(account_id)
+            print(f"📊 [{masked}] Total ranges: {len(ranges_data)}")
+            
             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"\n🔥 RANGE BERUBAH: {country} ({masked})")
                     print(f"   📊 {prev_count} → {current_count} SMS")
-                    range_counter[rng] = current_count
-
-                    numbers_data = get_numbers_with_count(rng)
-                    print(f"   📞 Scan {len(numbers_data)} nomor...")
-
+                    account["range_counter"][rng] = current_count
+                    
+                    numbers_data = get_numbers_with_count(account_id, rng)
+                    print(f"   📞 Total nomor: {len(numbers_data)}")
+                    
                     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")
-                            sms_counter[key] = num_count
-
-                            all_sms = get_sms_fast(rng, num)
+                            account["sms_counter"][key] = num_count
+                            
+                            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:
-                                        masked = mask_number(num)
-                                        msg = f"🔔 *NEW OTP*\n🌍 {country}\n📞 `{masked}`\n💬 {service}\n🔐 `{otp}`\n\n{sms[:300]}"
-                                        if tg_send(msg):
-                                            sent_cache.add(sms_id)
-                                            add_otp_log(country, masked, service, otp, sms)
-                                            print(f"      ✅ OTP: {otp} - {service} (via proxy)")
-
-                    print(f"   ✅ Selesai proses {country}")
+                                    if sms_id not in account["sent_cache"]:
+                                        masked_num = mask_number(num)
+                                        msg = f"🔔 *NEW OTP*\n🌍 {country}\n📞 `{masked_num}`\n💬 {service}\n🔐 `{otp}`\n\n{sms[:300]}"
+                                        print(f"      📤 Mengirim OTP {otp} ke Telegram...")
+                                        
+                                        if tg_send(account_id, msg):
+                                            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_num, service, otp, sms)
+                                            print(f"      ✅ OTP: {otp} - {service} TERKIRIM!")
+                    
                     time.sleep(0.5)
-
-            print("\n⏳ Tidur 2 detik...")
+                else:
+                    print(f"  ⏭️ Range {clean_country(rng)} tidak berubah (count: {current_count})")
+            
+            print(f"\n⏳ [{masked}] Tidur 2 detik...")
             time.sleep(2)
-
+            
         except Exception as e:
-            print(f"❌ Error: {e}")
-            time.sleep(3)
+            print(f"❌ ERROR in scraper for {masked}: {str(e)}")
+            time.sleep(5)
+    
+    print(f"\n🛑🛑🛑 SCRAPER STOPPED FOR: {masked} ����🛑🛑")
+
+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 MULTI ACCOUNT - FOURSTORE")
+    print("  ⚡ PORT: 7860")
+    print(f"  🌐 DOMAIN: {CUSTOM_DOMAIN}")
+    print("  📁 Data tersimpan di MongoDB")
+    print("  📋 LOGGING: FULL DETAIL")
+    print("  🔒 EMAIL SENSOR: AKTIF")
+    print("  🤖 AUTO LOGIN: AKTIF (setelah tambah akun)")
+    print("  👑 OWNER SYSTEM: AKTIF")
+    print("="*60 + "\n")
+    
+    # Auto login untuk akun yang sudah login sebelumnya
+    for acc_id, acc in accounts.items():
+        if acc.get("status"):
+            masked = mask_email(acc['username'])
+            print(f"🔄 Auto-login untuk {masked}...")
+            success, msg = login_account(
+                acc_id, 
+                acc['username'], 
+                acc['password'],
+                acc.get('bot_token', ''),
+                acc.get('chat_id', ''),
+                acc.get('owner_id', 'unknown')
+            )
+            if success:
+                thread = Thread(target=run_account_scraper, args=(acc_id,), daemon=True)
+                thread.start()
+                print(f"✅ {masked} online")
+            else:
+                print(f"❌ {masked} offline: {msg}")
+                acc["status"] = False
+                save_accounts_to_mongodb(accounts)
+    
+    print("\n✅ BOT SIAP! Dashboard: https://fourstore-otp.hf.space")
+    print("🔐 Login dengan Owner ID untuk mengakses")
+    
+    while True:
+        time.sleep(60)
 
 if __name__ == "__main__":
     try:
         main()
     except KeyboardInterrupt:
-        print("\n🛑 BOT STOPPED")
+        print("\n🛑 BOT STOPPED")
+        save_accounts_to_mongodb(accounts)