1 files changed, 51 insertions, 0 deletions
diff --git a/mcp/senia/diary.py b/mcp/senia/diary.py
new file mode 100644
index 0000000..1cd15f8
--- /dev/null
+++ b/mcp/senia/diary.py
@@ -0,0 +1,51 @@
+"""Diary log tool implementations.
+
+Raw, granular, agent-authored entries. Compaction (not in this module) will
+later distill these into daily/monthly markdown summaries; raw entries remain
+in sqlite as the lossless archive.
+"""
+
+from datetime import datetime, timedelta, timezone
+from db import get_conn
+
+
+def _now() -> str:
+    return datetime.now(timezone.utc).astimezone().isoformat(timespec="seconds")
+
+
+def _row(r):
+    return dict(r) if r else None
+
+
+def log(content: str) -> dict:
+    with get_conn() as conn:
+        cur = conn.execute(
+            "INSERT INTO diary_logs (ts, content) VALUES (?, ?)",
+            (_now(), content),
+        )
+        return _row(conn.execute("SELECT * FROM diary_logs WHERE id=?", (cur.lastrowid,)).fetchone())
+
+
+def today() -> list[dict]:
+    now = datetime.now(timezone.utc).astimezone()
+    start = now.replace(hour=0, minute=0, second=0, microsecond=0).isoformat()
+    with get_conn() as conn:
+        return [dict(r) for r in conn.execute(
+            "SELECT * FROM diary_logs WHERE ts >= ? ORDER BY ts", (start,)
+        ).fetchall()]
+
+
+def recent(hours: int = 24) -> list[dict]:
+    cutoff = (datetime.now(timezone.utc) - timedelta(hours=hours)).isoformat()
+    with get_conn() as conn:
+        return [dict(r) for r in conn.execute(
+            "SELECT * FROM diary_logs WHERE ts >= ? ORDER BY ts DESC", (cutoff,)
+        ).fetchall()]
+
+
+def range_query(start_ts: str, end_ts: str) -> list[dict]:
+    with get_conn() as conn:
+        return [dict(r) for r in conn.execute(
+            "SELECT * FROM diary_logs WHERE ts >= ? AND ts < ? ORDER BY ts",
+            (start_ts, end_ts),
+        ).fetchall()]