Update app.py

app.py

@@ -7,7 +7,6 @@ import shutil
 import logging
 import requests
 import gc
-import json
 from flask import Flask, request, jsonify
 from huggingface_hub import HfApi
 
@@ -18,18 +17,11 @@ DATASET_REPO = os.environ.get("DATASET_REPO")
 HF_TOKEN = os.environ.get("HF_TOKEN")
 RENDER_URL = os.environ.get("RENDER_URL") 
 ACCOUNTS_FILE = "accounts.txt"
-WARP_PORT = 40000
 
-api = HfApi(token=HF_TOKEN)
-
-# --- YARDIMCI KOMUTLAR ---
-def run_command(cmd):
-    try:
-        return subprocess.run(cmd, shell=True, capture_output=True, text=True)
-    except Exception as e:
-        print(f"⚠️ Komut Hatası: {e}", flush=True)
-        return None
+# Hugging Face token varsa API'yi başlat
+api = HfApi(token=HF_TOKEN) if HF_TOKEN else None
 
+# --- YARDIMCI FONKSİYONLAR ---
 def get_accounts():
     if not os.path.exists(ACCOUNTS_FILE): return []
     with open(ACCOUNTS_FILE, 'r') as f:
@@ -44,54 +36,21 @@ def report_to_render(status, message, task_id, download_url=None):
         }, timeout=10)
     except: pass
 
-# --- GÜVENLİ WARP YÖNETİMİ ---
+# --- TOR VE GİZLİLİK YÖNETİMİ (Ücretsiz Sınırsız IP) ---
 def rotate_warp_ip():
-    """WARP IP'sini güvenli bir şekilde değiştirir (Çökmeden)"""
-    print("\n♻️ IP ROTASYONU BAŞLATILIYOR...", flush=True)
+    """Tor ağını yeniden başlatarak yepyeni bir IP (Çıkış Düğümü) alır"""
+    print("\n🧅 TOR AĞI: Yeni IP aranıyor...", flush=True)
     try:
-        os.system("pkill wireproxy")
-        os.system("pkill wgcf")
+        os.system("pkill tor")
         time.sleep(2)
+        subprocess.Popen(["tor"], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
         
-        for f in ["wgcf-account.toml", "wgcf-profile.conf", "wireproxy.conf"]:
-            if os.path.exists(f): 
-                try: os.remove(f)
-                except: pass
-        
-        print("⚡ Cloudflare ile görüşülüyor...", flush=True)
-        subprocess.run(["wgcf", "register", "--accept-tos"], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL, timeout=30)
-        subprocess.run(["wgcf", "generate"], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL, timeout=30)
-        
-        if not os.path.exists("wgcf-profile.conf"):
-            print("❌ WARP Config alınamadı!", flush=True)
-            return False
-            
-        with open("wgcf-profile.conf", "r") as f:
-            content = f.read()
-            
-        private_key = content.split("PrivateKey = ")[1].split("\n")[0].strip()
-        address = content.split("Address = ")[1].split("\n")[0].strip()
-        
-        wp_conf = f"""[Interface]
-PrivateKey = {private_key}
-Address = {address}
-DNS = 1.1.1.1
-[Peer]
-PublicKey = bmXOC+F1FxEMF9dyiK2H5/1SUtzH0JuVo51h2wPfgyo=
-AllowedIPs = 0.0.0.0/0
-Endpoint = engage.cloudflareclient.com:2408
-[Socks5]
-BindAddress = 127.0.0.1:{WARP_PORT}"""
-
-        with open("wireproxy.conf", "w") as f:
-            f.write(wp_conf)
-            
-        print(f"🚀 Tünel Açılıyor...", flush=True)
-        subprocess.Popen(["wireproxy", "-c", "wireproxy.conf"], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
-        time.sleep(5)
+        print("⏳ Tor devresinin kurulması bekleniyor (15 sn)...", flush=True)
+        time.sleep(15) 
+        print("🚀 TOR Tüneli Hazır! Yeni Kimlik Aktif.", flush=True)
         return True
     except Exception as e:
-        print(f"❌ IP Rotasyonunda Hata: {e}", flush=True)
+        print(f"❌ Tor Başlatma Hatası: {e}", flush=True)
         return False
 
 def safe_mega_reset():
@@ -106,13 +65,13 @@ def safe_mega_reset():
 def login_with_proxy(account_str):
     try:
         email, password = account_str.split(":", 1)
-        proxy_url = f"socks5://127.0.0.1:{WARP_PORT}"
+        
+        proxy_url = "socks5://127.0.0.1:9050"
         subprocess.run(["mega-proxy", proxy_url], capture_output=True)
         
-        # --- EKLENEN KRİTİK KISIM: ZORLA ÇIKIŞ (LOGOUT) ---
+        # ESKİ HESABI ZORLA DIŞARI ATMA (Zincirleme patlamayı önler)
         subprocess.run(["mega-logout"], capture_output=True, stderr=subprocess.DEVNULL)
         time.sleep(2)
-        # --------------------------------------------------
         
         print(f"🔑 Giriş Deneniyor: {email[:3]}***", flush=True)
         res = subprocess.run(["mega-login", email, password], capture_output=True, text=True, timeout=45)
@@ -132,6 +91,7 @@ def get_mega_details():
         return res.stdout.strip()
     except: return ""
 
+# --- ANA İNDİRME MOTORU ---
 def download_engine(link, task_id):
     try:
         print(f"\n⚙️ WORKER BAŞLADI: {task_id}", flush=True)
@@ -144,7 +104,10 @@ def download_engine(link, task_id):
         accounts = get_accounts()
         random.shuffle(accounts)
         
-        if not accounts: return
+        if not accounts: 
+            print("❌ HATA: accounts.txt boş veya bulunamadı!", flush=True)
+            return
+        
         is_completed = False
         
         safe_mega_reset()
@@ -166,7 +129,6 @@ def download_engine(link, task_id):
             no_transfer_count = 0
             loop_counter = 0
             
-           # 🔴 ZOMBİ VE HIZ KORUMASI V3 (Acımasız Mod)
             previous_active_transfers = []
             stuck_counter = 0
             
@@ -176,9 +138,9 @@ def download_engine(link, task_id):
                 lower_output = output.lower()
                 lines = output.split('\n')
                 
-                # 1. Klasik Limit ve Ban Kontrolü
+                # 1. Kota ve Ban Kontrolü
                 if "bandwidth quota exceeded" in lower_output or "paused" in lower_output or "retrying" in lower_output:
-                    print("\n🚨 KOTA/IP BAN TESPİT EDİLDİ! Tünel Değiştiriliyor...", flush=True)
+                    print("\n🚨 KOTA TESPİT EDİLDİ! Tor Kimliği Değiştiriliyor...", flush=True)
                     os.system("pkill mega-get")
                     if rotate_warp_ip():
                         safe_mega_reset()
@@ -186,30 +148,27 @@ def download_engine(link, task_id):
                         time.sleep(60)
                     break 
                     
-                # 2. V3 Zombi ve Hız Koruması (Tamamen Harf ve Rakam Kontrolü)
-                # Sadece ACTIVE olan satırları bul ve listele
+                # 2. V3 Zombi ve Hız Koruması (Acımasız Mod)
                 current_active_transfers = [line for line in lines if "ACTIVE" in line]
                 
                 if current_active_transfers:
-                    # Eğer ACTIVE olan indirmeler bir önceki saniyeyle HARFİ HARFİNE aynıysa (Yani 1 KB bile inmediyse veya 100%'de takıldıysa)
                     if current_active_transfers == previous_active_transfers:
                         stuck_counter += 1
-                        print(f"⚠️ HIZ SIFIR VEYA 100% BUG'I! (Tüneli patlatmaya son {6 - stuck_counter} adım)", flush=True)
-                        if stuck_counter >= 6: # 30 Saniye tık yoksa acıma
-                            print("\n💥 SİSTEM TIKANDI! Mega'nın kafasına sıkılıp Tünel değiştiriliyor...", flush=True)
+                        print(f"⚠️ HIZ SIFIR VEYA ZOMBİ BUG! (Tor'u patlatmaya son {6 - stuck_counter} adım)", flush=True)
+                        if stuck_counter >= 6:
+                            print("\n💥 SİSTEM TIKANDI! Mega'nın kafasına sıkılıp yeni Tor IP alınıyor...", flush=True)
                             os.system("pkill mega-get")
                             rotate_warp_ip()
                             safe_mega_reset()
                             stuck_counter = 0
-                            break # Tüneli yeniler ve mega-get'i taze iple tetikler
+                            break
                     else:
-                        # Eğer 1 KB bile indiyse rakam değişeceği için sayacı sıfırla
                         stuck_counter = 0
                         previous_active_transfers = current_active_transfers
                 else:
                     stuck_counter = 0
                     
-                # 3. İndirme Bitiş Kontrolü
+                # 3. Bitiş Kontrolü
                 if "no active transfers" in lower_output:
                     loop_counter += 1
                     if loop_counter > 3: 
@@ -224,7 +183,7 @@ def download_engine(link, task_id):
                 else:
                     no_transfer_count = 0
                 
-                # Terminale Temiz Log Basma
+                # Log Basma
                 for line in lines:
                     if "TRANSFERRING" in line or "%" in line:
                         print(f"📊 {line.strip()}", flush=True)
@@ -239,13 +198,16 @@ def download_engine(link, task_id):
         shutil.make_archive(f"{abs_base}/{task_id}", 'zip', download_folder)
         
         print("📤 YÜKLENİYOR...", flush=True)
-        try:
-            api.upload_file(
-                path_or_fileobj=zip_file, repo_id=DATASET_REPO, repo_type="dataset", path_in_repo=f"uploads/{task_id}.zip"
-            )
-            print("✅ HUGGING FACE YÜKLEMESİ BAŞARILI!")
-        except Exception as e:
-            print(f"❌ Upload Hatası: {e}", flush=True)
+        if api:
+            try:
+                api.upload_file(
+                    path_or_fileobj=zip_file, repo_id=DATASET_REPO, repo_type="dataset", path_in_repo=f"uploads/{task_id}.zip"
+                )
+                print("✅ HUGGING FACE YÜKLEMESİ BAŞARILI!")
+            except Exception as e:
+                print(f"❌ Upload Hatası: {e}", flush=True)
+        else:
+            print("⚠️ HF_TOKEN bulunamadı, Hugging Face yüklemesi atlandı.")
             
         try:
             shutil.rmtree(download_folder, ignore_errors=True)
@@ -255,7 +217,8 @@ def download_engine(link, task_id):
         
     except Exception as e:
         print(f"🔥 KRİTİK HATA: {e}", flush=True)
-        
+
+# --- WEB ARAYÜZÜ (PANEL) ---
 @app.route('/process', methods=['POST'])
 def process():
     data = request.json
@@ -267,7 +230,7 @@ def ui():
     return """
     <html>
         <body style="background-color: #1e1e1e; color: white; font-family: sans-serif; text-align: center; padding-top: 50px;">
-            <h2>Yael Mega-Worker Paneli 🚀</h2>
+            <h2>Yael Mega-Worker (Tor Edition) 🚀</h2>
             <div style="margin: 20px;">
                 <input id="mega_link" type="text" placeholder="Mega.nz Linkini Buraya Yapıştır..." style="width: 80%; max-width: 500px; padding: 15px; border-radius: 8px; border: none; margin-bottom: 10px;"/><br>
                 <input id="task_id" type="text" placeholder="Görev Adı (Örn: arsiv_1 - Boşluk Bırakma)" style="width: 80%; max-width: 500px; padding: 15px; border-radius: 8px; border: none; margin-bottom: 20px;"/><br>