GitHub Actions deploy 6c3a8a0e7d279ff033ddcb436e68cb29e1155820

core-python/tests/test_huggingface_human_training_space.py

@@ -3,7 +3,9 @@
 from __future__ import annotations
 
 import importlib
+import json
 import sys
+import tempfile
 from pathlib import Path
 
 from fastapi.testclient import TestClient
@@ -87,6 +89,40 @@ def test_register_and_login_flow(monkeypatch, tmp_path: Path) -> None:
     assert login_body["platform"]["examples"]
 
 
+def test_register_with_storage_fallback(monkeypatch) -> None:
+    client = TestClient(human_training_space_app.app)
+    original_users_file = human_training_space_app.USERS_FILE
+    fallback_root = Path(tempfile.gettempdir()) / human_training_space_app.USER_STORE_FALLBACK_DIRNAME
+    fallback_file = fallback_root / original_users_file.name
+    if fallback_file.exists():
+        fallback_file.unlink()
+    original_path_mkdir = Path.mkdir
+
+    def fail_default_data_mkdir(self: Path, *args, **kwargs) -> None:
+        if self == original_users_file.parent:
+            raise PermissionError("read-only")
+        return original_path_mkdir(self, *args, **kwargs)
+
+    monkeypatch.setattr(human_training_space_app, "USERS_FILE", original_users_file)
+    monkeypatch.setattr(Path, "mkdir", fail_default_data_mkdir)
+    human_training_space_app.SESSION_STORE.clear()
+
+    response = client.post(
+        "/api/auth/register",
+        json={
+            "full_name": "Māris Ozols",
+            "email": "maris-fallback@example.com",
+            "password": "drosha-parole-123",
+            "role": "owner",
+        },
+    )
+
+    assert response.status_code == 200
+    assert fallback_file.exists()
+    payload = json.loads(fallback_file.read_text(encoding="utf-8"))
+    assert payload["maris-fallback@example.com"]["role"] == "owner"
+
+
 def test_login_rejects_invalid_password(monkeypatch, tmp_path: Path) -> None:
     client = TestClient(human_training_space_app.app)
     monkeypatch.setattr(

huggingface_human_training_space/app.py

@@ -9,6 +9,7 @@ import os
 import secrets
 import subprocess
 import sys
+import tempfile
 from datetime import UTC, datetime
 from pathlib import Path
 from threading import Lock
@@ -162,9 +163,10 @@ PLATFORM_SECTIONS = {
     ],
 }
 
-LOGO_URL = "https://github.com/MarisUK/maris.ai.human.training/M-Core.png"
+LOGO_URL = "https://github.com/user-attachments/assets/347ded6a-40dc-4991-9cc7-4207cffdf452"
 PERSISTENT_DIR = Path(get_env_any_or_default("MARIS_PERSISTENT_DIR", "HF_PERSISTENT_DIR", default="/data"))
 USERS_FILE = PERSISTENT_DIR / "human-training-users.json"
+USER_STORE_FALLBACK_DIRNAME = "maris-human-training-space"
 TRAIN_SCRIPT = str(REPO_ROOT / "huggingface" / "train-hf.sh")
 LOG_DIR = Path(
     get_env_any_or_default(
@@ -255,24 +257,41 @@ def _timestamp() -> str:
     return datetime.now(UTC).replace(microsecond=0).isoformat()
 
 
-def _ensure_user_store() -> None:
-    USERS_FILE.parent.mkdir(parents=True, exist_ok=True)
-    if not USERS_FILE.exists():
-        USERS_FILE.write_text("{}\n", encoding="utf-8")
+def _resolve_user_store_path() -> Path:
+    try:
+        USERS_FILE.parent.mkdir(parents=True, exist_ok=True)
+    except PermissionError:
+        fallback_root = Path(tempfile.gettempdir()) / USER_STORE_FALLBACK_DIRNAME
+        try:
+            fallback_root.mkdir(parents=True, exist_ok=True)
+        except PermissionError as exc:
+            raise HTTPException(
+                status_code=500,
+                detail="Lietotāju glabātuve nav pieejama ne primārajā, ne rezerves vietā.",
+            ) from exc
+        return fallback_root / USERS_FILE.name
+    return USERS_FILE
+
+
+def _ensure_user_store() -> Path:
+    users_file = _resolve_user_store_path()
+    if not users_file.exists():
+        users_file.write_text("{}\n", encoding="utf-8")
+    return users_file
 
 
 def _load_users() -> dict[str, dict[str, str]]:
-    _ensure_user_store()
+    users_file = _ensure_user_store()
     try:
-        payload = json.loads(USERS_FILE.read_text(encoding="utf-8"))
+        payload = json.loads(users_file.read_text(encoding="utf-8"))
     except json.JSONDecodeError as exc:
         raise HTTPException(status_code=500, detail="Lietotāju glabātuve nav nolasāma.") from exc
     return payload if isinstance(payload, dict) else {}
 
 
 def _save_users(users: dict[str, dict[str, str]]) -> None:
-    _ensure_user_store()
-    USERS_FILE.write_text(json.dumps(users, ensure_ascii=False, indent=2) + "\n", encoding="utf-8")
+    users_file = _ensure_user_store()
+    users_file.write_text(json.dumps(users, ensure_ascii=False, indent=2) + "\n", encoding="utf-8")
 
 
 def _hash_password(password: str, salt_hex: str | None = None) -> tuple[str, str]: