Function loadTelemetryCredentials

packages/memos-core/src/telemetry.ts:22–41

(pluginDir?: 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",
    };
  }
  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 FLUSH_AT = 10;
const FLUSH_INTERVAL_MS = 30_000;