Update app.py

app.py

@@ -13,13 +13,6 @@ import uuid
 import sys
 from pymongo import MongoClient
 from pymongo.errors import ConnectionFailure
-import logging
-from telegram import Update
-from telegram.ext import Updater, CommandHandler, CallbackContext
-
-# Setup logging
-logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s', level=logging.INFO)
-logger = logging.getLogger(__name__)
 
 MONGODB_URI = os.environ.get("MONGODB_URI")
 DB_NAME = "otp_bot"
@@ -165,11 +158,11 @@ 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_account(account_id, username, password, bot_token, chat_id, owner_id):
+def login_account(account_id, username, password, bot_token, chat_id):
     try:
         masked = mask_email(username)
         print(f"\n{'='*60}")
-        print(f"🔐 PROSES LOGIN UNTUK: {masked} (ID: {account_id}) (Owner: {owner_id})")
+        print(f"🔐 PROSES LOGIN UNTUK: {masked} (ID: {account_id})")
         print(f"{'='*60}")
         
         session = httpx.Client(follow_redirects=True, timeout=30.0)
@@ -198,7 +191,6 @@ def login_account(account_id, username, password, bot_token, chat_id, owner_id):
             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()
             
             if mongo_client:
@@ -562,7 +554,6 @@ def home():
                     <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="text" name="owner_id" placeholder="Owner ID (opsional)" class="form-input">
                     <button type="submit" class="btn">Tambah & Login Otomatis</button>
                 </form>
             </div>
@@ -695,13 +686,9 @@ def add_account_route():
     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 = "default"
     
     masked = mask_email(username)
-    print(f"\n➕ TAMBAH AKUN BARU: {masked} (ID: {account_id}) (Owner: {owner_id})")
+    print(f"\n➕ TAMBAH AKUN BARU: {masked} (ID: {account_id})")
     
     accounts[account_id] = {
         "id": account_id,
@@ -709,7 +696,6 @@ def add_account_route():
         "password": password,
         "bot_token": bot_token,
         "chat_id": chat_id,
-        "owner_id": owner_id,
         "session": None,
         "csrf": None,
         "status": False,
@@ -734,8 +720,7 @@ def add_account_route():
         username, 
         password,
         bot_token,
-        chat_id,
-        owner_id
+        chat_id
     )
     
     if success:
@@ -761,95 +746,6 @@ def stream():
                 sse_clients.remove(q)
     return Response(generate(), mimetype="text/event-stream")
 
-# ========== BOT TELEGRAM ==========
-def start_command(update: Update, context: CallbackContext):
-    try:
-        chat_id = str(update.effective_chat.id)
-        user = update.effective_user
-        print(f"📩 /start dari {user.first_name} (Chat ID: {chat_id})")
-        
-        user_accounts = []
-        for acc_id, acc in accounts.items():
-            if acc.get("owner_id") == chat_id:
-                user_accounts.append(acc)
-        
-        text = f"👋 Halo {user.first_name}!\n\n📌 Chat ID kamu: `{chat_id}`\n\n"
-        
-        if user_accounts:
-            text += f"✅ Kamu punya {len(user_accounts)} akun terdaftar.\n"
-            text += "/accounts - Lihat daftar akun"
-        else:
-            text += "❌ Belum punya akun.\nGunakan Chat ID sebagai Owner ID di web."
-        
-        update.message.reply_text(text, parse_mode='Markdown')
-        print(f"✅ Pesan terkirim ke {chat_id}")
-    except Exception as e:
-        print(f"❌ Error di start_command: {e}")
-
-def accounts_command(update: Update, context: CallbackContext):
-    try:
-        chat_id = str(update.effective_chat.id)
-        print(f"📩 /accounts dari Chat ID: {chat_id}")
-        
-        user_accounts = []
-        for acc_id, acc in accounts.items():
-            if acc.get("owner_id") == chat_id:
-                user_accounts.append((acc_id, acc))
-        
-        if not user_accounts:
-            update.message.reply_text("❌ Kamu belum punya akun.")
-            return
-        
-        text = "📋 *Daftar Akun:*\n\n"
-        for acc_id, acc in user_accounts:
-            status = "🟢 ON" if acc.get("status") else "🔴 OFF"
-            masked = mask_email(acc['username'])
-            text += f"• `{masked}`\n  ID: `{acc_id}` | {status} | OTP: {len(acc.get('sent_cache', []))}\n\n"
-        
-        update.message.reply_text(text, parse_mode='Markdown')
-        print(f"✅ Accounts terkirim ke {chat_id}")
-    except Exception as e:
-        print(f"❌ Error di accounts_command: {e}")
-
-def error_handler(update: Update, context: CallbackContext):
-    print(f"❌ Telegram Error: {context.error}")
-
-def run_telegram_bot():
-    try:
-        print("🤖 Starting Telegram Bot...")
-        
-        # Kumpulkan semua token unik
-        tokens = set()
-        for acc_id, acc in accounts.items():
-            if acc.get("bot_token"):
-                tokens.add(acc['bot_token'])
-        
-        if not tokens:
-            print("⚠️ Tidak ada bot token ditemukan di database!")
-            return
-        
-        print(f"📊 Menemukan {len(tokens)} bot token")
-        
-        # Jalankan bot untuk setiap token
-        for token in tokens:
-            try:
-                updater = Updater(token, use_context=True)
-                dp = updater.dispatcher
-                
-                dp.add_handler(CommandHandler("start", start_command))
-                dp.add_handler(CommandHandler("accounts", accounts_command))
-                dp.add_error_handler(error_handler)
-                
-                updater.start_polling()
-                print(f"✅ Bot dengan token {token[:10]}... berjalan")
-            except Exception as e:
-                print(f"❌ Gagal start bot dengan token {token[:10]}: {e}")
-        
-        print("🤖 Semua bot Telegram aktif!")
-        
-    except Exception as e:
-        print(f"❌ Fatal error di run_telegram_bot: {e}")
-
 def run_account_scraper(account_id):
     account = accounts.get(account_id)
     if not account:
@@ -942,9 +838,8 @@ def run_account_scraper(account_id):
 def run_server():
     app.run(host='0.0.0.0', port=7860, debug=False, threaded=True)
 
-# Jalankan semua thread
+# Jalankan server Flask
 Thread(target=run_server, daemon=True).start()
-Thread(target=run_telegram_bot, daemon=True).start()
 
 def main():
     print("\n" + "="*60)
@@ -958,8 +853,7 @@ def main():
     print("  📋 LOGGING: FULL DETAIL")
     print("  🔒 EMAIL SENSOR: AKTIF")
     print("  🤖 AUTO LOGIN: AKTIF")
-    print("  👑 OWNER ID: Input manual di form")
-    print("  🤖 TELEGRAM BOT: AKTIF (Multi-Token)")
+    print("  📱 TELEGRAM: HANYA KIRIM OTP (TANPA MENU)")
     print("="*60 + "\n")
     
     # Auto login untuk akun yang sudah login sebelumnya
@@ -972,8 +866,7 @@ def main():
                 acc['username'], 
                 acc['password'],
                 acc.get('bot_token', ''),
-                acc.get('chat_id', ''),
-                acc.get('owner_id', 'default')
+                acc.get('chat_id', '')
             )
             if success:
                 thread = Thread(target=run_account_scraper, args=(acc_id,), daemon=True)
@@ -988,8 +881,6 @@ def main():
                     save_accounts_to_file(accounts)
     
     print("\n✅ BOT SIAP! Dashboard: https://fourstore-otp.hf.space")
-    print("📝 Owner ID bisa diisi manual saat tambah akun")
-    print("🤖 Bot Telegram siap menerima perintah")
     
     while True:
         time.sleep(60)