fix(runtime): pick writable DATA_DIR via storage module; create dirs on startup; remove hardcoded /data

app.py

@@ -1,2 +1,3 @@
 # app.py (repo kökündə)
 from app.api import app  # FastAPI instance
+

app/__init__.py

@@ -0,0 +1 @@
+

app/api.py

@@ -1,4 +1,5 @@
-# app/api.py
+from app.storage import DATA_DIR, INDEX_DIR, HISTORY_JSON
+# app/api.py
 from __future__ import annotations
 
 import time
@@ -200,3 +201,15 @@ def reset_index():
         return {"message": "index reset", "ntotal": getattr(rag.index, "ntotal", 0)}
     except Exception as e:
         raise HTTPException(status_code=500, detail=str(e))
+
+@app.on_event("startup")
+async def _ensure_dirs():
+    try:
+        INDEX_DIR.mkdir(parents=True, exist_ok=True)
+        # HISTORY_JSON parent is DATA_DIR
+        HISTORY_JSON.parent.mkdir(parents=True, exist_ok=True)
+    except Exception:
+        # boot-un dayanmasının qarşısını alaq
+        pass
+
+

app/metrics.py

@@ -40,3 +40,4 @@ class StatsTracker:
         }
 
 tracker = StatsTracker()
+

app/paths.py

@@ -1,6 +1,7 @@
 import os
 from pathlib import Path
-DATA_DIR = Path(os.getenv("DATA_DIR", "/data"))
+DATA_DIR = Path(os.getenv("DATA_DIR", str(DATA_DIR)))
 DATA_DIR.mkdir(parents=True, exist_ok=True)
 INDEX_DIR = DATA_DIR / "index"; INDEX_DIR.mkdir(exist_ok=True)
 HISTORY_JSON = DATA_DIR / "history.json"
+

app/rag/__init__.py

@@ -0,0 +1 @@
+

app/rag_system.py

@@ -361,3 +361,4 @@ __all__ = [
     "UPLOAD_DIR",
     "INDEX_DIR",
 ]
+

app/routes_stats.py

@@ -11,3 +11,4 @@ def get_stats():
 def get_history():
     s = tracker.get_stats()
     return {"history": s["lastN_questions"], "total_chunks": s["total_chunks"]}
+

app/schemas.py

@@ -23,3 +23,4 @@ class HistoryItem(BaseModel):
 class HistoryResponse(BaseModel):
     session_id: str
     history: List[HistoryItem]
+

app/store.py

@@ -10,3 +10,4 @@ def add_history(session_id: str, role: str, content: str):
 
 def get_history(session_id: str) -> List[dict]:
     return _history.get(session_id, [])
+

app/utils.py

@@ -7,3 +7,4 @@ def ensure_session(session_id: str | None) -> str:
 
 def http400(msg: str):
     raise HTTPException(status_code=400, detail=msg)
+

boot.py

@@ -30,3 +30,4 @@ if __name__ == "__main__":
     if last_err:
         raise last_err
     sys.exit(1)
+

main.py

@@ -13,3 +13,4 @@ async def generate_alias(
 @app.get("/health")
 def health_alias():
     return {"status": "ok"}
+