feat(memos-local-openclaw): This PR merges the local plugin 0317 branch (openclaw-local-plugin-20260317).

.gitignore

@@ -226,6 +226,9 @@ cython_debug/
 # DS_Store
 .DS_Store
 
+# OpenWork integration assets (managed separately)
+apps/openwork-memos-integration/apps/desktop/public/assets/usecases/
+
 # Outputs and Evaluation Results
 outputs
 

apps/memos-local-openclaw/.gitignore

@@ -14,8 +14,6 @@ Thumbs.db
 # Generated / non-essential
 package-lock.json
 .installed-version
-www/
-docs/
 ppt/
 
 # Database files

apps/memos-local-openclaw/README.md

@@ -504,7 +504,7 @@ TELEMETRY_ENABLED=false
 
 ### Technical details
 
-- Uses [PostHog](https://posthog.com) for event collection
+- Uses Aliyun ARMS RUM for event collection
 - Each installation gets a random anonymous UUID (stored at `~/.openclaw/memos-local/.anonymous-id`)
 - Events are batched and sent in the background; failures are silently ignored
 - The anonymous ID is never linked to any personal information

apps/memos-local-openclaw/index.ts

@@ -9,6 +9,7 @@ import type { OpenClawPluginApi } from "openclaw/plugin-sdk";
 import { Type } from "@sinclair/typebox";
 import * as fs from "fs";
 import * as path from "path";
+import { fileURLToPath } from "url";
 import { buildContext } from "./src/config";
 import { SqliteStore } from "./src/storage/sqlite";
 import { Embedder } from "./src/embedding";
@@ -76,13 +77,20 @@ const memosLocalPlugin = {
 
   register(api: OpenClawPluginApi) {
     // ─── Ensure better-sqlite3 native module is available ───
-    const pluginDir = path.dirname(new URL(import.meta.url).pathname);
+    const pluginDir = path.dirname(fileURLToPath(import.meta.url));
+
+    function normalizeFsPath(p: string): string {
+      return path.resolve(p).replace(/\\/g, "/").toLowerCase();
+    }
+
     let sqliteReady = false;
 
     function trySqliteLoad(): boolean {
       try {
         const resolved = require.resolve("better-sqlite3", { paths: [pluginDir] });
-        if (!resolved.startsWith(pluginDir)) {
+        const resolvedNorm = normalizeFsPath(resolved);
+        const pluginNorm = normalizeFsPath(pluginDir);
+        if (!resolvedNorm.startsWith(pluginNorm + "/") && resolvedNorm !== pluginNorm) {
           api.logger.warn(`memos-local: better-sqlite3 resolved outside plugin dir: ${resolved}`);
           return false;
         }
@@ -182,6 +190,7 @@ const memosLocalPlugin = {
     const workspaceDir = api.resolvePath("~/.openclaw/workspace");
     const skillCtx = { ...ctx, workspaceDir };
     const skillEvolver = new SkillEvolver(store, engine, skillCtx);
+    skillEvolver.onSkillEvolved = (name, type) => telemetry.trackSkillEvolved(name, type);
     const skillInstaller = new SkillInstaller(store, skillCtx);
 
     let pluginVersion = "0.0.0";
@@ -257,6 +266,7 @@ const memosLocalPlugin = {
           return result;
         } catch (e) {
           ok = false;
+          telemetry.trackError(toolName, (e as Error)?.name ?? "unknown");
           throw e;
         } finally {
           const dur = performance.now() - t0;
@@ -720,6 +730,7 @@ const memosLocalPlugin = {
         parameters: Type.Object({}),
         execute: trackTool("memory_viewer", async () => {
           ctx.log.debug(`memory_viewer called`);
+          telemetry.trackViewerOpened();
           const url = `http://127.0.0.1:${viewerPort}`;
           return {
             content: [

apps/memos-local-openclaw/package.json

@@ -50,7 +50,6 @@
     "@huggingface/transformers": "^3.8.0",
     "@sinclair/typebox": "^0.34.48",
     "better-sqlite3": "^12.6.2",
-    "posthog-node": "^5.28.0",
     "puppeteer": "^24.38.0",
     "semver": "^7.7.4",
     "uuid": "^10.0.0"

apps/memos-local-openclaw/scripts/postinstall.cjs

@@ -112,7 +112,7 @@ try {
 function ensureDependencies() {
   phase(0, "检测核心依赖 / Check core dependencies");
 
-  const coreDeps = ["@sinclair/typebox", "uuid", "posthog-node", "@huggingface/transformers"];
+  const coreDeps = ["@sinclair/typebox", "uuid", "@huggingface/transformers"];
   const missing = [];
   for (const dep of coreDeps) {
     try {

apps/memos-local-openclaw/scripts/refresh-summaries.ts

@@ -62,36 +62,66 @@ async function main() {
     process.exit(1);
   }
 
+  const isAnthropic = cfg.provider === "anthropic"
+    || cfg.endpoint?.toLowerCase().includes("anthropic");
+
   console.log(`Summarizer: ${cfg.provider} / ${cfg.model}`);
 
   let endpoint = cfg.endpoint.replace(/\/+$/, "");
-  if (!endpoint.endsWith("/chat/completions")) endpoint += "/chat/completions";
+  if (isAnthropic) {
+    if (!endpoint.endsWith("/v1/messages") && !endpoint.endsWith("/messages")) {
+      endpoint += "/v1/messages";
+    }
+  } else {
+    if (!endpoint.endsWith("/chat/completions")) endpoint += "/chat/completions";
+  }
 
   async function callLLM(text: string): Promise<string> {
+    const headers: Record<string, string> = isAnthropic
+      ? {
+          "Content-Type": "application/json",
+          "x-api-key": cfg.apiKey,
+          "anthropic-version": "2023-06-01",
+        }
+      : {
+          "Content-Type": "application/json",
+          Authorization: `Bearer ${cfg.apiKey}`,
+        };
+
+    const body = isAnthropic
+      ? JSON.stringify({
+          model: cfg.model,
+          temperature: 0.1,
+          max_tokens: 4096,
+          system: TASK_SUMMARY_PROMPT,
+          messages: [{ role: "user", content: text }],
+        })
+      : JSON.stringify({
+          model: cfg.model,
+          temperature: 0.1,
+          max_tokens: 4096,
+          messages: [
+            { role: "system", content: TASK_SUMMARY_PROMPT },
+            { role: "user", content: text },
+          ],
+        });
+
     const resp = await fetch(endpoint, {
       method: "POST",
-      headers: {
-        "Content-Type": "application/json",
-        Authorization: `Bearer ${cfg.apiKey}`,
-      },
-      body: JSON.stringify({
-        model: cfg.model,
-        temperature: 0.1,
-        max_tokens: 4096,
-        messages: [
-          { role: "system", content: TASK_SUMMARY_PROMPT },
-          { role: "user", content: text },
-        ],
-      }),
+      headers,
+      body,
       signal: AbortSignal.timeout(60_000),
     });
 
     if (!resp.ok) {
-      const body = await resp.text();
-      throw new Error(`API ${resp.status}: ${body.slice(0, 200)}`);
+      const respBody = await resp.text();
+      throw new Error(`API ${resp.status}: ${respBody.slice(0, 200)}`);
     }
 
     const json = (await resp.json()) as any;
+    if (isAnthropic) {
+      return json.content?.find((c: any) => c.type === "text")?.text?.trim() ?? "";
+    }
     return json.choices[0]?.message?.content?.trim() ?? "";
   }
 

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

@@ -70,6 +70,7 @@ export function captureMessages(
     if (role === "user") {
       content = stripInboundMetadata(content);
     } else {
+      content = stripThinkingTags(content);
       content = stripEvidenceWrappers(content, evidenceTag);
     }
     if (!content.trim()) continue;
@@ -149,6 +150,13 @@ export function stripInboundMetadata(text: string): string {
   return stripEnvelopePrefix(result.join("\n")).trim();
 }
 
+/** Strip <think…>…</think⟩ blocks emitted by DeepSeek-style reasoning models. */
+const THINKING_TAG_RE = /<think[\s>][\s\S]*?<\/think>\s*/gi;
+
+function stripThinkingTags(text: string): string {
+  return text.replace(THINKING_TAG_RE, "");
+}
+
 function stripEnvelopePrefix(text: string): string {
   return text.replace(ENVELOPE_PREFIX_RE, "");
 }

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

@@ -51,8 +51,6 @@ export function resolveConfig(raw: Partial<MemosLocalConfig> | undefined, stateD
     },
     telemetry: {
       enabled: telemetryEnabled,
-      posthogApiKey: cfg.telemetry?.posthogApiKey ?? process.env.POSTHOG_API_KEY ?? "",
-      posthogHost: cfg.telemetry?.posthogHost ?? process.env.POSTHOG_HOST ?? "",
     },
   };
 }

apps/memos-local-openclaw/src/ingest/providers/index.ts

@@ -1,21 +1,56 @@
 import * as fs from "fs";
 import * as path from "path";
-import type { SummarizerConfig, Logger } from "../../types";
-import { summarizeOpenAI, summarizeTaskOpenAI, generateTaskTitleOpenAI, judgeNewTopicOpenAI, filterRelevantOpenAI, judgeDedupOpenAI } from "./openai";
+import type { SummarizerConfig, SummaryProvider, Logger } from "../../types";
+import { summarizeOpenAI, summarizeTaskOpenAI, judgeNewTopicOpenAI, filterRelevantOpenAI, judgeDedupOpenAI } from "./openai";
 import type { FilterResult, DedupResult } from "./openai";
 export type { FilterResult, DedupResult } from "./openai";
 import { summarizeAnthropic, summarizeTaskAnthropic, generateTaskTitleAnthropic, judgeNewTopicAnthropic, filterRelevantAnthropic, judgeDedupAnthropic } from "./anthropic";
 import { summarizeGemini, summarizeTaskGemini, generateTaskTitleGemini, judgeNewTopicGemini, filterRelevantGemini, judgeDedupGemini } from "./gemini";
 import { summarizeBedrock, summarizeTaskBedrock, generateTaskTitleBedrock, judgeNewTopicBedrock, filterRelevantBedrock, judgeDedupBedrock } from "./bedrock";
 
+/**
+ * Detect provider type from provider key name or base URL.
+ */
+function detectProvider(
+  providerKey: string | undefined,
+  baseUrl: string,
+): SummaryProvider {
+  const key = providerKey?.toLowerCase() ?? "";
+  const url = baseUrl.toLowerCase();
+  if (key.includes("anthropic") || url.includes("anthropic")) return "anthropic";
+  if (key.includes("gemini") || url.includes("generativelanguage.googleapis.com")) {
+    return "gemini";
+  }
+  if (key.includes("bedrock") || url.includes("bedrock")) return "bedrock";
+  return "openai_compatible";
+}
+
+/**
+ * Return the correct endpoint for a given provider and base URL.
+ */
+function normalizeEndpointForProvider(
+  provider: SummaryProvider,
+  baseUrl: string,
+): string {
+  const stripped = baseUrl.replace(/\/+$/, "");
+  if (provider === "anthropic") {
+    if (stripped.endsWith("/v1/messages")) return stripped;
+    return `${stripped}/v1/messages`;
+  }
+  if (stripped.endsWith("/chat/completions")) return stripped;
+  if (stripped.endsWith("/completions")) return stripped;
+  return `${stripped}/chat/completions`;
+}
+
 /**
  * Build a SummarizerConfig from OpenClaw's native model configuration (openclaw.json).
  * This serves as the final fallback when both strongCfg and plugin summarizer fail or are absent.
  */
 function loadOpenClawFallbackConfig(log: Logger): SummarizerConfig | undefined {
   try {
     const home = process.env.HOME ?? process.env.USERPROFILE ?? "";
-    const cfgPath = path.join(home, ".openclaw", "openclaw.json");
+    const ocHome = process.env.OPENCLAW_STATE_DIR || path.join(home, ".openclaw");
+    const cfgPath = path.join(ocHome, "openclaw.json");
     if (!fs.existsSync(cfgPath)) return undefined;
 
     const raw = JSON.parse(fs.readFileSync(cfgPath, "utf-8"));
@@ -36,13 +71,12 @@ function loadOpenClawFallbackConfig(log: Logger): SummarizerConfig | undefined {
     const apiKey: string | undefined = providerCfg.apiKey;
     if (!baseUrl || !apiKey) return undefined;
 
-    const endpoint = baseUrl.endsWith("/chat/completions")
-      ? baseUrl
-      : baseUrl.replace(/\/+$/, "") + "/chat/completions";
+    const provider = detectProvider(providerKey, baseUrl);
+    const endpoint = normalizeEndpointForProvider(provider, baseUrl);
 
-    log.debug(`OpenClaw fallback model: ${modelId} via ${baseUrl}`);
+    log.debug(`OpenClaw fallback model: ${modelId} via ${baseUrl} (${provider})`);
     return {
-      provider: "openai_compatible",
+      provider,
       endpoint,
       apiKey,
       model: modelId,