ledger falls back when no persistent storage

app/ledger.py

@@ -1,129 +1,149 @@
-# -*- coding: utf-8 -*-
-"""원장 — 참가자·포지션·점수를 담는다.
-
-파일 기반이다. HF Space 재시작 시 사라지므로 운영에서는 외부 저장소로 옮긴다.
-지금은 구조를 확정하는 게 목적이고, 저장 위치만 바꾸면 되도록 인터페이스를 좁게 둔다.
-
-🔴 포지션은 절대 덮어쓰지 않는다. 매 제출을 append 한다.
-   덮어쓰면 "언제 무엇을 냈는가"가 사라지고, 그게 사라지면 채점을 재현할 수 없다.
-"""
-import os, json, time, hashlib, threading
-from datetime import datetime, timezone
-
-ROOT = os.environ.get("FINCHAL_DATA", os.path.join(os.path.dirname(__file__), "_data"))
-LOCK = threading.Lock()
-
-
-def _p(*a):
-    p = os.path.join(ROOT, *a)
-    os.makedirs(os.path.dirname(p), exist_ok=True)
-    return p
-
-
-def now():
-    return datetime.now(timezone.utc).replace(microsecond=0)
-
-
-def _read(path, default):
-    try:
-        with open(path, encoding="utf-8") as f:
-            return json.load(f)
-    except Exception:
-        return default
-
-
-def _write(path, obj):
-    tmp = path + ".tmp"
-    with open(tmp, "w", encoding="utf-8") as f:
-        json.dump(obj, f, ensure_ascii=False)
-    os.replace(tmp, path)          # 원자적 교체 — 중간에 죽어도 반쪽 파일이 안 남는다
-
-
-# ─────────────────────── 참가자 ───────────────────────
-def make_key(user_id):
-    raw = "%s|%s|finchal" % (user_id, os.environ.get("FINCHAL_SALT", "s1"))
-    return "fc_" + hashlib.sha256(raw.encode()).hexdigest()[:24]
-
-
-def register(user_id, strategy, ptype, assets):
-    """참가 등록. 이미 있으면 전략명·유형만 갱신하고 키는 유지한다."""
-    with LOCK:
-        u = _read(_p("users.json"), {})
-        key = make_key(user_id)
-        prev = u.get(user_id, {})
-        u[user_id] = {
-            "user": user_id, "key": key, "strategy": strategy, "type": ptype,
-            "assets": sorted(set(assets)),
-            "joined": prev.get("joined", now().isoformat()),
-            "visits": prev.get("visits", []),
-        }
-        _write(_p("users.json"), u)
-        return u[user_id]
-
-
-def user_by_key(key):
-    for v in _read(_p("users.json"), {}).values():
-        if v.get("key") == key:
-            return v
-    return None
-
-
-def touch(user_id):
-    """접속 기록 — 사람 부문의 '주 1회 접속' 요건 판정에 쓴다."""
-    with LOCK:
-        u = _read(_p("users.json"), {})
-        if user_id in u:
-            v = u[user_id].setdefault("visits", [])
-            d = now().date().isoformat()
-            if not v or v[-1] != d:
-                v.append(d)
-                v[:] = v[-400:]
-                _write(_p("users.json"), u)
-
-
-def all_users():
-    return list(_read(_p("users.json"), {}).values())
-
-
-# ─────────────────────── 포지션 ───────────────────────
-def submit(user_id, asset, position, source="api"):
-    """포지션 제출. 덮어쓰지 않고 줄 단위로 쌓는다."""
-    pos = max(-1.0, min(1.0, float(position)))
-    rec = {"t": now().isoformat(), "u": user_id, "a": asset,
-           "p": pos, "src": source}
-    with LOCK:
-        with open(_p("positions", "%s.jsonl" % asset), "a", encoding="utf-8") as f:
-            f.write(json.dumps(rec, ensure_ascii=False) + "\n")
-    touch(user_id)
-    return rec
-
-
-def positions(asset, user_id=None):
-    out = []
-    p = _p("positions", "%s.jsonl" % asset)
-    if not os.path.exists(p):
-        return out
-    with open(p, encoding="utf-8") as f:
-        for line in f:
-            try:
-                r = json.loads(line)
-            except Exception:
-                continue
-            if user_id is None or r.get("u") == user_id:
-                out.append(r)
-    return out
-
-
-def latest(asset, user_id):
-    ps = positions(asset, user_id)
-    return ps[-1] if ps else None
-
-
-# ─────────────────────── 점수 스냅샷 ───────────────────────
-def save_scores(asset, rows):
-    _write(_p("scores", "%s.json" % asset),
-           {"at": now().isoformat(), "rows": rows})
-
-
-def load_scores(asset):
-    return _read(_p("scores", "%s.json" % asset), {"at": None, "rows": []})
+# -*- coding: utf-8 -*-
+"""원장 — 참가자·포지션·점수를 담는다.
+
+파일 기반이다. HF Space 재시작 시 사라지므로 운영에서는 외부 저장소로 옮긴다.
+지금은 구조를 확정하는 게 목적이고, 저장 위치만 바꾸면 되도록 인터페이스를 좁게 둔다.
+
+🔴 포지션은 절대 덮어쓰지 않는다. 매 제출을 append 한다.
+   덮어쓰면 "언제 무엇을 냈는가"가 사라지고, 그게 사라지면 채점을 재현할 수 없다.
+"""
+import os, json, time, hashlib, threading
+from datetime import datetime, timezone
+
+def _root():
+    """원장 위치. 영속 스토리지가 있으면 거기, 없으면 컨테이너 안.
+
+    🔴 HF Space에 영속 스토리지를 안 붙이면 /data 가 없다. 그때 죽어 버리면
+       화면 자체가 안 뜬다. 떠 있되 '재시작하면 사라진다'는 사실이 보이게 한다.
+       원장이 휘발되는 것과 서비스가 안 뜨는 것은 둘 다 나쁘지만, 후자는
+       무엇이 문제인지조차 알 수 없다.
+    """
+    want = os.environ.get("FINCHAL_DATA")
+    if want:
+        try:
+            os.makedirs(want, exist_ok=True)
+            t = os.path.join(want, ".w")
+            open(t, "w").close(); os.remove(t)
+            return want, True
+        except Exception:
+            pass
+    return os.path.join(os.path.dirname(os.path.abspath(__file__)), "_data"), False
+
+
+ROOT, PERSISTENT = _root()
+LOCK = threading.Lock()
+
+
+def _p(*a):
+    p = os.path.join(ROOT, *a)
+    os.makedirs(os.path.dirname(p), exist_ok=True)
+    return p
+
+
+def now():
+    return datetime.now(timezone.utc).replace(microsecond=0)
+
+
+def _read(path, default):
+    try:
+        with open(path, encoding="utf-8") as f:
+            return json.load(f)
+    except Exception:
+        return default
+
+
+def _write(path, obj):
+    tmp = path + ".tmp"
+    with open(tmp, "w", encoding="utf-8") as f:
+        json.dump(obj, f, ensure_ascii=False)
+    os.replace(tmp, path)          # 원자적 교체 — 중간에 죽어도 반쪽 파일이 안 남는다
+
+
+# ─────────────────────── 참가자 ───────────────────────
+def make_key(user_id):
+    raw = "%s|%s|finchal" % (user_id, os.environ.get("FINCHAL_SALT", "s1"))
+    return "fc_" + hashlib.sha256(raw.encode()).hexdigest()[:24]
+
+
+def register(user_id, strategy, ptype, assets):
+    """참가 등록. 이미 있으면 전략명·유형만 갱신하고 키는 유지한다."""
+    with LOCK:
+        u = _read(_p("users.json"), {})
+        key = make_key(user_id)
+        prev = u.get(user_id, {})
+        u[user_id] = {
+            "user": user_id, "key": key, "strategy": strategy, "type": ptype,
+            "assets": sorted(set(assets)),
+            "joined": prev.get("joined", now().isoformat()),
+            "visits": prev.get("visits", []),
+        }
+        _write(_p("users.json"), u)
+        return u[user_id]
+
+
+def user_by_key(key):
+    for v in _read(_p("users.json"), {}).values():
+        if v.get("key") == key:
+            return v
+    return None
+
+
+def touch(user_id):
+    """접속 기록 — 사람 부문의 '주 1회 접속' 요건 판정에 쓴다."""
+    with LOCK:
+        u = _read(_p("users.json"), {})
+        if user_id in u:
+            v = u[user_id].setdefault("visits", [])
+            d = now().date().isoformat()
+            if not v or v[-1] != d:
+                v.append(d)
+                v[:] = v[-400:]
+                _write(_p("users.json"), u)
+
+
+def all_users():
+    return list(_read(_p("users.json"), {}).values())
+
+
+# ─────────────────────── 포지션 ───────────────────────
+def submit(user_id, asset, position, source="api"):
+    """포지션 제출. 덮어쓰지 않고 줄 단위로 쌓는다."""
+    pos = max(-1.0, min(1.0, float(position)))
+    rec = {"t": now().isoformat(), "u": user_id, "a": asset,
+           "p": pos, "src": source}
+    with LOCK:
+        with open(_p("positions", "%s.jsonl" % asset), "a", encoding="utf-8") as f:
+            f.write(json.dumps(rec, ensure_ascii=False) + "\n")
+    touch(user_id)
+    return rec
+
+
+def positions(asset, user_id=None):
+    out = []
+    p = _p("positions", "%s.jsonl" % asset)
+    if not os.path.exists(p):
+        return out
+    with open(p, encoding="utf-8") as f:
+        for line in f:
+            try:
+                r = json.loads(line)
+            except Exception:
+                continue
+            if user_id is None or r.get("u") == user_id:
+                out.append(r)
+    return out
+
+
+def latest(asset, user_id):
+    ps = positions(asset, user_id)
+    return ps[-1] if ps else None
+
+
+# ─────────────────────── 점수 스냅샷 ───────────────────────
+def save_scores(asset, rows):
+    _write(_p("scores", "%s.json" % asset),
+           {"at": now().isoformat(), "rows": rows})
+
+
+def load_scores(asset):
+    return _read(_p("scores", "%s.json" % asset), {"at": None, "rows": []})

app/main.py

@@ -346,4 +346,7 @@ def _startup():
 
 @app.get("/health")
 def health():
-    return {"ok": True, "season": S1["name"], "assets": list(ASSETS)}
+    return {"ok": True, "season": S1["name"], "assets": list(ASSETS),
+            "ledger": L.ROOT, "persistent": L.PERSISTENT,
+            "warn": None if L.PERSISTENT else
+                    "영속 스토리지가 없습니다. 컨테이너가 재시작하면 원장이 사라집니다."}