update

app.py

@@ -59,36 +59,61 @@ def get_search_date():
 
 def login_account(account_id, username, password):
     try:
+        print(f"\n🔐 LOGIN ACCOUNT: {username}")
+        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"📦 Session aktif, menyimpan data...")
+            
             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:
-            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):
     try:
         account = accounts.get(account_id)
         if not account or not account.get("bot_token") or not account.get("chat_id"):
+            print(f"⚠️ Telegram: No bot_token/chat_id for {account_id}")
             return False
         
         url = f"{TELEGRAM_PROXY_URL}?url=https://api.telegram.org/bot{account['bot_token']}/sendMessage"
@@ -97,9 +122,12 @@ def tg_send(account_id, msg):
             "text": msg,
             "parse_mode": "Markdown"
         }
-        httpx.post(url, json=payload, timeout=30)
+        print(f"📤 Send to Telegram: {msg[:50]}...")
+        r = httpx.post(url, json=payload, timeout=30)
+        print(f"📊 Telegram response: {r.status_code}")
         return True
-    except:
+    except Exception as e:
+        print(f"❌ Telegram error: {e}")
         return False
 
 def clean_country(rng):
@@ -140,16 +168,21 @@ def extract_otp(text):
 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"):
+        print(f"⚠️ Account {account_id} invalid")
         return []
     
     try:
         date = get_search_date()
+        print(f"\n🔍 AMBIL RANGE - {account['username']} - Tanggal: {date}")
+        
         r = account["session"].post(GET_RANGE_URL, data={
             "_token": account["csrf"],
             "from": date,
             "to": date
         }, timeout=15)
-
+        
+        print(f"📊 Status: {r.status_code}")
+        
         soup = BeautifulSoup(r.text, "html.parser")
         ranges_data = []
 
@@ -165,9 +198,11 @@ def get_ranges_with_count(account_id):
                 "name": rng,
                 "count": count
             })
+            print(f"  ✅ {rng} - {count} SMS")
 
         return ranges_data
-    except:
+    except Exception as e:
+        print(f"❌ Error get_ranges: {e}")
         return []
 
 def get_numbers_with_count(account_id, rng):
@@ -177,6 +212,8 @@ def get_numbers_with_count(account_id, rng):
     
     try:
         date = get_search_date()
+        print(f"\n    📞 AMBIL NOMOR: {rng}")
+        
         r = account["session"].post(GET_NUMBER_URL, data={
             "_token": account["csrf"],
             "start": date,
@@ -212,9 +249,11 @@ def get_numbers_with_count(account_id, rng):
                         "number": num,
                         "count": count
                     })
+                    print(f"        ✅ {mask_number(num)} - {count} SMS")
 
         return numbers_data
-    except:
+    except Exception as e:
+        print(f"    ❌ Error get_numbers: {e}")
         return []
 
 def get_sms_fast(account_id, rng, number):
@@ -229,8 +268,10 @@ def get_sms_fast(account_id, rng, number):
         if cache_key in account["sms_cache"]:
             timestamp, results = account["sms_cache"][cache_key]
             if time.time() - timestamp < 5:
+                print(f"      💾 Cache: {len(results)} SMS")
                 return results
 
+        print(f"      📨 AMBIL SMS: {mask_number(number)}")
         r = account["session"].post(GET_SMS_URL, data={
             "_token": account["csrf"],
             "start": date,
@@ -256,12 +297,14 @@ def get_sms_fast(account_id, rng, number):
                     otp = extract_otp(sms)
                     if otp:
                         results.append((service, sms, otp))
+                        print(f"        ✅ OTP: {otp} - {service}")
             except:
                 continue
 
         account["sms_cache"][cache_key] = (time.time(), results)
         return results
-    except:
+    except Exception as e:
+        print(f"      ❌ Error get_sms: {e}")
         return []
 
 def add_otp_log(account_id, country, number, service, otp, sms):
@@ -290,6 +333,7 @@ def add_otp_log(account_id, country, number, service, otp, sms):
     
     broadcast_sse(log_entry)
     save_accounts(accounts)
+    print(f"      📊 OTP LOGGED: {otp}")
     return log_entry
 
 def broadcast_sse(data):
@@ -582,6 +626,7 @@ def generate_otp_rows(logs, search_query):
 @app.route('/add_account', methods=['POST'])
 def add_account_route():
     account_id = str(uuid.uuid4())[:8]
+    print(f"\n➕ TAMBAH AKUN BARU: {request.form['username']}")
     accounts[account_id] = {
         "id": account_id,
         "username": request.form['username'],
@@ -600,33 +645,45 @@ def add_account_route():
         "created_at": time.time()
     }
     save_accounts(accounts)
+    print(f"✅ Akun ditambahkan: {account_id}")
     return redirect('/')
 
 @app.route('/delete_account/<account_id>')
 def delete_account_route(account_id):
     if account_id in accounts:
+        print(f"\n🗑️ HAPUS AKUN: {accounts[account_id]['username']}")
         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):
     if account_id in accounts:
         acc = accounts[account_id]
+        print(f"\n🔐 Mencoba login untuk: {acc['username']}")
         success, msg = login_account(account_id, acc['username'], acc['password'])
+        print(f"📝 Result: {success} - {msg}")
+        
         if success:
-            # Start thread 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}")
+    
     return redirect('/')
 
 @app.route('/logout_account/<account_id>', methods=['POST'])
 def logout_account_route(account_id):
     if account_id in accounts:
+        print(f"\n🔌 LOGOUT: {accounts[account_id]['username']}")
         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')
@@ -647,18 +704,26 @@ def run_account_scraper(account_id):
     if not account:
         return
     
-    print(f"🚀 Starting scraper for {account['username']}")
+    username = account['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 {account['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"):
@@ -668,11 +733,15 @@ def run_account_scraper(account_id):
                 current_count = range_item["count"]
                 prev_count = account["range_counter"].get(rng, 0)
                 
+                print(f"\n  📌 RANGE: {rng} | current: {current_count} | prev: {prev_count}")
+                
                 if current_count > prev_count:
                     country = clean_country(rng)
+                    print(f"  🔥 RANGE BERUBAH: {country} | {prev_count} → {current_count}")
                     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"):
@@ -683,11 +752,15 @@ def run_account_scraper(account_id):
                         key = f"{rng}-{num}"
                         prev_num_count = account["sms_counter"].get(key, 0)
                         
+                        print(f"\n    📱 Nomor: {mask_number(num)} | count: {num_count} | prev: {prev_num_count}")
+                        
                         if num_count > prev_num_count:
+                            print(f"      📨 SMS baru: {prev_num_count} → {num_count}")
                             account["sms_counter"][key] = num_count
                             
                             all_sms = get_sms_fast(account_id, rng, num)
                             new_sms = all_sms[prev_num_count:]
+                            print(f"      📦 Total SMS baru: {len(new_sms)}")
                             
                             for service, sms, otp in new_sms:
                                 if otp:
@@ -695,6 +768,8 @@ 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):
                                             if "sent_cache" not in account:
                                                 account["sent_cache"] = []
@@ -702,42 +777,55 @@ def run_account_scraper(account_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} TERKIRIM!")
                     
                     time.sleep(0.5)
+                else:
+                    print(f"  ⏭️ Range tidak berubah")
             
+            print(f"\n⏳ [{username}] Tidur 2 detik...")
             time.sleep(2)
             
         except Exception as e:
-            print(f"❌ Error in scraper for {account['username']}: {e}")
+            print(f"❌ ERROR in scraper for {username}: {str(e)}")
             time.sleep(5)
+    
+    print(f"\n🛑 SCRAPER STOPPED FOR: {username}")
 
 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("  📋 LOGGING: FULL DETAIL")
     print("="*60 + "\n")
     
-    # Login semua akun yang punya status True
+    print(f"📊 Total akun terload: {len(accounts)}")
+    
     for acc_id, acc in accounts.items():
+        print(f"\n📁 Account: {acc['username']}")
+        print(f"   Status: {'ONLINE' if acc.get('status') else 'OFFLINE'}")
+        
         if acc.get("status"):
+            print(f"   🔄 Mencoba login ulang...")
             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")
+                print(f"   ✅ {acc['username']} online")
             else:
-                print(f"❌ {acc['username']} offline: {msg}")
+                print(f"   ❌ {acc['username']} offline: {msg}")
+                acc["status"] = False
+                save_accounts(accounts)
+    
+    print("\n✅ BOT SIAP! Dashboard: http://localhost:7860")
     
-    # Keep main thread alive
     while True:
         time.sleep(60)