Update store.py

backend/app/data/store.py

@@ -1,13 +1,18 @@
-# same content as your current store.py, just moved here
 from __future__ import annotations
 import json, sqlite3
 from datetime import datetime, timezone, timedelta
 from typing import Dict, Any, List, Optional
 from pathlib import Path
-from ..data.geo import haversine_km
 
-Path("data").mkdir(exist_ok=True)
-_CONN = sqlite3.connect("data/pulsemaps_reports.db", check_same_thread=False)
+from ..config.settings import settings
+from .geo import haversine_km
+
+# Use writable, absolute paths from settings (prefers /data in containers)
+DB_PATH: Path = settings.REPORTS_DB
+DB_PATH.parent.mkdir(parents=True, exist_ok=True)
+
+# Single connection
+_CONN = sqlite3.connect(str(DB_PATH), check_same_thread=False)
 _CONN.execute("""
 CREATE TABLE IF NOT EXISTS reports (
   id INTEGER PRIMARY KEY AUTOINCREMENT,
@@ -24,18 +29,29 @@ def _row_to_feature(row: tuple) -> Dict[str, Any]:
     _id, lat, lon, text, props_json, created_at = row
     props = {"type": "user_report", "text": text, "reported_at": created_at}
     if props_json:
-        try: props.update(json.loads(props_json))
-        except Exception: props["raw_props"] = props_json
-    return {"type": "Feature", "geometry": {"type": "Point", "coordinates": [lon, lat]}, "properties": props}
+        try:
+            props.update(json.loads(props_json))
+        except Exception:
+            props["raw_props"] = props_json
+    return {
+        "type": "Feature",
+        "geometry": {"type": "Point", "coordinates": [lon, lat]},
+        "properties": props,
+    }
 
 def add_report(lat: float, lon: float, text: str = "User report", props: dict | None = None):
     created_at = datetime.now(timezone.utc).isoformat()
     props_json = json.dumps(props or {})
-    _CONN.execute("INSERT INTO reports (lat, lon, text, props_json, created_at) VALUES (?,?,?,?,?)",
-                  (float(lat), float(lon), text, props_json, created_at))
+    _CONN.execute(
+        "INSERT INTO reports (lat, lon, text, props_json, created_at) VALUES (?,?,?,?,?)",
+        (float(lat), float(lon), text, props_json, created_at),
+    )
     _CONN.commit()
-    return {"type": "Feature", "geometry": {"type": "Point", "coordinates": [float(lon), float(lat)]},
-            "properties": {"type": "user_report", "text": text, "reported_at": created_at, **(props or {})}}
+    return {
+        "type": "Feature",
+        "geometry": {"type": "Point", "coordinates": [float(lon), float(lat)]},
+        "properties": {"type": "user_report", "text": text, "reported_at": created_at, **(props or {})},
+    }
 
 def get_feature_collection() -> Dict[str, Any]:
     cur = _CONN.execute("SELECT id, lat, lon, text, props_json, created_at FROM reports ORDER BY id DESC")
@@ -66,4 +82,4 @@ def find_reports_near(lat: float, lon: float, radius_km: float = 10.0, limit: in
 def clear_reports() -> dict[str, any]:
     _CONN.execute("DELETE FROM reports")
     _CONN.commit()
-    return {"ok": True, "message": "All reports cleared."}
+    return {"ok": True, "message": "All reports cleared."}