Class DefaultHubRuntime

apps/memos-local-plugin/core/hub/runtime.ts:70–368

}

class DefaultHubRuntime implements HubRuntime {
  private server: HubServerRuntime | null = null;
  private client: HubClientRuntime | null = null;
  private status: HubAdminPayload["status"] = "disabled";
  private error: string | null = null;

  constructor(
    private readonly deps: {
      repos: Repos;
      config: ResolvedConfig;
      log: Logger;
      agent: string;
      version: string;
    },
  ) {}

  async start(): Promise<void> {
    if (!this.deps.config.hub.enabled) {
      this.status = "disabled";
      return;
    }
    this.status = "starting";
    this.error = null;
    try {
      if (this.deps.config.hub.role === "hub") {
        this.server = new HubServerRuntime({
          repo: this.deps.repos.hub,
          config: this.deps.config,
          log: this.deps.log.child({ channel: "core.hub.server" }),
          version: this.deps.version,
        });
        await this.server.start();
        this.status = "running";
      } else {
        this.client = new HubClientRuntime({
          repo: this.deps.repos.hub,
          config: this.deps.config,
          log: this.deps.log.child({ channel: "core.hub.client" }),
        });
        const conn = await this.client.start();
        this.status = conn?.userToken ? "connected" : "pending";
      }
    } catch (err) {
      this.status = "error";
      this.error = err instanceof Error ? err.message : String(err);
      this.deps.log.warn("hub.start.failed", { err: this.error });
    }
  }

  async stop(): Promise<void> {
    await this.client?.stop();
    await this.server?.stop();
    this.client = null;
    this.server = null;
  }

  async adminSnapshot(): Promise<HubAdminPayload> {
    const cfg = this.deps.config.hub;