Update app.py

app.py

@@ -160,11 +160,16 @@ def download_engine(link, task_id):
             no_transfer_count = 0
             loop_counter = 0
             
+            # 🔴 ZOMBİ KORUMASI: Senin "Hız düşerse şokla" fikrinin kodlanmış hali
+            previous_output = ""
+            stuck_counter = 0
+            
             while True:
                 time.sleep(5)
                 output = get_mega_details()
                 lower_output = output.lower()
                 
+                # 1. Klasik Limit 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İ! Değiştiriliyor...", flush=True)
                     os.system("pkill mega-get")
@@ -174,6 +179,27 @@ def download_engine(link, task_id):
                         time.sleep(60)
                     break 
                     
+                # 2. Hız Darboğazı ve Zombi Dosya Şoklama (YENİ EKLENEN KISIM)
+                if "active" in lower_output:
+                    # Eğer ekrandaki veri bir önceki saniyeyle tamamen aynıysa (Hız 0'a düştüyse)
+                    if output == previous_output:
+                        stuck_counter += 1
+                        print(f"⚠️ Uyarı: Hız Kesildi! Takılma tespit edildi (Şoka son {6 - stuck_counter} adım)", flush=True)
+                        if stuck_counter >= 6: # 30 Saniye boyunca milim ilerlemediyse
+                            print("\n🧟 ZOMBİ DOSYA VURULDU! Mega hızı kesti, IP'ye şok veriliyor...", flush=True)
+                            os.system("pkill mega-get")
+                            rotate_warp_ip()
+                            safe_mega_reset()
+                            stuck_counter = 0
+                            break # İç döngüyü kırar, taze IP ile mega-get'i tekrar tetikler
+                    else:
+                        # Akış devam ediyorsa sayacı sıfırla
+                        stuck_counter = 0
+                        previous_output = output
+                else:
+                    stuck_counter = 0
+                    
+                # 3. İndirme Bitiş Kontrolü
                 if "no active transfers" in lower_output:
                     loop_counter += 1
                     if loop_counter > 3: 
@@ -188,6 +214,7 @@ def download_engine(link, task_id):
                 else:
                     no_transfer_count = 0
                 
+                # Terminale Temiz Log Basma
                 lines = output.split('\n')
                 for line in lines:
                     if "TRANSFERRING" in line or "%" in line:
@@ -219,7 +246,7 @@ def download_engine(link, task_id):
         
     except Exception as e:
         print(f"🔥 KRİTİK HATA: {e}", flush=True)
-
+        
 @app.route('/process', methods=['POST'])
 def process():
     data = request.json