Update main.py

main.py

@@ -374,6 +374,21 @@ async def api_health():
     conn=get_db(); n=conn.execute("SELECT COUNT(*) FROM traces").fetchone()[0]; conn.close()
     return JSONResponse({"ok":True,"total_traces":n,"retain_days":RETAIN_DAYS})
 
+@app.delete("/api/traces/delete_person")
+async def delete_person_traces(person_id: str):
+    conn = get_db()
+    # Scrub person_id from payload JSON rather than full delete
+    rows = conn.execute("SELECT id, payload FROM traces").fetchall()
+    scrubbed = 0
+    for row in rows:
+        p = row["payload"] or ""
+        if person_id in p:
+            new_p = p.replace(person_id, "[ERASED]")
+            conn.execute("UPDATE traces SET payload=? WHERE id=?", (new_p, row["id"]))
+            scrubbed += 1
+    conn.commit()
+    return JSONResponse({"scrubbed": scrubbed})
+
 @app.get("/mcp/sse")
 async def mcp_sse(request:Request):
     async def gen():