fix(memos-local): resolve telemetry credentials path in ESM mode

The plugin runs as ESM (type: module) but telemetry.ts relied on
__dirname which is undefined in ESM. Credentials file existed on disk
but was never found, silently disabling all telemetry since day one.

Now accepts pluginDir from index.ts (resolved via import.meta.url)
and uses it as primary search path for telemetry.credentials.json.

Made-with: Cursor

Author: jiachengzhen

apps/memos-local-openclaw/index.ts

@@ -225,7 +225,7 @@ const memosLocalPlugin = {
       const pkg = JSON.parse(fs.readFileSync(path.join(__dirname, "package.json"), "utf-8"));
       pluginVersion = pkg.version ?? pluginVersion;
     } catch {}
-    const telemetry = new Telemetry(ctx.config.telemetry ?? {}, stateDir, pluginVersion, ctx.log);
+    const telemetry = new Telemetry(ctx.config.telemetry ?? {}, stateDir, pluginVersion, ctx.log, pluginDir);
 
     // Install bundled memory-guide skill so OpenClaw loads it (write from embedded content so it works regardless of deploy layout)
     const workspaceSkillsDir = path.join(workspaceDir, "skills");

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

@@ -18,28 +18,27 @@ export interface TelemetryConfig {
   enabled?: boolean;
 }
 
-function loadTelemetryCredentials(): { endpoint: string; pid: string; env: string } {
+function loadTelemetryCredentials(pluginDir?: string): { endpoint: string; pid: string; env: string } {
   if (process.env.MEMOS_ARMS_ENDPOINT) {
     return {
       endpoint: process.env.MEMOS_ARMS_ENDPOINT,
       pid: process.env.MEMOS_ARMS_PID ?? "",
       env: process.env.MEMOS_ARMS_ENV ?? "prod",
     };
   }
-  try {
-    const credPath = path.resolve(__dirname, "..", "telemetry.credentials.json");
-    const raw = fs.readFileSync(credPath, "utf-8");
-    const creds = JSON.parse(raw);
-    if (creds.endpoint) return { endpoint: creds.endpoint, pid: creds.pid ?? "", env: creds.env ?? "prod" };
-  } catch {}
+  const bases = pluginDir ? [pluginDir, path.join(pluginDir, "src")] : [];
+  if (typeof __dirname === "string") bases.push(path.resolve(__dirname, ".."), __dirname);
+  const candidates = bases.map(b => path.join(b, "telemetry.credentials.json"));
+  for (const credPath of candidates) {
+    try {
+      const raw = fs.readFileSync(credPath, "utf-8");
+      const creds = JSON.parse(raw);
+      if (creds.endpoint) return { endpoint: creds.endpoint, pid: creds.pid ?? "", env: creds.env ?? "prod" };
+    } catch {}
+  }
   return { endpoint: "", pid: "", env: "prod" };
 }
 
-const _creds = loadTelemetryCredentials();
-const ARMS_ENDPOINT = _creds.endpoint;
-const ARMS_PID = _creds.pid;
-const ARMS_ENV = _creds.env;
-
 const FLUSH_AT = 10;
 const FLUSH_INTERVAL_MS = 30_000;
 const SEND_TIMEOUT_MS = 30_000;
@@ -67,19 +66,27 @@ export class Telemetry {
   private flushTimer: ReturnType<typeof setInterval> | null = null;
   private sessionId: string;
   private firstSeenDate: string;
+  private armsEndpoint: string;
+  private armsPid: string;
+  private armsEnv: string;
 
-  constructor(config: TelemetryConfig, stateDir: string, pluginVersion: string, log: Logger) {
+  constructor(config: TelemetryConfig, stateDir: string, pluginVersion: string, log: Logger, pluginDir?: string) {
     this.log = log;
     this.pluginVersion = pluginVersion;
     this.enabled = config.enabled !== false;
     this.distinctId = this.loadOrCreateAnonymousId(stateDir);
     this.firstSeenDate = this.loadOrCreateFirstSeen(stateDir);
     this.sessionId = this.loadOrCreateSessionId(stateDir);
 
-    if (!this.enabled || !ARMS_ENDPOINT) {
+    const creds = loadTelemetryCredentials(pluginDir);
+    this.armsEndpoint = creds.endpoint;
+    this.armsPid = creds.pid;
+    this.armsEnv = creds.env;
+
+    if (!this.enabled || !this.armsEndpoint) {
       this.enabled = false;
       this.log.debug(
-        !ARMS_ENDPOINT
+        !this.armsEndpoint
           ? "Telemetry disabled (no credentials configured)"
           : "Telemetry disabled (opt-out)",
       );
@@ -192,8 +199,8 @@ export class Telemetry {
   private buildPayload(events: ArmsEvent[]): Record<string, unknown> {
     return {
       app: {
-        id: ARMS_PID,
-        env: ARMS_ENV,
+        id: this.armsPid,
+        env: this.armsEnv,
         version: this.pluginVersion,
         type: "node",
       },
@@ -212,7 +219,7 @@ export class Telemetry {
     const payload = this.buildPayload(batch);
 
     try {
-      const resp = await fetch(ARMS_ENDPOINT, {
+      const resp = await fetch(this.armsEndpoint, {
         method: "POST",
         headers: { "Content-Type": "text/plain" },
         body: JSON.stringify(payload),