Update bot.py

bot.py

@@ -1,63 +1,112 @@
-import requests
 import gradio as gr
-import threading
+import subprocess
+import os
 import time
+import requests
 
-def jalankan_bot_anda():
-    # Ini adalah simulasi dari sistem bot Anda.
-    # Di sini kita buktikan bahwa Port 10801 s/d 10850 masing-masing
-    # tersambung secara persisten ke WARP yang berbeda.
-    
-    hasil_log = []
-    print("\n[*] Bot mulai memeriksa 50 koneksi persisten...")
-    
-    for i in range(1, 51):
-        port_persisten = 10800 + i
-        proxy = {
-            "http": f"socks5://127.0.0.1:{port_persisten}",
-            "https": f"socks5://127.0.0.1:{port_persisten}"
-        }
+def uji_warp_via_rotator(tipe_proxy, host, port, user, password):
+    log = []
+    log.append("==========================================")
+    log.append(f"[*] MEMULAI EKSPERIMEN: WARP -> ROTATOR {host}")
+    log.append("==========================================")
+
+    # 1. Bersihkan file lama
+    for f in ["proxychains.conf", "wgcf-account.toml", "wgcf-profile.conf", "wireproxy.conf"]:
+        if os.path.exists(f):
+            os.remove(f)
+
+    # 2. Merakit proxychains.conf dengan proxy Dataheaven Anda
+    tipe = "socks5" if tipe_proxy == "SOCKS5" else "http"
+    auth = f"{user} {password}" if user and password else ""
+    conf_str = f"""strict_chain
+proxy_dns
+remote_dns_subnet 224
+tcp_read_time_out 15000
+tcp_connect_time_out 8000
+[ProxyList]
+{tipe} {host} {port} {auth}
+"""
+    with open("proxychains.conf", "w") as f:
+        f.write(conf_str)
+
+    log.append(f"[*] Proxychains Siap! Jalur: VPS HF -> {tipe.upper()} {host}:{port} -> Cloudflare")
+
+    # 3. Mendaftar ke Cloudflare
+    log.append("[*] Meminta konfigurasi WARP ke Cloudflare...")
+    subprocess.run(["wgcf", "register", "--accept-tos"], capture_output=True)
+    subprocess.run(["wgcf", "generate"], capture_output=True)
+
+    if not os.path.exists("wgcf-profile.conf"):
+        log.append("[-] GAGAL: Terkena Rate Limit Cloudflare (Atau Rotator gagal tembus).")
+        return "\n".join(log)
+
+    # 4. Set local port untuk bot Python
+    with open("wgcf-profile.conf", "r") as f:
+        warp_conf = f.read()
+    with open("wireproxy.conf", "w") as f:
+        f.write(warp_conf)
+        f.write("\n[Socks5]\nBindAddress = 127.0.0.1:10888\n")
+
+    # 5. MENJALANKAN EKSPERIMEN
+    log.append("[*] Mengeksekusi WARP (UDP) dibungkus menembus Rotator Dataheaven...")
+    process = subprocess.Popen(
+        ["proxychains4", "-f", "proxychains.conf", "wireproxy", "-c", "wireproxy.conf"],
+        stdout=subprocess.PIPE,
+        stderr=subprocess.PIPE,
+        text=True
+    )
+
+    log.append("[*] Menunggu 15 detik agar terowongan Handshake terbentuk...")
+    time.sleep(15)
+
+    # 6. Test Koneksi Bot
+    log.append("[*] Bot Python mencoba menembus koneksi...")
+    proxies = {
+        "http": "socks5://127.0.0.1:10888",
+        "https": "socks5://127.0.0.1:10888"
+    }
+
+    try:
+        # Tembak IP Checker
+        res = requests.get("https://api.ipify.org?format=json", proxies=proxies, timeout=15)
+        log.append("\n[+++] HASIL EKSPERIMEN: BERHASIL SANGAT SEMPURNA! [+++]")
+        log.append(f"      IP Keluar Anda: {res.json()['ip']}")
+        log.append("      Teori Anda terbukti bisa diimplementasikan!")
+    except Exception as e:
+        log.append("\n[---] HASIL EKSPERIMEN: GAGAL / TIMEOUT [---]")
+        log.append(f"      Error Bot: {str(e)}")
+        log.append("\n[!] KESIMPULAN TEKNIS:")
+        log.append("    Ini membuktikan bahwa Rotator Proxy Dataheaven memblokir/mengabaikan")
+        log.append("    paket UDP yang dibutuhkan oleh protokol WireGuard Cloudflare.")
         
-        try:
-            # Bot Anda melakukan request menggunakan port akun spesifik
-            res = requests.get("https://api.ipify.org?format=json", proxies=proxy, timeout=10)
-            ip_publik = res.json()['ip']
-            log_msg = f"[+] Bot Akun {i} (Via Port {port_persisten}) -> IP WARP Keluar: {ip_publik}"
-            print(log_msg)
-            hasil_log.append(log_msg)
-        except Exception as e:
-            log_msg = f"[-] Bot Akun {i} (Via Port {port_persisten}) -> Proxy Error/Timeout"
-            print(log_msg)
-            hasil_log.append(log_msg)
-            
-    return "\n".join(hasil_log)
-
-# Variabel penyimpan hasil sementara
-output_layar = "Tunggu sekitar 5-10 menit saat booting awal (Anti Rate-Limit sedang bekerja merakit 50 akun)...\n\nSilakan refresh tombol di bawah nanti."
-
-def proses_background():
-    global output_layar
-    # Beri jeda 10 detik agar wireproxy di bash stabil, lalu jalankan bot
-    time.sleep(10)
-    output_layar = jalankan_bot_anda()
-
-# Jalankan bot di latar belakang agar antarmuka web Hugging Face tidak freeze
-threading.Thread(target=proses_background, daemon=True).start()
-
-def refresh_status():
-    return output_layar
-
-# ========================================================
-# WAJIB ADA UNTUK HUGGING FACE (Dummy Web Server Port 7860)
-# ========================================================
-with gr.Blocks(title="Status Bot Persistent") as demo:
-    gr.Markdown("# 🤖 Status 50 SOCKS5 Persistent Port")
-    gr.Markdown("Bot berjalan mandiri di background. 1 Port didedikasikan untuk 1 Akun tanpa rotasi.")
+        # Ambil log asli dari terminal proxychains
+        process.terminate()
+        out, err = process.communicate()
+        log.append("\n--- Log Asli Terminal Proxychains ---")
+        log.append(err[-600:] if err else "Tidak ada output error spesifik dari proxychains.") 
+
+    if process.poll() is None:
+        process.terminate()
+
+    return "\n".join(log)
+
+with gr.Blocks(title="Lab Uji Coba: WARP via Rotator") as demo:
+    gr.Markdown("# 🧪 Lab Uji Coba: WARP via Proxy Dataheaven")
+    gr.Markdown("Kredensial sudah terisi otomatis. Langsung klik eksekusi untuk membuktikan!")
     
-    layar_log = gr.Textbox(label="Laporan IP Keluar per Akun", lines=25, value=output_layar)
-    btn_refresh = gr.Button("🔄 Cek Status IP Terkini", variant="primary")
+    with gr.Row():
+        # Secara default biasanya rotator premium mendukung SOCKS5, tapi bisa diubah ke HTTP di UI jika SOCKS5 gagal.
+        tipe = gr.Radio(["SOCKS5", "HTTP"], label="Tipe Proxy", value="SOCKS5")
+        host = gr.Textbox(label="IP / Host Rotator", value="edge1-us.dataheaven.ai")
+        port = gr.Textbox(label="Port Rotator", value="8888")
+        
+    with gr.Row():
+        user = gr.Textbox(label="Username Proxy", value="oy9jb-id")
+        pwd = gr.Textbox(label="Password Proxy", value="e8ij1r8u", type="password")
+        
+    btn = gr.Button("🚀 Eksekusi Uji Coba Sekarang!", variant="primary")
+    layar_log = gr.Textbox(label="Terminal Hasil Eksperimen", lines=25)
     
-    btn_refresh.click(refresh_status, outputs=[layar_log])
+    btn.click(uji_warp_via_rotator, inputs=[tipe, host, port, user, pwd], outputs=[layar_log])
 
-# Launch di 0.0.0.0 agar Hugging Face bisa mem-passing health check
 demo.launch(server_name="0.0.0.0", server_port=7860)