Create mcp_server.py

mcp_server.py

@@ -0,0 +1,46 @@
+# mcp_server.py  (最小骨架)
+import json, os
+from modelcontextprotocol import Server
+import rag_utils
+
+srv = Server(name="soulcompass-mcp")
+
+@srv.tool("tarot.search")
+def tarot_search(query: str, k: int = 3):
+    hits = rag_utils.search_tarot(query, k)
+    return {"hits": hits}
+
+@srv.tool("numerology.search")
+def num_search(query: str, k: int = 3):
+    hits = rag_utils.search_numerology(query, k)
+    return {"hits": hits}
+
+@srv.tool("corpus.search_union")
+def union_search(query: str, k_each: int = 2):
+    hits = rag_utils.search_union(query, k_each)
+    return {"hits": hits}
+
+# 以 UID 區分使用者資料（沿用你 app.py 的結構）
+DATA_ROOT = "data/users"
+
+@srv.tool("journal.append")
+def journal_append(uid: str, entry: dict):
+    user_dir = os.path.join(DATA_ROOT, uid); os.makedirs(user_dir, exist_ok=True)
+    path = os.path.join(user_dir, "journal.jsonl")
+    with open(path, "a", encoding="utf-8") as f:
+        f.write(json.dumps(entry, ensure_ascii=False) + "\n")
+    return {"ok": True}
+
+@srv.tool("journal.query")
+def journal_query(uid: str, limit: int = 50):
+    path = os.path.join(DATA_ROOT, uid, "journal.jsonl")
+    out = []
+    if os.path.exists(path):
+        for line in open(path, "r", encoding="utf-8").read().splitlines()[-limit:]:
+            try: out.append(json.loads(line))
+            except: pass
+    return {"entries": out}
+
+if __name__ == "__main__":
+    # 以 stdio 方式啟動（Space 內最簡單）
+    srv.run_stdio()