Method handleSaveConfig

packages/memos-core/src/viewer/server.ts:3115–3253

(req: http.IncomingMessage, res: http.ServerResponse)

  }

  private handleSaveConfig(req: http.IncomingMessage, res: http.ServerResponse): void {
    this.readBody(req, async (body) => {
      try {
        const newCfg = JSON.parse(body);
        const cfgPath = this.getOpenClawConfigPath();
        let raw: Record<string, unknown> = {};
        if (fs.existsSync(cfgPath)) {
          raw = JSON.parse(fs.readFileSync(cfgPath, "utf-8"));
        }

        if (!raw.plugins) raw.plugins = {};
        const plugins = raw.plugins as Record<string, unknown>;
        if (!plugins.entries) plugins.entries = {};
        const entries = plugins.entries as Record<string, unknown>;
        const entryKey = entries["memos-local-openclaw-plugin"] ? "memos-local-openclaw-plugin"
          : entries["memos-local"] ? "memos-local"
          : entries["memos-lite-openclaw-plugin"] ? "memos-lite-openclaw-plugin"
          : entries["memos-lite"] ? "memos-lite"
          : "memos-local-openclaw-plugin";
        if (!entries[entryKey]) entries[entryKey] = { enabled: true };
        const entry = entries[entryKey] as Record<string, unknown>;
        if (!entry.config) entry.config = {};
        const config = entry.config as Record<string, unknown>;

        const oldSharing = config.sharing as Record<string, unknown> | undefined;
        const oldSharingRole = oldSharing?.role as string | undefined;
        const oldSharingEnabled = Boolean(oldSharing?.enabled);
        const oldClientHubAddress = String((oldSharing?.client as Record<string, unknown>)?.hubAddress || "");

        if (newCfg.embedding) config.embedding = newCfg.embedding;
        if (newCfg.summarizer) config.summarizer = newCfg.summarizer;
        if (newCfg.skillEvolution) config.skillEvolution = newCfg.skillEvolution;
        if (newCfg.viewerPort) config.viewerPort = newCfg.viewerPort;
        if (newCfg.taskAutoFinalizeHours !== undefined) config.taskAutoFinalizeHours = newCfg.taskAutoFinalizeHours;
        if (newCfg.telemetry !== undefined) config.telemetry = newCfg.telemetry;
        if (newCfg.sharing !== undefined) {
          const existing = (config.sharing as Record<string, unknown>) || {};
          const merged = { ...existing, ...newCfg.sharing };
          if (newCfg.sharing.capabilities && existing.capabilities) {
            merged.capabilities = { ...(existing.capabilities as Record<string, unknown>), ...newCfg.sharing.capabilities };
          }
          if (merged.role === "client" && merged.client) {
            const clientCfg = merged.client as Record<string, unknown>;
            const addr = String(clientCfg.hubAddress || "");
            if (addr && oldSharingRole === "hub" && oldSharingEnabled) {
              const selfHubPort = (oldSharing?.hub as Record<string, unknown>)?.port ?? 18800;
              const localIPs = this.getLocalIPs();
              localIPs.push("127.0.0.1", "localhost", "0.0.0.0");
              try {
                const u = new URL(addr.startsWith("http") ? addr : `http://${addr}`);
                const targetPort = u.port || (u.protocol === "https:" ? "443" : "80");
                if (localIPs.includes(u.hostname) && targetPort === String(selfHubPort)) {
                  res.writeHead(400, { "Content-Type": "application/json" });
                  res.end(JSON.stringify({ error: "cannot_join_self" }));
                  return;
                }
              } catch {}
            }