Create log_utils.py

src/log_utils.py

@@ -0,0 +1,26 @@
+# src/log_utils.py
+from __future__ import annotations
+
+import json
+import os
+from datetime import datetime
+from typing import Any, Dict
+
+def _ensure_dir(path: str) -> None:
+    os.makedirs(path, exist_ok=True)
+
+def write_audit_log(case_id: str, payload: Dict[str, Any], *, base_dir: str = "/data/econsult/audit") -> str:
+    """Write a single JSON audit record per case."""
+    _ensure_dir(base_dir)
+    ts = datetime.utcnow().isoformat(timespec="seconds") + "Z"
+    record = dict(payload)
+    record["case_id"] = case_id
+    record["ts_iso"] = ts
+    # Normalize some floats for readability
+    for k in ("runtime_sec", "coverage_percent"):
+        if k in record and isinstance(record[k], (int, float)):
+            record[k] = float(f"{record[k]:.4f}")
+    fp = os.path.join(base_dir, f"{case_id}.json")
+    with open(fp, "w", encoding="utf-8") as f:
+        json.dump(record, f, indent=2, ensure_ascii=False)
+    return fp