gramps
cbe4a361bb
- auto_detect_facts() scans chat turns for factual content (IPs, paths, services, config changes, hardware refs) using pattern matching - check_fact_conflicts() cross-references detected facts against stored FTS5 memories — when a contradiction exists (same topic, diff value) the system surfaces a rag_update_suggestion in the done SSE payload - Frontend shows a floating notification banner comparing old vs new fact with Update/Dismiss buttons - confirm_fact_update() replaces the memory + re-embeds/re-indexes the Qdraft entry on user confirmation - Silent auto-ingest (memories + Qdrant) when no conflict exists - Frontend: msg-toolbar opacity 0→0.35 for visibility
81 lines
3.2 KiB
Python
81 lines
3.2 KiB
Python
"""JarvisChat routers - Memory CRUD API."""
|
|
from fastapi import APIRouter, HTTPException, Request
|
|
from typing import Optional
|
|
|
|
from db import get_db
|
|
from memory import add_memory, delete_memory, update_memory, get_all_memories, search_memories
|
|
from rag import confirm_fact_update
|
|
from security import read_json_body, BODY_LIMIT_DEFAULT_BYTES
|
|
from config import MAX_MEMORY_FACT_CHARS
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
@router.get("/api/memories")
|
|
async def list_memories(topic: Optional[str] = None):
|
|
memories = get_all_memories(topic)
|
|
return {"memories": memories, "count": len(memories)}
|
|
|
|
|
|
@router.post("/api/memories")
|
|
async def create_memory(request: Request):
|
|
body = await read_json_body(request, BODY_LIMIT_DEFAULT_BYTES)
|
|
fact = str(body.get("fact", "")).strip()
|
|
if not fact:
|
|
raise HTTPException(status_code=400, detail="Memory fact is required")
|
|
if len(fact) > MAX_MEMORY_FACT_CHARS:
|
|
raise HTTPException(status_code=413, detail="Memory fact is too long")
|
|
rowid = add_memory(fact=fact, topic=body.get("topic", "general"), source=body.get("source", "manual"))
|
|
return {"rowid": rowid, "status": "ok"}
|
|
|
|
|
|
@router.delete("/api/memories/{rowid}")
|
|
async def remove_memory(rowid: int):
|
|
if not delete_memory(rowid):
|
|
raise HTTPException(status_code=404, detail="Memory not found")
|
|
return {"status": "ok"}
|
|
|
|
|
|
@router.put("/api/memories/{rowid}")
|
|
async def edit_memory(rowid: int, request: Request):
|
|
body = await read_json_body(request, BODY_LIMIT_DEFAULT_BYTES)
|
|
fact = str(body.get("fact", "")).strip()
|
|
if not fact:
|
|
raise HTTPException(status_code=400, detail="Memory fact is required")
|
|
if len(fact) > MAX_MEMORY_FACT_CHARS:
|
|
raise HTTPException(status_code=413, detail="Memory fact is too long")
|
|
if not update_memory(rowid, fact):
|
|
raise HTTPException(status_code=404, detail="Memory not found")
|
|
return {"status": "ok"}
|
|
|
|
|
|
@router.get("/api/memories/search")
|
|
async def search_memories_api(q: str, limit: int = 10):
|
|
results = search_memories(q, limit=limit)
|
|
return {"results": results, "count": len(results)}
|
|
|
|
|
|
@router.post("/api/memories/confirm-update")
|
|
async def confirm_memory_update(request: Request):
|
|
body = await read_json_body(request, BODY_LIMIT_DEFAULT_BYTES)
|
|
memory_id = body.get("memory_id")
|
|
new_fact = str(body.get("new_fact", "")).strip()
|
|
old_fact = str(body.get("old_fact", "")).strip()
|
|
user_message = str(body.get("user_message", "")).strip()
|
|
assistant_message = str(body.get("assistant_message", "")).strip()
|
|
if not memory_id or not new_fact:
|
|
raise HTTPException(status_code=400, detail="memory_id and new_fact are required")
|
|
ok = await confirm_fact_update(memory_id, old_fact, new_fact, user_message, assistant_message)
|
|
if not ok:
|
|
raise HTTPException(status_code=404, detail="Memory not found")
|
|
return {"status": "ok"}
|
|
|
|
|
|
@router.get("/api/memories/stats")
|
|
async def memory_stats():
|
|
db = get_db()
|
|
total = db.execute("SELECT COUNT(*) as c FROM memories").fetchone()["c"]
|
|
topics = db.execute("SELECT topic, COUNT(*) as c FROM memories GROUP BY topic ORDER BY c DESC").fetchall()
|
|
db.close()
|
|
return {"total": total, "by_topic": {row["topic"]: row["c"] for row in topics}}
|