feat: added delete memories

Author: nullure

README.md

@@ -53,6 +53,7 @@ from openmemory.client import Memory
 mem = Memory()
 mem.add("user prefers dark mode", user_id="u1")
 results = mem.search("preferences", user_id="u1")
+await mem.delete("memory_id")
 ```
 
 > Note: `add`, `search`, `get`, `delete` are async. Use `await` in async contexts.
@@ -101,6 +102,7 @@ import { Memory } from "openmemory-js"
 const mem = new Memory()
 await mem.add("user likes spicy food", { user_id: "u1" })
 const results = await mem.search("food?", { user_id: "u1" })
+await mem.delete("memory_id")
 ```
 
 Drop this into:
@@ -388,17 +390,31 @@ The `opm` CLI talks directly to the engine / server.
 ### Install
 
 ```bash
-cd backend
+cd packages/openmemory-js
 npm install
+npm run build
 npm link   # adds `opm` to your PATH
 ```
 
+### Usage
+
+```bash
+# Start the API server
+opm serve
+
+# In another terminal:
+opm health
+opm add "Recall that I prefer TypeScript over Python" --tags preference
+opm query "language preference"
+```
+
 ### Commands
 
 ```bash
 opm add "user prefers dark mode" --user u1 --tags prefs
 opm query "preferences" --user u1 --limit 5
 opm list --user u1
+opm delete <id>
 opm reinforce <id>
 opm stats
 ```

packages/openmemory-js/bin/opm.js

@@ -38,6 +38,7 @@ commands:
   user <id>             get user summary
   health                ping server
   mcp                   start mcp server (stdio)
+  serve                 start api server
 
 options:
   --user <id>           user id
@@ -256,6 +257,16 @@ for (let i = 1; i < argv.length; i++) {
             process.exit(1);
         }
         break;
+      case 'serve':
+        try {
+            console.log('[opm] passing control to server...');
+            require('../dist/server/index.js');
+        } catch (e) {
+            console.error('[error] failed to start server. ensure project is built (npm run build).');
+            console.error(e.message);
+            process.exit(1);
+        }
+        break;
       default:
         console.error(`[error] unknown command: ${cmd}`);
         console.log(helptext);

packages/openmemory-js/src/ai/mcp.ts

@@ -8,6 +8,7 @@ import {
     add_hsg_memory,
     hsg_query,
     reinforce_memory,
+    delete_memory,
     sector_configs,
 } from "../memory/hsg";
 import { q, all_async, memories_table, vector_store } from "../core/db";
@@ -444,6 +445,37 @@ export const create_mcp_srv = () => {
         },
     );
 
+    registry.tool(
+        "openmemory_delete",
+        "Delete a memory by identifier",
+        {
+            id: z.string().min(1).describe("Memory identifier to delete"),
+            user_id: z.string().trim().min(1).optional().describe("Validate ownership"),
+        },
+        async ({ id, user_id }) => {
+            const u = uid(user_id);
+            if (u) {
+                // Pre-check ownership if user_id provided
+                const mem = await q.get_mem.get(id);
+                if (mem && mem.user_id !== u) {
+                    throw new Error(`Memory ${id} not found for user ${u}`);
+                }
+            }
+
+            const success = await delete_memory(id);
+            if (!success) {
+                return {
+                    content: [{ type: "text", text: `Memory ${id} not found or could not be deleted.` }],
+                    isError: true
+                };
+            }
+
+            return {
+                content: [{ type: "text", text: `Memory ${id} successfully deleted.` }],
+            };
+        },
+    );
+
     registry.tool(
         "openmemory_list",
         "List recent memories for quick inspection",

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

@@ -1155,6 +1155,21 @@ export async function add_hsg_memory(
         throw error;
     }
 }
+export async function delete_memory(id: string): Promise<boolean> {
+    const mem = await q.get_mem.get(id);
+    if (!mem) return false;
+    await transaction.begin();
+    try {
+        await q.del_mem.run(id);
+        await q.del_waypoints.run(id, id);
+        await vector_store.deleteVectors(id);
+        await transaction.commit();
+        return true;
+    } catch (error) {
+        await transaction.rollback();
+        throw error;
+    }
+}
 export async function reinforce_memory(
     id: string,
     boost: number = 0.1,

packages/openmemory-js/src/ops/compress.ts

@@ -214,7 +214,7 @@ class MemoryCompressionEngine {
         if (!t || t.length < 50) return this.compress(t, "semantic");
         const code =
             /\b(function|const|let|var|def|class|import|export)\b/.test(t);
-        const urls = /https?:\/\
+        const urls = /https?:\/\//.test(t);
         const verb = t.split(/\s+/).length > 100;
         let a: "semantic" | "syntactic" | "aggressive";
         if (code || urls) a = "aggressive";

packages/openmemory-js/src/sources/github.ts

@@ -34,7 +34,7 @@ export class github_source extends base_source {
         }
 
         const [owner, repo] = filters.repo.split('/');
-        const path = filters.path?.replace(/^\
+        const path = filters.path?.replace(/^\//, "") || "";
         const include_issues = filters.include_issues || false;
 
         const results: source_item[] = [];

packages/openmemory-js/src/sources/web_crawler.ts

@@ -99,7 +99,7 @@ export class web_crawler_source extends base_source {
                             const full_url = new URL(href, url);
                             if (full_url.hostname !== base_domain) return;
 
-                            const clean_url = `${full_url.protocol}
+                            const clean_url = `${full_url.protocol}//${full_url.host}${full_url.pathname}`;
                             if (!this.visited.has(clean_url)) {
                                 to_visit.push({ url: clean_url, depth: depth + 1 });
                             }

packages/openmemory-py/src/openmemory/ai/mcp.py

@@ -63,6 +63,19 @@ async def handle_list_tools() -> list[Tool]:
                     },
                     "required": ["id"]
                 }
+                }
+            ),
+             Tool(
+                name="openmemory_delete",
+                description="Delete a memory by ID",
+                inputSchema={
+                    "type": "object",
+                    "properties": {
+                        "id": {"type": "string"},
+                        "user_id": {"type": "string"}
+                    },
+                    "required": ["id"]
+                }
             ),
              Tool(
                 name="openmemory_list",
@@ -121,6 +134,21 @@ async def handle_call_tool(name: str, arguments: dict | None) -> list[TextConten
                     return [TextContent(type="text", text=f"Memory {mid} not found")]
                 return [TextContent(type="text", text=json.dumps(dict(m), default=str, indent=2))]
 
+            elif name == "openmemory_delete":
+                mid = args.get("id")
+                uid = args.get("user_id")
+                
+                # Check exist/ownership
+                m = await mem.get(mid)
+                if not m:
+                    return [TextContent(type="text", text=f"Memory {mid} not found")]
+                
+                if uid and m["user_id"] != uid:
+                     return [TextContent(type="text", text=f"Memory {mid} not found for user {uid}")]
+
+                await mem.delete(mid)
+                return [TextContent(type="text", text=f"Memory {mid} deleted")]
+
             elif name == "openmemory_list":
                 limit = args.get("limit", 20)
                 uid = args.get("user_id")