feat: fixed mcp

Author: nullure

packages/openmemory-js/bin/opm.js

@@ -243,7 +243,13 @@ for (let i = 1; i < argv.length; i++) {
       case 'mcp':
         // Start MCP server (requires build)
         try {
-            require('../dist/ai/mcp.js');
+            const mcp = require('../dist/ai/mcp.js');
+            if (mcp && mcp.start_mcp_stdio) {
+                await mcp.start_mcp_stdio();
+            } else {
+                console.error('[error] mcp module missing start_mcp_stdio export');
+                process.exit(1);
+            }
         } catch (e) {
             console.error('[error] failed to start mcp server. ensure project is built (npm run build).');
             console.error(e.message);

packages/openmemory-js/package-lock.json

@@ -1,6 +1,6 @@
 {
     "name": "openmemory-js",
-    "version": "1.3.0",
+    "version": "1.3.1",
     "author": "nullure",
     "bin": {
         "opm": "./bin/opm.js",
@@ -36,6 +36,7 @@
         "zod": "^3.25.76"
     },
     "devDependencies": {
+        "@types/cheerio": "^0.22.35",
         "@types/fluent-ffmpeg": "^2.1.26",
         "@types/node": "^20.19.25",
         "@types/pg": "^8.15.6",

packages/openmemory-js/package.json

@@ -421,7 +421,7 @@ export const mcp = (app: any) => {
     const srv_ready = srv
         .connect(trans)
         .then(() => {
-            console.log("[MCP] Server started and transport connected");
+            console.error("[MCP] Server started and transport connected");
         })
         .catch((error) => {
             console.error("[MCP] Failed to initialize transport:", error);
@@ -436,7 +436,7 @@ export const mcp = (app: any) => {
                 send_err(res, -32600, "Request body must be a JSON object");
                 return;
             }
-            console.log("[MCP] Incoming request:", JSON.stringify(pay));
+            console.error("[MCP] Incoming request:", JSON.stringify(pay));
             set_hdrs(res);
             await trans.handleRequest(req, res, pay);
         } catch (error) {

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

@@ -142,7 +142,7 @@ if (is_pg) {
                 const admin = pool("postgres");
                 try {
                     await admin.query(`CREATE DATABASE ${db_name}`);
-                    console.log(`[DB] Created ${db_name}`);
+                    console.error(`[DB] Created ${db_name}`);
                 } catch (e: any) {
                     if (e.code !== "42P04") throw e;
                 } finally {
@@ -202,11 +202,11 @@ if (is_pg) {
         // Initialize VectorStore
         if (env.vector_backend === "valkey") {
             vector_store = new ValkeyVectorStore();
-            console.log("[DB] Using Valkey VectorStore");
+            console.error("[DB] Using Valkey VectorStore");
         } else {
             const vt = process.env.OM_VECTOR_TABLE || "openmemory_vectors";
             vector_store = new PostgresVectorStore({ run_async, get_async, all_async }, v.replace(/"/g, ""));
-            console.log(`[DB] Using Postgres VectorStore with table: ${v}`);
+            console.error(`[DB] Using Postgres VectorStore with table: ${v}`);
         }
     };
     init().catch((err) => {
@@ -551,10 +551,10 @@ if (is_pg) {
 
     if (env.vector_backend === "valkey") {
         vector_store = new ValkeyVectorStore();
-        console.log("[DB] Using Valkey VectorStore");
+        console.error("[DB] Using Valkey VectorStore");
     } else {
         vector_store = new PostgresVectorStore({ run_async, get_async, all_async }, sqlite_vector_table);
-        console.log(`[DB] Using SQLite VectorStore with table: ${sqlite_vector_table}`);
+        console.error(`[DB] Using SQLite VectorStore with table: ${sqlite_vector_table}`);
     }
 
     // Simple Mutex for transaction serialization

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

@@ -8,7 +8,7 @@
  *   generic webhook endpoint for source-specific payloads
  */
 
-import * as sources from "../sources";
+import * as sources from "../../sources";
 
 export function src(app: any) {
     // list available sources
@@ -61,7 +61,7 @@ export function src(app: any) {
         }
 
         try {
-            const { ingest_document } = await import("../../ops/ingest");
+            const { ingestDocument } = await import("../../ops/ingest");
 
             // handle different github events
             let content = "";
@@ -85,7 +85,7 @@ export function src(app: any) {
             }
 
             if (content) {
-                const result = await ingest_document("text", content, meta);
+                const result = await ingestDocument("text", content, meta);
                 res.json({ ok: true, memory_id: result.root_memory_id, event: event_type });
             } else {
                 res.json({ ok: true, skipped: true, reason: "no content" });
@@ -100,9 +100,9 @@ export function src(app: any) {
         const payload = req.body;
 
         try {
-            const { ingest_document } = await import("../../ops/ingest");
+            const { ingestDocument } = await import("../../ops/ingest");
             const content = JSON.stringify(payload, null, 2);
-            const result = await ingest_document("text", content, { source: "notion_webhook" });
+            const result = await ingestDocument("text", content, { source: "notion_webhook" });
             res.json({ ok: true, memory_id: result.root_memory_id });
         } catch (e: any) {
             res.status(500).json({ error: e.message });

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

@@ -216,7 +216,7 @@ export abstract class base_source {
     }
 
     async ingest_all(filters?: Record<string, any>): Promise<string[]> {
-        const { ingest_document } = await import('../ops/ingest');
+        const { ingestDocument } = await import('../ops/ingest');
 
         const items = await this.list_items(filters);
         const ids: string[] = [];
@@ -228,7 +228,7 @@ export abstract class base_source {
             const item = items[i];
             try {
                 const content = await this.fetch_item(item.id);
-                const result = await ingest_document(
+                const result = await ingestDocument(
                     content.type || 'text',
                     content.data || content.text || '',
                     { source: this.name, ...content.meta },

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

@@ -71,13 +71,13 @@ export class onedrive_source extends base_source {
         let next_url: string | null = url;
 
         while (next_url) {
-            const resp = await fetch(next_url, {
+            const resp: Response = await fetch(next_url, {
                 headers: { Authorization: `Bearer ${this.access_token}` }
             });
 
             if (!resp.ok) throw new Error(`http ${resp.status}: ${resp.statusText}`);
 
-            const data = await resp.json();
+            const data: any = await resp.json();
 
             for (const item of data.value || []) {
                 results.push({

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

@@ -4,7 +4,13 @@
  * no auth required for public urls
  */
 
-import { base_source, source_config_error, source_item, source_content } from './base';
+import { base_source, source_config_error, source_item, source_content, source_config } from './base';
+
+export interface web_crawler_config extends source_config {
+    max_pages?: number;
+    max_depth?: number;
+    timeout?: number;
+}
 
 export class web_crawler_source extends base_source {
     name = 'web_crawler';
@@ -16,7 +22,7 @@ export class web_crawler_source extends base_source {
 
     constructor(
         user_id?: string,
-        config?: { max_pages?: number; max_depth?: number; timeout?: number } & Record<string, any>
+        config?: web_crawler_config
     ) {
         super(user_id, config);
         this.max_pages = config?.max_pages || 50;