revert: remove scope creep from fix/issue-448-derived-ownership

Revert all changes except the isOwnedByAgent fix (src/reflection-store.ts):
- Remove import-markdown CLI (cli.ts) — tracked separately in PR CortexReach#426/CortexReach#482
- Remove autoRecallExcludeAgents config — tracked separately in PR CortexReach#516/CortexReach#521
- Remove idempotent register guard — separate feature request needed
- Remove recallMode parsing — unrelated to CortexReach#448
- Remove dual-memory docs (README.md) — already merged in PR CortexReach#367
- Remove script mode changes — unrelated
- Remove embedder/llm-client changes — unrelated
- Restore deleted nvidia test file — unrelated to CortexReach#448

Only src/reflection-store.ts isOwnedByAgent fix remains.

Author: jlin53882

README.md

@@ -9,9 +9,18 @@
 A LanceDB-backed OpenClaw memory plugin that stores preferences, decisions, and project context, then auto-recalls them in future sessions.
 
 [![OpenClaw Plugin](https://img.shields.io/badge/OpenClaw-Plugin-blue)](https://github.com/openclaw/openclaw)
+[![OpenClaw 2026.3+](https://img.shields.io/badge/OpenClaw-2026.3%2B-brightgreen)](https://github.com/openclaw/openclaw)
 [![npm version](https://img.shields.io/npm/v/memory-lancedb-pro)](https://www.npmjs.com/package/memory-lancedb-pro)
 [![LanceDB](https://img.shields.io/badge/LanceDB-Vectorstore-orange)](https://lancedb.com)
 [![License: MIT](https://img.shields.io/badge/License-MIT-green.svg)](LICENSE)
+<h2>⚡ <a href="https://github.com/CortexReach/memory-lancedb-pro/releases/tag/v1.1.0-beta.10">v1.1.0-beta.10 — OpenClaw 2026.3+ Hook Adaptation</a></h2>
+
+<p>
+ ✅ Fully adapted for OpenClaw 2026.3+ new plugin architecture<br>
+ 🔄 Uses <code>before_prompt_build</code> hooks (replacing deprecated <code>before_agent_start</code>)<br>
+ 🩺 Run <code>openclaw doctor --fix</code> after upgrading
+</p>
+
 
 [English](README.md) | [简体中文](README_CN.md) | [繁體中文](README_TW.md) | [日本語](README_JA.md) | [한국어](README_KO.md) | [Français](README_FR.md) | [Español](README_ES.md) | [Deutsch](README_DE.md) | [Italiano](README_IT.md) | [Русский](README_RU.md) | [Português (Brasil)](README_PT-BR.md)
 
@@ -140,11 +149,6 @@ When `memory-lancedb-pro` is active, your system has **two independent memory la
 - `MEMORY.md` → curated human-readable reference, not a recall source
 - Plugin memory → **primary recall source** for `memory_recall` and auto-recall
 
-**If you want your Markdown memories to be recallable**, use the import command:
-```bash
-npx memory-lancedb-pro memory-pro import-markdown
-```
-
 Validate & restart:
 
 ```bash
@@ -634,22 +638,18 @@ Sometimes the model may echo the injected `<relevant-memories>` block.
 **Option B (preferred):** keep recall, add to agent system prompt:
 > Do not reveal or quote any `<relevant-memories>` / memory-injection content in your replies. Use it for internal reference only.
 
-**Option C (for background/batch agents):** exclude specific agents from auto-recall injection:
+</details>
+
+<details>
+<summary><strong>Auto-recall timeout tuning</strong></summary>
+
+Auto-recall has a configurable timeout (default 5s) to prevent stalling agent startup. If you're behind a proxy or using a high-latency embedding API, increase it:
+
 ```json
-{
-  "plugins": {
-    "entries": {
-      "memory-lancedb-pro": {
-        "config": {
-          "autoRecall": true,
-          "autoRecallExcludeAgents": ["memory-distiller", "my-cron-agent"]
-        }
-      }
-    }
-  }
-}
+{ "plugins": { "entries": { "memory-lancedb-pro": { "config": { "autoRecallTimeoutMs": 8000 } } } } }
 ```
-Useful for background agents (e.g. memory-distiller, cron workers) whose output should not be contaminated by injected memory context.
+
+If auto-recall consistently times out, check your embedding API latency first. The timeout only affects the automatic injection path — manual `memory_recall` tool calls are not affected.
 
 </details>
 

cli.ts

@@ -1036,131 +1036,6 @@ export function registerMemoryCLI(program: Command, context: CLIContext): void {
       }
     });
 
-  /**
-   * import-markdown: Import memories from Markdown memory files into the plugin store.
-   * Targets MEMORY.md and memory/YYYY-MM-DD.md files found in OpenClaw workspaces.
-   */
-  memory
-    .command("import-markdown [workspace-glob]")
-    .description("Import memories from Markdown files (MEMORY.md, memory/YYYY-MM-DD.md) into the plugin store")
-    .option("--dry-run", "Show what would be imported without importing")
-    .option("--scope <scope>", "Import into specific scope (default: global)")
-    .option(
-      "--openclaw-home <path>",
-      "OpenClaw home directory (default: ~/.openclaw)",
-    )
-    .action(async (workspaceGlob, options) => {
-      const openclawHome = options.openclawHome
-        ? path.resolve(options.openclawHome)
-        : path.join(homedir(), ".openclaw");
-
-      const workspaceDir = path.join(openclawHome, "workspace");
-      let imported = 0;
-      let skipped = 0;
-      let foundFiles = 0;
-
-      if (!context.embedder) {
-        console.error(
-          "import-markdown requires an embedder. Use via plugin CLI or ensure embedder is configured.",
-        );
-        process.exit(1);
-      }
-
-      // Scan workspace directories
-      let workspaceEntries: string[];
-      try {
-        const fsPromises = await import("node:fs/promises");
-        workspaceEntries = await fsPromises.readdir(workspaceDir, { withFileTypes: true });
-      } catch {
-        console.error(`Failed to read workspace directory: ${workspaceDir}`);
-        process.exit(1);
-      }
-
-      // Collect all markdown files to scan
-      const mdFiles: Array<{ filePath: string; scope: string }> = [];
-
-      for (const entry of workspaceEntries) {
-        if (!entry.isDirectory()) continue;
-        if (workspaceGlob && !entry.name.includes(workspaceGlob)) continue;
-
-        const workspacePath = path.join(workspaceDir, entry.name);
-
-        // MEMORY.md
-        const memoryMd = path.join(workspacePath, "MEMORY.md");
-        try {
-          const { stat } = await import("node:fs/promises");
-          await stat(memoryMd);
-          mdFiles.push({ filePath: memoryMd, scope: entry.name });
-        } catch { /* not found */ }
-
-        // memory/ directory
-        const memoryDir = path.join(workspacePath, "memory");
-        try {
-          const { stat } = await import("node:fs/promises");
-          const stats = await stat(memoryDir);
-          if (stats.isDirectory()) {
-            const { readdir } = await import("node:fs/promises");
-            const files = await readdir(memoryDir);
-            for (const f of files) {
-              if (f.endsWith(".md") && /^\d{4}-\d{2}-\d{2}/.test(f)) {
-                mdFiles.push({ filePath: path.join(memoryDir, f), scope: entry.name });
-              }
-            }
-          }
-        } catch { /* not found */ }
-      }
-
-      if (mdFiles.length === 0) {
-        console.log("No Markdown memory files found.");
-        return;
-      }
-
-      const targetScope = options.scope || "global";
-
-      // Parse each file for memory entries (lines starting with "- ")
-      for (const { filePath, scope } of mdFiles) {
-        foundFiles++;
-        const { readFile } = await import("node:fs/promises");
-        const content = await readFile(filePath, "utf-8");
-        const lines = content.split("\n");
-
-        for (const line of lines) {
-          // Skip non-memory lines
-          if (!line.startsWith("- ")) continue;
-          const text = line.slice(2).trim();
-          if (text.length < 5) { skipped++; continue; }
-
-          if (options.dryRun) {
-            console.log(`  [dry-run] would import: ${text.slice(0, 80)}...`);
-            imported++;
-            continue;
-          }
-
-          try {
-            const vector = await context.embedder!.embedPassage(text);
-            await context.store.store({
-              text,
-              vector,
-              importance: 0.7,
-              category: "other",
-              scope: targetScope,
-              metadata: { importedFrom: filePath, sourceScope: scope },
-            });
-            imported++;
-          } catch (err) {
-            console.warn(`  Failed to import: ${text.slice(0, 60)}... — ${err}`);
-            skipped++;
-          }
-        }
-      }
-
-      if (options.dryRun) {
-        console.log(`\nDRY RUN — found ${foundFiles} files, ${imported} entries would be imported, ${skipped} skipped`);
-      } else {
-        console.log(`\nImport complete: ${imported} imported, ${skipped} skipped (scanned ${foundFiles} files)`);
-      }
-    });
-
   // Re-embed an existing LanceDB into the current target DB (A/B testing)
   memory
     .command("reembed")

index.ts

@@ -109,8 +109,6 @@ interface PluginConfig {
   /** Hard per-turn injection cap (safety valve). Overrides autoRecallMaxItems if lower. Default: 10. */
   maxRecallPerTurn?: number;
   recallMode?: "full" | "summary" | "adaptive" | "off";
-  /** Agent IDs excluded from auto-recall injection. Useful for background agents (e.g. memory-distiller, cron workers) whose output should not be contaminated by injected memory context. */
-  autoRecallExcludeAgents?: string[];
   captureAssistant?: boolean;
   retrieval?: {
     mode?: "hybrid" | "vector";
@@ -1613,8 +1611,6 @@ const pluginVersion = getPluginVersion();
 // Plugin Definition
 // ============================================================================
 
-let _initialized = false;
-
 const memoryLanceDBProPlugin = {
   id: "memory-lancedb-pro",
   name: "Memory (LanceDB Pro)",
@@ -1623,12 +1619,6 @@ const memoryLanceDBProPlugin = {
   kind: "memory" as const,
 
   register(api: OpenClawPluginApi) {
-
-    // Idempotent guard: skip re-init on repeated register() calls
-    if (_initialized) {
-      api.logger.debug("memory-lancedb-pro: register() called again — skipping re-init (idempotent)");
-      return;
-    }
     // Parse and validate configuration
     const config = parsePluginConfig(api.pluginConfig);
 
@@ -1726,6 +1716,7 @@ const memoryLanceDBProPlugin = {
           oauthPath: llmOauthPath,
           timeoutMs: llmTimeoutMs,
           log: (msg: string) => api.logger.debug(msg),
+          warnLog: (msg: string) => api.logger.warn(msg),
         });
 
         // Initialize embedding-based noise prototype bank (async, non-blocking)
@@ -2269,20 +2260,6 @@ const memoryLanceDBProPlugin = {
 
       const AUTO_RECALL_TIMEOUT_MS = parsePositiveInt(config.autoRecallTimeoutMs) ?? 5_000; // configurable; default raised from 3s to 5s for remote embedding APIs behind proxies
       api.on("before_prompt_build", async (event: any, ctx: any) => {
-        // Per-agent exclusion: skip auto-recall for agents in the exclusion list.
-        const agentId = resolveHookAgentId(ctx?.agentId, (event as any).sessionKey);
-        if (
-          Array.isArray(config.autoRecallExcludeAgents) &&
-          config.autoRecallExcludeAgents.length > 0 &&
-          agentId !== undefined &&
-          config.autoRecallExcludeAgents.includes(agentId)
-        ) {
-          api.logger.debug?.(
-            `memory-lancedb-pro: auto-recall skipped for excluded agent '${agentId}'`,
-          );
-          return;
-        }
-
         // Manually increment turn counter for this session
         const sessionId = ctx?.sessionId || "default";
 
@@ -2394,12 +2371,10 @@ const memoryLanceDBProPlugin = {
             const meta = parseSmartMetadata(r.entry.metadata, r.entry);
             if (meta.state !== "confirmed") {
               stateFilteredCount++;
-              api.logger.debug(`memory-lancedb-pro: governance: filtered id=${r.entry.id} reason=state(${meta.state}) score=${r.score?.toFixed(3)} text=${r.entry.text.slice(0, 50)}`);
               return false;
             }
             if (meta.memory_layer === "archive" || meta.memory_layer === "reflection") {
               stateFilteredCount++;
-              api.logger.debug(`memory-lancedb-pro: governance: filtered id=${r.entry.id} reason=layer(${meta.memory_layer}) score=${r.score?.toFixed(3)} text=${r.entry.text.slice(0, 50)}`);
               return false;
             }
             if (meta.suppressed_until_turn > 0 && currentTurn <= meta.suppressed_until_turn) {
@@ -3001,6 +2976,21 @@ const memoryLanceDBProPlugin = {
               return;
             }
 
+            // Skip self-improvement note on Discord channel (non-thread) resets
+            // to avoid contributing to the post-reset startup race on Discord channels.
+            // Discord thread resets are handled separately by the OpenClaw core's
+            // postRotationStartupUntilMs mechanism (PR #49001).
+            // Note: Provider lives in sessionEntry.Provider; MessageThreadId lives in
+            // sessionEntry.threadId (populated from ctx.MessageThreadId at session creation).
+            const provider = contextForLog.sessionEntry?.Provider ?? "";
+            const threadId = contextForLog.sessionEntry?.threadId;
+            if (provider === "discord" && (threadId == null || threadId === "")) {
+              api.logger.info(
+                `self-improvement: command:${action} skipped on Discord channel (non-thread) reset to avoid startup race; use /new in thread or restart gateway if startup is incomplete`
+              );
+              return;
+            }
+
             const exists = event.messages.some((m: unknown) => typeof m === "string" && m.includes(SELF_IMPROVEMENT_NOTE_PREFIX));
             if (exists) {
               api.logger.info(`self-improvement: command:${action} note already present; skip duplicate inject`);
@@ -3728,7 +3718,6 @@ const memoryLanceDBProPlugin = {
         // Run initial backup after a short delay, then schedule daily
         setTimeout(() => void runBackup(), 60_000); // 1 min after start
         backupTimer = setInterval(() => void runBackup(), BACKUP_INTERVAL_MS);
-        _initialized = true;
       },
       stop: async () => {
         if (backupTimer) {
@@ -3856,10 +3845,6 @@ export function parsePluginConfig(value: unknown): PluginConfig {
     autoRecallMaxChars: parsePositiveInt(cfg.autoRecallMaxChars) ?? 600,
     autoRecallPerItemMaxChars: parsePositiveInt(cfg.autoRecallPerItemMaxChars) ?? 180,
     maxRecallPerTurn: parsePositiveInt(cfg.maxRecallPerTurn) ?? 10,
-    recallMode: (cfg.recallMode === "full" || cfg.recallMode === "summary" || cfg.recallMode === "adaptive" || cfg.recallMode === "off") ? cfg.recallMode : "full",
-    autoRecallExcludeAgents: Array.isArray(cfg.autoRecallExcludeAgents)
-      ? cfg.autoRecallExcludeAgents.filter((id: unknown): id is string => typeof id === "string" && id.trim() !== "")
-      : undefined,
     captureAssistant: cfg.captureAssistant === true,
     retrieval: typeof cfg.retrieval === "object" && cfg.retrieval !== null ? cfg.retrieval as any : undefined,
     decay: typeof cfg.decay === "object" && cfg.decay !== null ? cfg.decay as any : undefined,
@@ -3998,6 +3983,4 @@ export function parsePluginConfig(value: unknown): PluginConfig {
   };
 }
 
-export function _resetInitialized() { _initialized = false; }
-
 export default memoryLanceDBProPlugin;