fix(capture): skip "Review the conversation above" internal prompts

apps/memos-local-openclaw/index.ts

@@ -9,7 +9,6 @@ import type { OpenClawPluginApi } from "openclaw/plugin-sdk";
 import { Type } from "@sinclair/typebox";
 import * as fs from "fs";
 import * as path from "path";
-import { createRequire } from "node:module";
 import { fileURLToPath } from "url";
 import { buildContext } from "./src/config";
 import type { HostModelsConfig } from "./src/openclaw-api";
@@ -225,115 +224,7 @@ const memosLocalPlugin = {
     }
 
     const moduleDir = path.dirname(fileURLToPath(import.meta.url));
-    const localRequire = createRequire(import.meta.url);
-    const npmCmd = process.platform === "win32" ? "npm.cmd" : "npm";
-
-    function detectPluginDir(startDir: string): string {
-      let cur = startDir;
-      for (let i = 0; i < 6; i++) {
-        const pkg = path.join(cur, "package.json");
-        if (fs.existsSync(pkg)) return cur;
-        const parent = path.dirname(cur);
-        if (parent === cur) break;
-        cur = parent;
-      }
-      return startDir;
-    }
-
-    const pluginDir = detectPluginDir(moduleDir);
-
-    function runNpm(args: string[]) {
-      const { spawnSync } = localRequire("child_process") as typeof import("node:child_process");
-      return spawnSync(npmCmd, args, {
-        cwd: pluginDir,
-        stdio: "pipe",
-        shell: false,
-        timeout: 120_000,
-      });
-    }
-
-    let sqliteReady = false;
-
-    function trySqliteLoad(): boolean {
-      try {
-        const resolved = localRequire.resolve("better-sqlite3", { paths: [pluginDir] });
-        const resolvedReal = fs.existsSync(resolved) ? fs.realpathSync.native(resolved) : resolved;
-        if (!isPathInside(pluginDir, resolvedReal)) {
-          api.logger.warn(`memos-local: better-sqlite3 resolved outside plugin dir: ${resolved}`);
-          return false;
-        }
-        localRequire(resolvedReal);
-        return true;
-      } catch {
-        return false;
-      }
-    }
-
-    sqliteReady = trySqliteLoad();
-
-    if (!sqliteReady) {
-      api.logger.warn(`memos-local: better-sqlite3 not found in ${pluginDir}, attempting auto-rebuild ...`);
-
-      try {
-        const rebuildResult = runNpm(["rebuild", "better-sqlite3"]);
-
-        const stdout = rebuildResult.stdout?.toString() || "";
-        const stderr = rebuildResult.stderr?.toString() || "";
-        if (stdout) api.logger.info(`memos-local: rebuild stdout: ${stdout.slice(0, 500)}`);
-        if (stderr) api.logger.warn(`memos-local: rebuild stderr: ${stderr.slice(0, 500)}`);
-
-        if (rebuildResult.status === 0) {
-          Object.keys(localRequire.cache)
-            .filter(k => k.includes("better-sqlite3") || k.includes("better_sqlite3"))
-            .forEach(k => delete localRequire.cache[k]);
-          sqliteReady = trySqliteLoad();
-          if (sqliteReady) {
-            api.logger.info("memos-local: better-sqlite3 auto-rebuild succeeded!");
-          } else {
-            api.logger.warn("memos-local: rebuild exited 0 but module still not loadable from plugin dir");
-          }
-        } else {
-          api.logger.warn(`memos-local: rebuild exited with code ${rebuildResult.status}`);
-        }
-      } catch (rebuildErr) {
-        api.logger.warn(`memos-local: auto-rebuild error: ${rebuildErr}`);
-      }
-
-      if (!sqliteReady) {
-        const nodeVer = process.version;
-        const nodeMajor = parseInt(process.versions?.node?.split(".")[0] ?? "0", 10);
-        const isNode25Plus = nodeMajor >= 25;
-        const lines = [
-          "",
-          "╔══════════════════════════════════════════════════════════════╗",
-          "║  MemOS Local Memory — better-sqlite3 native module missing  ║",
-          "╠══════════════════════════════════════════════════════════════╣",
-          "║                                                            ║",
-          "║  Auto-rebuild failed (Node " + nodeVer + "). Run manually:              ║",
-          "║                                                            ║",
-          `║  cd ${pluginDir}`,
-          "║  npm rebuild better-sqlite3                                ║",
-          "║  openclaw gateway stop && openclaw gateway start           ║",
-          "║                                                            ║",
-          "║  If rebuild fails, install build tools first:              ║",
-          "║  macOS:  xcode-select --install                            ║",
-          "║  Linux:  sudo apt install build-essential python3          ║",
-        ];
-        if (isNode25Plus) {
-          lines.push("║                                                            ║");
-          lines.push("║  Node 25+ has no prebuild: build tools required, or use    ║");
-          lines.push("║  Node LTS (20/22): nvm install 22 && nvm use 22            ║");
-        }
-        lines.push("║                                                            ║");
-        lines.push("╚══════════════════════════════════════════════════════════════╝");
-        lines.push("");
-        api.logger.warn(lines.join("\n"));
-        throw new Error(
-          `better-sqlite3 native module not found (Node ${nodeVer}). Auto-rebuild failed. Fix: install build tools, then cd ${pluginDir} && npm rebuild better-sqlite3. Or use Node LTS (20/22).`
-        );
-      }
-    }
-
+    const pluginDir = moduleDir; // alias — replaces removed detectPluginDir(moduleDir)
     let pluginCfg = (api.pluginConfig ?? {}) as Record<string, unknown>;
     const stateDir = process.env.OPENCLAW_STATE_DIR || api.resolvePath("~/.openclaw");
 

apps/memos-local-openclaw/openclaw.plugin.json

@@ -20,7 +20,7 @@
     }
   },
   "requirements": {
-    "node": ">=18.0.0",
+    "node": ">=22.0.0",
     "openclaw": ">=2026.2.0"
   },
   "setup": {
@@ -33,5 +33,25 @@
       "If better-sqlite3 fails to build, ensure you have C++ build tools: xcode-select --install (macOS) or build-essential (Linux)"
     ]
   },
-  "extensions": ["./index.ts"]
+  "extensions": [
+    "./index.ts"
+  ],
+  "contracts": {
+    "tools": [
+      "memory_search",
+      "memory_get",
+      "memory_timeline",
+      "memory_viewer",
+      "task_summary",
+      "skill_search",
+      "skill_install",
+      "skill_upgrade",
+      "memory_share",
+      "memory_unshare",
+      "skill_publish",
+      "skill_unpublish",
+      "network_skill_pull",
+      "network_team_info"
+    ]
+  }
 }

apps/memos-local-openclaw/src/embedding/index.ts

@@ -7,6 +7,8 @@ import { embedMistral } from "./providers/mistral";
 import { embedLocal } from "./local";
 import { modelHealth } from "../ingest/providers";
 
+type EmbeddingInputKind = "document" | "query";
+
 export class Embedder {
   constructor(
     private cfg: EmbeddingConfig | undefined,
@@ -57,13 +59,17 @@ export class Embedder {
     if (this.provider === "cohere" && this.cfg) {
       return embedCohereQuery(text, this.cfg, this.log);
     }
-    const vecs = await this.embedBatch([text]);
+    const vecs = await this.embedBatch([text], "query");
     return vecs[0];
   }
 
-  private async embedBatch(texts: string[]): Promise<number[][]> {
+  private async embedBatch(
+    texts: string[],
+    inputKind: EmbeddingInputKind = "document",
+  ): Promise<number[][]> {
     const provider = this.provider;
     const cfg = this.cfg;
+    const inputType = this.resolveInputType(inputKind);
 
     const modelInfo = `${provider}/${cfg?.model ?? "default"}`;
     try {
@@ -75,7 +81,9 @@ export class Embedder {
         case "zhipu":
         case "siliconflow":
         case "bailian":
-          result = await embedOpenAI(texts, cfg!, this.log); break;
+          result = await embedOpenAI(texts, cfg!, this.log, inputType); break;
+        case "openclaw":
+          result = await this.embedOpenClaw(texts, inputType); break;
         case "gemini":
           result = await embedGemini(texts, cfg!, this.log); break;
         case "cohere":
@@ -100,7 +108,13 @@ export class Embedder {
     }
   }
 
-  private async embedOpenClaw(texts: string[]): Promise<number[][]> {
+  private resolveInputType(inputKind: EmbeddingInputKind): string | undefined {
+    if (!this.cfg) return undefined;
+    if (inputKind === "query") return this.cfg.queryInputType ?? this.cfg.inputType;
+    return this.cfg.documentInputType ?? this.cfg.inputType;
+  }
+
+  private async embedOpenClaw(texts: string[], inputType?: string): Promise<number[][]> {
     if (!this.openclawAPI) {
       throw new Error(
         "OpenClaw API not available. Ensure sharing.capabilities.hostEmbedding is enabled in config."
@@ -111,6 +125,7 @@ export class Embedder {
     const response = await this.openclawAPI.embed({
       texts,
       model: this.cfg?.model,
+      inputType,
     });
 
     return response.embeddings;

apps/memos-local-openclaw/src/embedding/providers/gemini.ts

@@ -5,7 +5,7 @@ export async function embedGemini(
   cfg: EmbeddingConfig,
   log: Logger,
 ): Promise<number[][]> {
-  const model = cfg.model ?? "text-embedding-004";
+  const model = cfg.model ?? "gemini-embedding-001";
   const endpoint =
     cfg.endpoint ??
     `https://generativelanguage.googleapis.com/v1beta/models/${model}:batchEmbedContents`;

apps/memos-local-openclaw/src/embedding/providers/openai.ts

@@ -4,6 +4,7 @@ export async function embedOpenAI(
   texts: string[],
   cfg: EmbeddingConfig,
   log: Logger,
+  inputType?: string,
 ): Promise<number[][]> {
   const endpoint = normalizeEmbeddingEndpoint(cfg.endpoint ?? "https://api.openai.com/v1/embeddings");
   const model = cfg.model ?? "text-embedding-3-small";
@@ -16,7 +17,11 @@ export async function embedOpenAI(
   const resp = await fetch(endpoint, {
     method: "POST",
     headers,
-    body: JSON.stringify({ input: texts, model }),
+    body: JSON.stringify({
+      input: texts,
+      model,
+      ...(inputType ? { input_type: inputType } : {}),
+    }),
     signal: AbortSignal.timeout(cfg.timeoutMs ?? 30_000),
   });
 

apps/memos-local-openclaw/src/openclaw-api.ts

@@ -12,6 +12,7 @@ import type { Logger, OpenClawAPI } from "./types";
 export interface OpenClawEmbedRequest {
   texts: string[];
   model?: string;
+  inputType?: string;
 }
 
 export interface OpenClawEmbedResponse {
@@ -98,7 +99,11 @@ export class OpenClawAPIClient implements OpenClawAPI {
     const resp = await fetch(endpoint, {
       method: "POST",
       headers: buildHeaders(provider),
-      body: JSON.stringify({ input: request.texts, model }),
+      body: JSON.stringify({
+        input: request.texts,
+        model,
+        ...(request.inputType ? { input_type: request.inputType } : {}),
+      }),
       signal: AbortSignal.timeout(30_000),
     });
 

apps/memos-local-openclaw/src/storage/sqlite.ts

@@ -3011,6 +3011,39 @@ export class SqliteStore {
     return result;
   }
 
+  // ─── Export ───
+
+  exportAll(): { memories: unknown[]; tasks: unknown[]; skills: unknown[] } {
+    const memories = this.db.prepare(
+      "SELECT * FROM chunks ORDER BY created_at ASC",
+    ).all();
+
+    const tasks = this.db.prepare(
+      "SELECT * FROM tasks ORDER BY started_at ASC",
+    ).all();
+
+    const skills = this.db.prepare(
+      "SELECT id, name, description, content, version, status, visibility, owner, created_at, updated_at FROM skills ORDER BY created_at ASC",
+    ).all();
+
+    return { memories, tasks, skills };
+  }
+
+  exportMemoriesAsCsv(): string {
+    const rows = this.db.prepare(
+      "SELECT id, session_key, role, summary, content, created_at FROM chunks ORDER BY created_at ASC",
+    ).all() as Array<{ id: string; session_key: string; role: string; summary: string; content: string; created_at: number }>;
+
+    const escape = (v: string) => `"${String(v ?? "").replace(/"/g, '""')}"`;
+    const header = ["id", "session_key", "role", "summary", "content", "created_at"].join(",");
+    const lines = rows.map((r) =>
+      [r.id, r.session_key, r.role, r.summary, r.content, new Date(r.created_at).toISOString()]
+        .map(escape)
+        .join(","),
+    );
+    return [header, ...lines].join("\n");
+  }
+
   close(): void {
     this.db.close();
   }
@@ -3031,7 +3064,7 @@ function sanitizeFtsQuery(raw: string): string {
     .filter((t) => t.length > 1)
     .filter((t) => !FTS_RESERVED.has(t.toUpperCase()));
 
-  return tokens.join(" ");
+  return tokens.map((t) => `"${t.replace(/"/g, '""')}"`).join(" ");
 }
 
 const FTS_RESERVED = new Set(["AND", "OR", "NOT", "NEAR"]);

apps/memos-local-openclaw/src/types.ts

@@ -189,6 +189,9 @@ export interface EmbeddingConfig extends ProviderConfig {
   batchSize?: number;
   dimensions?: number;
   retry?: number;
+  inputType?: string;
+  queryInputType?: string;
+  documentInputType?: string;
 }
 
 // ─── Skill ───
@@ -419,8 +422,17 @@ export interface PluginContext {
 }
 
 export interface OpenClawAPI {
-  embed(request: { texts: string[]; model?: string }): Promise<{ embeddings: number[][]; dimensions: number }>;
-  complete(request: { prompt: string; maxTokens?: number; temperature?: number; model?: string }): Promise<{ text: string }>;
+  embed(request: {
+    texts: string[];
+    model?: string;
+    inputType?: string;
+  }): Promise<{ embeddings: number[][]; dimensions: number }>;
+  complete(request: {
+    prompt: string;
+    maxTokens?: number;
+    temperature?: number;
+    model?: string;
+  }): Promise<{ text: string }>;
 }
 
 export interface Logger {