Update app.py

app.py

@@ -2,10 +2,10 @@ import os
 import json
 import uuid
 from datetime import datetime, timezone
-from pathlib import Path
+from io import BytesIO
 
 import gradio as gr
-from huggingface_hub import CommitScheduler
+from huggingface_hub import HfApi
 
 HF_TOKEN = os.environ.get("HF_TOKEN")
 if not HF_TOKEN:
@@ -16,18 +16,7 @@ if not HF_TOKEN:
     )
 
 DATASET_REPO_ID = "Mati83moni/quantization-requests"
-LOCAL_DIR = Path("intake_data")
-LOCAL_DIR.mkdir(exist_ok=True)
-LOCAL_FILE = LOCAL_DIR / "requests.jsonl"
-
-scheduler = CommitScheduler(
-    repo_id=DATASET_REPO_ID,
-    repo_type="dataset",
-    folder_path=LOCAL_DIR,
-    path_in_repo="data",
-    every=2,
-    token=HF_TOKEN,
-)
+api = HfApi(token=HF_TOKEN)
 
 VALID_FORMATS = ["GGUF", "AWQ", "EXL3"]
 
@@ -48,8 +37,9 @@ def submit_request(model_link: str, quant_format: str, contact_email: str, notes
     if "@" not in contact_email or "." not in contact_email.split("@")[-1]:
         return gr.update(value="❌ Podaj prawidłowy adres e-mail kontaktowy.", visible=True)
 
+    record_id = str(uuid.uuid4())
     record = {
-        "id": str(uuid.uuid4()),
+        "id": record_id,
         "submitted_at_utc": datetime.now(timezone.utc).isoformat(),
         "model_link": model_link,
         "format": quant_format,
@@ -58,9 +48,21 @@ def submit_request(model_link: str, quant_format: str, contact_email: str, notes
         "status": "new",
     }
 
-    with scheduler.lock:
-        with LOCAL_FILE.open("a", encoding="utf-8") as f:
-            f.write(json.dumps(record, ensure_ascii=False) + "\n")
+    payload = json.dumps(record, ensure_ascii=False, indent=2).encode("utf-8")
+
+    try:
+        api.upload_file(
+            path_or_fileobj=BytesIO(payload),
+            path_in_repo=f"data/{record_id}.json",
+            repo_id=DATASET_REPO_ID,
+            repo_type="dataset",
+            commit_message=f"New request from {contact_email}",
+        )
+    except Exception as e:
+        return gr.update(
+            value=f"❌ Błąd zapisu zgłoszenia, spróbuj ponownie za chwilę. ({type(e).__name__})",
+            visible=True,
+        )
 
     return gr.update(
         value="✅ Zgłoszenie przyjęte. Odezwę się na podany e-mail w ciągu 24h z wyceną i terminem.",