Update translator_runner.py

translator_runner.py

@@ -45,7 +45,7 @@ import subprocess
 import tempfile
 import time
 import zipfile
-from dataclasses import dataclass, field
+from dataclasses import asdict, dataclass, field
 from pathlib import Path
 from typing import Callable, Optional
 
@@ -57,6 +57,50 @@ MT_TIMEOUT = int(os.environ.get("MT_TIMEOUT", "600"))
 
 ALLOWED_ENGINES = ("local_llm", "google", "openai", "deepseek", "libretranslate", "custom")
 
+# Sekme kapatılıp geri açıldığında (ya da Space yeniden başladığında) son
+# işin durumunu okuyabilmek için basit bir diske-yazma kalıcılığı. Sadece
+# TEK bir "son iş" tutuyoruz (tek kullanıcı senaryosu için yeterli) —
+# çoklu iş geçmişi gerekmiyor.
+_JOB_STATE_FILE = os.path.join(tempfile.gettempdir(), "rlmt_current_job.json")
+
+
+def save_job_state(job: "TranslationJob") -> None:
+    """
+    Job durumunu diske yazar. Her önemli güncellemede (durum değişimi,
+    ilerleme, log satırı) çağrılır — sekme kapatılsa/yenilense bile son
+    bilinen durum kaybolmasın diye. Yazma hatası sessizce yutulur (bu
+    özellik best-effort'tur, ana akışı bloklamamalı).
+    """
+    try:
+        with open(_JOB_STATE_FILE, "w", encoding="utf-8") as f:
+            json.dump(asdict(job), f, ensure_ascii=False)
+    except OSError:
+        pass
+
+
+def load_job_state() -> Optional["TranslationJob"]:
+    """
+    Diskte kayıtlı son job durumunu okur. Dosya yoksa veya bozuksa None
+    döner. Gradio arayüzü açılışta bunu çağırıp "hâlâ çalışan/tamamlanmış
+    bir iş var mı" diye kontrol eder.
+    """
+    if not os.path.isfile(_JOB_STATE_FILE):
+        return None
+    try:
+        with open(_JOB_STATE_FILE, "r", encoding="utf-8") as f:
+            data = json.load(f)
+        return TranslationJob(**data)
+    except (OSError, json.JSONDecodeError, TypeError):
+        return None
+
+
+def clear_job_state() -> None:
+    """Kayıtlı job durumunu siler (kullanıcı yeni bir iş başlattığında)."""
+    try:
+        os.remove(_JOB_STATE_FILE)
+    except OSError:
+        pass
+
 
 @dataclass
 class TranslationJob:
@@ -239,15 +283,21 @@ def run_translation(
     RenLocalizer'ı senkron olarak çalıştırır (Gradio callback'i içinde
     çağrılır — Gradio kendi tarafında bu fonksiyonu bir thread/worker'da
     yürütür). on_log her yeni log satırında çağrılır (canlı akış için).
+
+    Her önemli durum değişikliğinde save_job_state() çağrılır — sekme
+    kapatılıp geri açıldığında (ya da Space yeniden başladığında) son
+    bilinen durum diskten okunabilsin diye.
     """
     job.status = "running"
     job.started_at = time.time()
+    save_job_state(job)
 
     run_cli_path = os.path.join(RENLOCALIZER_DIR, "run_cli.py")
     if not os.path.isfile(run_cli_path):
         job.status = "failed"
         job.error_summary = f"RenLocalizer bulunamadı: {run_cli_path}"
         on_log(job.error_summary)
+        save_job_state(job)
         return job
 
     if job.engine not in ALLOWED_ENGINES:
@@ -290,9 +340,11 @@ def run_translation(
         job.status = "failed"
         job.error_summary = f"Süreç başlatılamadı: {exc}"
         on_log(job.error_summary)
+        save_job_state(job)
         return job
 
     assert process.stdout is not None
+    line_count_since_save = 0
     for line in process.stdout:
         line = line.rstrip("\n")
         if not line:
@@ -306,6 +358,15 @@ def run_translation(
             if total > 0:
                 job.progress_percent = min(100, round((current / total) * 100))
 
+        # Her satırda disk yazmak gereksiz I/O yaratır (RenLocalizer
+        # binlerce satır üretebiliyor) — periyodik olarak kaydediyoruz,
+        # yeterince sık ki sekme yeniden açıldığında güncel bir durum
+        # görünsün.
+        line_count_since_save += 1
+        if line_count_since_save >= 10:
+            save_job_state(job)
+            line_count_since_save = 0
+
     process.wait()
     job.finished_at = time.time()
 
@@ -329,6 +390,7 @@ def run_translation(
         job.error_summary = f"Çeviri başarısız: {reason}"
         on_log(job.error_summary)
 
+    save_job_state(job)
     return job