Update app.py

app.py

@@ -23,7 +23,6 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-# Arka plandaki görevleri takip edeceğimiz hafıza sözlüğü
 jobs = {}
 
 def process_repack(job_id: str, asset_path: str, zip_path: str, original_filename: str):
@@ -48,16 +47,15 @@ def process_repack(job_id: str, asset_path: str, zip_path: str, original_filenam
 
         for obj in env.objects:
             processed += 1
-            # Her 50 objede bir hızı ölç ve ETA (Kalan Süre) hesapla
             if processed % 50 == 0:
                 elapsed = time.time() - start_time
                 rate = processed / elapsed if elapsed > 0 else 1
                 remaining_seconds = int((total_objects - processed) / rate)
-                prog = 5 + int((processed / total_objects) * 45) # İlk aşama %5 ile %50 arası sürer
+                prog = 5 + int((processed / total_objects) * 45)
                 
                 jobs[job_id].update({
                     "progress": prog,
-                    "message": f"Diyaloglar yamalanıyor... (Kalan Süre: ~{remaining_seconds} saniye)"
+                    "message": f"Diyaloglar yamalanıyor... (Kalan Süre: ~{remaining_seconds} sn)"
                 })
 
             if obj.type.name in ["TextAsset", "MonoBehaviour"]:
@@ -82,24 +80,42 @@ def process_repack(job_id: str, asset_path: str, zip_path: str, original_filenam
                             patched_data = patched_data.replace(orig_block, trans_block)
                         obj.set_raw_data(bytes(patched_data))
 
-        # En ağır kısma geçiliyor: Orijinal boyuta sıkıştırma (LZMA)
         jobs[job_id].update({
             "progress": 60, 
-            "message": "Orijinal boyuta (LZMA) sıkıştırılıyor. Sunucu hızına göre 1-3 dakika sürebilir, bağlantınız kopmayacak..."
+            "message": "Sıkıştırma algoritmaları deneniyor... (Sunucu hızına göre 1-3 dakika sürebilir)"
         })
         
         output_path = os.path.join(tempfile.gettempdir(), f"repacked_{job_id}_{original_filename}")
-        with open(output_path, "wb") as f:
+        
+        compression_error = ""
+        try:
+            # 1. Deneme: Modern UnityPy String Formatı (LZMA)
+            packed_data = env.file.save(packer="lzma")
+        except Exception as e1:
             try:
-                # 300 MB'ı 20 MB'a düşüren asıl kod:
-                f.write(env.file.save(packer=CompressionFlags.LZMA))
-            except Exception:
-                f.write(env.file.save())
+                # 2. Deneme: Daha hızlı olan LZ4 Formatı
+                packed_data = env.file.save(packer="lz4")
+            except Exception as e2:
+                try:
+                    # 3. Deneme: Eski Sürüm UnityPy Enum Formatı
+                    packed_data = env.file.save(packer=CompressionFlags.LZMA)
+                except Exception as e3:
+                    # HİÇBİRİ İŞE YARAMAZSA HATAYI EKRANA YANSIT
+                    compression_error = f"LZMA_Str: {str(e1)} | LZ4_Str: {str(e2)} | Enum: {str(e3)}"
+                    packed_data = env.file.save()
+                    
+        with open(output_path, "wb") as f:
+            f.write(packed_data)
+
+        if compression_error:
+            final_msg = f"Dosya hazırlandı AMA Sıkıştırılamadı! Hata Logu: {compression_error}"
+        else:
+            final_msg = "İşlem %100 Tamamlandı ve Orijinal Boyuta Sıkıştırıldı! Dosya İndiriliyor..."
 
         jobs[job_id].update({
             "status": "completed",
             "progress": 100,
-            "message": "İşlem %100 Tamamlandı! Dosya İndiriliyor...",
+            "message": final_msg,
             "file_path": output_path,
             "filename": original_filename
         })
@@ -108,11 +124,10 @@ def process_repack(job_id: str, asset_path: str, zip_path: str, original_filenam
         jobs[job_id].update({"status": "error", "message": f"Kritik Hata: {str(e)}"})
 
 
-# --------- YENİ API UÇ NOKTALARI (ENDPOINTS) ---------
+# --------- API UÇ NOKTALARI (ENDPOINTS) ---------
 
 @app.post("/generate_dll")
 async def generate_dll(binary_file: UploadFile = File(...), metadata_file: UploadFile = File(...)):
-    # Bu kısmı dokunmadık, aynı duruyor
     temp_dir = tempfile.mkdtemp()
     binary_path = os.path.join(temp_dir, binary_file.filename)
     metadata_path = os.path.join(temp_dir, metadata_file.filename)
@@ -130,7 +145,6 @@ async def generate_dll(binary_file: UploadFile = File(...), metadata_file: Uploa
 
 @app.post("/extract")
 async def extract_dialogues(file: UploadFile = File(...), assembly_file: Optional[UploadFile] = File(None)):
-    # Bu kısmı dokunmadık, aynı duruyor
     temp_dir = tempfile.mkdtemp()
     asset_path = os.path.join(temp_dir, file.filename)
     with open(asset_path, "wb") as f: f.write(await file.read())
@@ -169,7 +183,6 @@ async def extract_dialogues(file: UploadFile = File(...), assembly_file: Optiona
                     except: pass
     return FileResponse(zip_filename, media_type="application/zip", filename=f"{file.filename}_dialogues.zip")
 
-# ARKA PLAN GÖREVİ BAŞLATICISI
 @app.post("/repack_async")
 async def repack_async(background_tasks: BackgroundTasks, asset_file: UploadFile = File(...), mod_zip: UploadFile = File(...)):
     job_id = str(uuid.uuid4())
@@ -177,27 +190,20 @@ async def repack_async(background_tasks: BackgroundTasks, asset_file: UploadFile
     asset_path = os.path.join(temp_dir, asset_file.filename)
     zip_path = os.path.join(temp_dir, mod_zip.filename)
     
-    # Dosyaları hızlıca diske al ve isteği hemen geri döndür ki 60 saniye sorunu yaşanmasın
     with open(asset_path, "wb") as f: f.write(await asset_file.read())
     with open(zip_path, "wb") as f: f.write(await mod_zip.read())
     
-    # Gerçek işi arka plandaki isimsiz bir hayalete devret
     background_tasks.add_task(process_repack, job_id, asset_path, zip_path, asset_file.filename)
     jobs[job_id] = {"status": "queued", "progress": 0, "message": "İşlem sıraya alındı, başlıyor..."}
-    
     return {"job_id": job_id}
 
-# DURUM KONTROLCÜSÜ (Yüzde ve Süre Buradan Okunur)
 @app.get("/status/{job_id}")
 async def get_status(job_id: str):
-    if job_id not in jobs:
-        return JSONResponse(status_code=404, content={"error": "Görev bulunamadı"})
+    if job_id not in jobs: return JSONResponse(status_code=404, content={"error": "Görev bulunamadı"})
     return jobs[job_id]
 
-# İNDİRME UÇ NOKTASI
 @app.get("/download/{job_id}")
 async def download_file(job_id: str):
     job = jobs.get(job_id)
-    if not job or job.get("status") != "completed":
-        return JSONResponse(status_code=400, content={"error": "Dosya henüz hazır değil"})
+    if not job or job.get("status") != "completed": return JSONResponse(status_code=400, content={"error": "Dosya hazır değil"})
     return FileResponse(job["file_path"], media_type="application/octet-stream", filename=job["filename"])