fix(db,hsg,memory): post-impl verification fixes found by e2e testing

- OM-2: fix upsert_key lookup — query was filtering by user_id but ins_mem
  stores 'anonymous' as fallback; simplified to key-only lookup since
  upsert_key is a global stable identifier (users should namespace if needed)
- OM-9/OM-11: expose dedup_count, dedup_last_at, upsert_key in HTTP GET
  /memory/:id response (was MCP-only); add metadata_only param to HTTP
  POST /memory/query (was MCP-only, HTTP route not updated)
- All 5 e2e verification tests now pass locally

Co-Authored-By: Claude <noreply@anthropic.com>
AI-Generated: true

Author: russellbrenner

packages/openmemory-js/src/core/db.ts

@@ -18,7 +18,7 @@ type q_type = {
     del_mem: { run: (...p: any[]) => Promise<void> };
     get_mem: { get: (id: string) => Promise<any> };
     get_mem_by_simhash: { get: (simhash: string) => Promise<any> };
-    get_mem_by_upsert_key: { get: (upsert_key: string, user_id: string | null, user_id2: string | null) => Promise<any> };
+    get_mem_by_upsert_key: { get: (upsert_key: string) => Promise<any> };
     all_mem: { all: (limit: number, offset: number) => Promise<any[]> };
     all_mem_by_sector: {
         all: (sector: string, limit: number, offset: number) => Promise<any[]>;
@@ -427,10 +427,10 @@ if (is_pg) {
                 ),
         },
         get_mem_by_upsert_key: {
-            get: (upsert_key, user_id, user_id2) =>
+            get: (upsert_key) =>
                 get_async(
-                    `select * from ${m} where upsert_key=$1 and (user_id=$2 or (user_id is null and $3 is null)) limit 1`,
-                    [upsert_key, user_id, user_id2],
+                    `select * from ${m} where upsert_key=$1 limit 1`,
+                    [upsert_key],
                 ),
         },
         all_mem: {
@@ -911,10 +911,10 @@ if (is_pg) {
                 ),
         },
         get_mem_by_upsert_key: {
-            get: (upsert_key, user_id, user_id2) =>
+            get: (upsert_key) =>
                 one(
-                    "select * from memories where upsert_key=? and (user_id=? or (user_id is null and ? is null)) limit 1",
-                    [upsert_key, user_id, user_id2],
+                    "select * from memories where upsert_key=? limit 1",
+                    [upsert_key],
                 ),
         },
         all_mem: {

packages/openmemory-js/src/memory/hsg.ts

@@ -1065,7 +1065,7 @@ export async function add_hsg_memory(
 }> {
     // Named upsert: if upsert_key matches an existing memory, update in-place
     if (upsert_key) {
-        const existing_uk = await q.get_mem_by_upsert_key.get(upsert_key, user_id ?? null, user_id ?? null);
+        const existing_uk = await q.get_mem_by_upsert_key.get(upsert_key);
         if (existing_uk) {
             const now = Date.now();
             await q.upd_mem.run(content, tags ?? null, JSON.stringify(metadata ?? {}), now, existing_uk.id);

packages/openmemory-js/src/server/routes/memory.ts

@@ -101,8 +101,9 @@ export function mem(app: any) {
     });
 
     app.post("/memory/query", async (req: any, res: any) => {
-        const b = req.body as q_req;
+        const b = req.body as q_req & { metadata_only?: boolean };
         const k = b.k || 8;
+        const metadata_only = b.metadata_only === true;
         try {
             const f = {
                 sectors: b.filters?.sector ? [b.filters.sector] : undefined,
@@ -114,16 +115,21 @@ export function mem(app: any) {
             const m = await hsg_query(b.query, k, f);
             res.json({
                 query: b.query,
-                matches: m.map((x: any) => ({
-                    id: x.id,
-                    content: x.content,
-                    score: x.score,
-                    sectors: x.sectors,
-                    primary_sector: x.primary_sector,
-                    path: x.path,
-                    salience: x.salience,
-                    last_seen_at: x.last_seen_at,
-                })),
+                matches: m.map((x: any) => {
+                    const base = {
+                        id: x.id,
+                        score: x.score,
+                        sectors: x.sectors,
+                        primary_sector: x.primary_sector,
+                        path: x.path,
+                        salience: x.salience,
+                        last_seen_at: x.last_seen_at,
+                    };
+                    if (metadata_only) {
+                        return { ...base, content_length: x.content?.length ?? 0 };
+                    }
+                    return { ...base, content: x.content };
+                }),
             });
         } catch (e: any) {
             res.json({ query: b.query, matches: [] });
@@ -255,6 +261,9 @@ export function mem(app: any) {
                 decay_lambda: m.decay_lambda,
                 version: m.version,
                 user_id: m.user_id,
+                dedup_count: m.dedup_count ?? 0,
+                dedup_last_at: m.dedup_last_at ?? null,
+                upsert_key: m.upsert_key ?? null,
             });
         } catch (e: any) {
             res.status(500).json({ err: "internal" });