Update app.py

app.py

@@ -10,6 +10,10 @@ import json
 from queue import Queue
 import os
 import uuid
+import sys
+
+# Force print to flush immediately
+print = lambda *args, **kwargs: __builtins__.print(*args, **kwargs, flush=True)
 
 BASE = "http://159.69.3.189"
 LOGIN_URL = f"{BASE}/login"
@@ -27,16 +31,22 @@ def load_accounts():
         try:
             with open(ACCOUNTS_FILE, 'r') as f:
                 return json.load(f)
-        except:
+        except Exception as e:
+            print(f"❌ Error load accounts: {e}")
             return {}
     return {}
 
 def save_accounts(accounts):
-    with open(ACCOUNTS_FILE, 'w') as f:
-        json.dump(accounts, f, indent=2)
+    try:
+        with open(ACCOUNTS_FILE, 'w') as f:
+            json.dump(accounts, f, indent=2)
+        print(f"💾 Accounts saved to {ACCOUNTS_FILE}")
+    except Exception as e:
+        print(f"❌ Error save accounts: {e}")
 
 # Inisialisasi accounts
 accounts = load_accounts()
+print(f"\n📊 Loaded {len(accounts)} accounts from file")
 
 # Tambahkan runtime data ke setiap account
 for acc_id in accounts:
@@ -49,6 +59,7 @@ for acc_id in accounts:
     accounts[acc_id]["sms_counter"] = {}
     accounts[acc_id]["range_counter"] = {}
     accounts[acc_id]["last_cleanup"] = time.time()
+    print(f"  ✅ Account {acc_id}: {accounts[acc_id].get('username')}")
 
 app = Flask('')
 app.secret_key = "fourstore-multi-account-secret"
@@ -63,23 +74,43 @@ def get_search_date():
 
 def login_account(account_id, username, password, bot_token, chat_id):
     try:
-        print(f"\n🔐 Login untuk: {username}")
+        print(f"\n{'='*60}")
+        print(f"🔐 PROSES LOGIN UNTUK: {username} (ID: {account_id})")
+        print(f"{'='*60}")
+        
+        print(f"📤 Membuat session baru...")
         session = httpx.Client(follow_redirects=True, timeout=30.0)
         
+        print(f"📥 GET login page: {LOGIN_URL}")
         r = session.get(LOGIN_URL, timeout=30)
+        print(f"📊 Status code: {r.status_code}")
+        
+        if r.status_code != 200:
+            print(f"❌ Gagal load login page")
+            return False, f"HTTP {r.status_code}"
+        
         soup = BeautifulSoup(r.text, "html.parser")
         token = soup.find("input", {"name": "_token"})
         if not token:
+            print(f"❌ Token CSRF tidak ditemukan dalam HTML")
+            print(f"📄 Preview HTML: {r.text[:200]}")
             return False, "Token tidak ditemukan"
         
         csrf_token = token.get("value")
+        print(f"✅ CSRF Token: {csrf_token[:20]}...")
+        
+        print(f"📤 POST login data...")
         r = session.post(LOGIN_URL, data={
             "_token": csrf_token,
             "email": username,
             "password": password
         }, timeout=30)
-
+        print(f"📊 Response status: {r.status_code}")
+        
         if "dashboard" in r.text.lower() or "logout" in r.text.lower():
+            print(f"✅✅✅ LOGIN BERHASIL! ✅✅✅")
+            print(f"📦 Menyimpan session untuk {username}")
+            
             accounts[account_id]["session"] = session
             accounts[account_id]["csrf"] = csrf_token
             accounts[account_id]["status"] = True
@@ -89,10 +120,15 @@ def login_account(account_id, username, password, bot_token, chat_id):
             accounts[account_id]["chat_id"] = chat_id
             accounts[account_id]["last_login"] = time.time()
             save_accounts(accounts)
+            
             return True, "Login berhasil"
         else:
-            return False, "Login gagal"
+            print(f"❌❌❌ LOGIN GAGAL! ❌❌❌")
+            print(f"📄 Response preview: {r.text[:300]}")
+            return False, "Login gagal - cek username/password"
+            
     except Exception as e:
+        print(f"❌ EXCEPTION: {str(e)}")
         return False, str(e)
 
 def tg_send(account_id, msg):
@@ -647,6 +683,8 @@ def add_account_route():
     bot_token = request.form.get('bot_token', '')
     chat_id = request.form.get('chat_id', '')
     
+    print(f"\n➕ TAMBAH AKUN BARU: {username} (ID: {account_id})")
+    
     accounts[account_id] = {
         "id": account_id,
         "username": username,
@@ -665,19 +703,28 @@ def add_account_route():
         "created_at": time.time()
     }
     save_accounts(accounts)
+    print(f"✅ Akun ditambahkan: {username}")
     return redirect('/')
 
 @app.route('/delete_account/<account_id>')
 def delete_account_route(account_id):
     if account_id in accounts:
+        username = accounts[account_id].get('username', 'Unknown')
+        print(f"\n🗑️ HAPUS AKUN: {username} (ID: {account_id})")
         del accounts[account_id]
         save_accounts(accounts)
+        print(f"✅ Akun dihapus")
     return redirect('/')
 
 @app.route('/login_account/<account_id>', methods=['POST'])
 def login_account_route(account_id):
+    print(f"\n🔔🔔🔔 LOGIN ACCOUNT DIPANGGIL: {account_id} 🔔🔔🔔")
+    
     if account_id in accounts:
         acc = accounts[account_id]
+        print(f"📋 Data akun: {acc.get('username')}")
+        print(f"🔐 Mencoba login...")
+        
         success, msg = login_account(
             account_id, 
             acc['username'], 
@@ -685,19 +732,31 @@ def login_account_route(account_id):
             acc.get('bot_token', ''),
             acc.get('chat_id', '')
         )
+        
+        print(f"📝 Result: {success} - {msg}")
+        
         if success:
-            # Start thread scraper untuk akun ini
+            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 {acc['username']}")
+        else:
+            print(f"❌❌❌ LOGIN GAGAL: {msg}")
+    else:
+        print(f"❌ Account ID {account_id} tidak ditemukan!")
+    
     return redirect('/')
 
 @app.route('/logout_account/<account_id>', methods=['POST'])
 def logout_account_route(account_id):
     if account_id in accounts:
+        username = accounts[account_id].get('username', 'Unknown')
+        print(f"\n🔌 LOGOUT: {username} (ID: {account_id})")
         accounts[account_id]["status"] = False
         accounts[account_id]["session"] = None
         accounts[account_id]["csrf"] = None
         save_accounts(accounts)
+        print(f"✅ Logout berhasil")
     return redirect('/')
 
 @app.route('/stream')
@@ -719,18 +778,25 @@ def run_account_scraper(account_id):
         return
     
     username = account['username']
-    print(f"🚀 Starting scraper for {username}")
+    print(f"\n🚀🚀🚀 STARTING SCRAPER FOR: {username} 🚀🚀🚀")
+    loop_count = 0
     
     while account.get("status"):
+        loop_count += 1
         try:
+            print(f"\n{'='*60}")
+            print(f"🔄 [{username}] 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"🧹 Cache cleared for {username}")
+                print(f"🧹 [{username}] Cache cleared")
             
             ranges_data = get_ranges_with_count(account_id)
+            print(f"📊 [{username}] Total ranges: {len(ranges_data)}")
             
             for range_item in ranges_data:
                 if not account.get("status"):
@@ -743,9 +809,11 @@ def run_account_scraper(account_id):
                 if current_count > prev_count:
                     country = clean_country(rng)
                     print(f"\n🔥 RANGE BERUBAH: {country} ({username})")
+                    print(f"   📊 {prev_count} → {current_count} SMS")
                     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"):
@@ -757,6 +825,8 @@ def run_account_scraper(account_id):
                         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")
                             account["sms_counter"][key] = num_count
                             
                             all_sms = get_sms_fast(account_id, rng, num)
@@ -768,22 +838,27 @@ def run_account_scraper(account_id):
                                     if sms_id not in account["sent_cache"]:
                                         masked = mask_number(num)
                                         msg = f"🔔 *NEW OTP*\n🌍 {country}\n📞 `{masked}`\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, service, otp, sms)
-                                            print(f"      ✅ OTP: {otp} - {service}")
+                                            print(f"      ✅ OTP: {otp} - {service} TERKIRIM!")
                     
                     time.sleep(0.5)
+                else:
+                    print(f"  ⏭️ Range {clean_country(rng)} tidak berubah (count: {current_count})")
             
+            print(f"\n⏳ [{username}] Tidur 2 detik...")
             time.sleep(2)
             
         except Exception as e:
-            print(f"❌ Error in scraper for {username}: {e}")
+            print(f"❌ ERROR in scraper for {username}: {str(e)}")
             time.sleep(5)
     
-    print(f"🛑 Scraper stopped for {username}")
+    print(f"\n🛑🛑🛑 SCRAPER STOPPED FOR: {username} 🛑🛑🛑")
 
 def run_server():
     app.run(host='0.0.0.0', port=7860, debug=False, threaded=True)
@@ -797,6 +872,7 @@ def main():
     print("  ⚡ PORT: 7860")
     print(f"  🌐 DOMAIN: {CUSTOM_DOMAIN}")
     print("  📁 Data tersimpan di accounts.json")
+    print("  📋 LOGGING: FULL DETAIL (FLUSH ENABLED)")
     print("="*60 + "\n")
     
     # Login otomatis untuk akun yang sudah login sebelumnya
@@ -819,7 +895,8 @@ def main():
                 acc["status"] = False
                 save_accounts(accounts)
     
-    print("\n✅ BOT SIAP! Dashboard: http://localhost:7860")
+    print("\n✅ BOT SIAP! Dashboard: https://fourstore-otp.hf.space")
+    print("📋 Log akan muncul di terminal ini setiap ada aktivitas\n")
     
     # Keep main thread alive
     while True: