Method start

packages/memos-core/src/hub/server.ts:63–130

()

  }

  async start(): Promise<string> {
    if (!this.teamToken) {
      throw new Error("team token is required to start hub mode");
    }
    if (this.server?.listening) {
      return `http://127.0.0.1:${this.port}`;
    }

    this.server = http.createServer(async (req, res) => {
      try {
        await this.handle(req, res);
      } catch (err: any) {
        const code = err?.statusCode ?? 500;
        const message = code === 413 ? "request_body_too_large" : "internal_error";
        this.opts.log.warn(`hub server error: ${String(err)}`);
        res.statusCode = code;
        res.setHeader("content-type", "application/json");
        res.end(JSON.stringify({ error: message }));
      }
    });

    const MAX_PORT_RETRIES = 3;
    let hubPort = this.port;
    await new Promise<void>((resolve, reject) => {
      let retries = 0;
      const onError = (err: NodeJS.ErrnoException) => {
        if (err.code === "EADDRINUSE" && retries < MAX_PORT_RETRIES) {
          retries++;
          hubPort = this.port + retries;
          this.opts.log.warn(`Hub port ${hubPort - 1} in use, trying ${hubPort}`);
          this.server!.listen(hubPort, "0.0.0.0");
        } else {
          this.server?.off("listening", onListening);
          reject(err);
        }
      };
      const onListening = () => {
        this.server?.off("error", onError);
        if (hubPort !== this.port) {
          this.opts.log.info(`Hub started on fallback port ${hubPort} (configured: ${this.port})`);
        }
        resolve();
      };
      this.server!.on("error", onError);
      this.server!.once("listening", onListening);
      this.server!.listen(hubPort, "0.0.0.0");
    });

    const bootstrap = this.userManager.ensureBootstrapAdmin(
      this.authSecret,
      "admin",
      this.authState.bootstrapAdminUserId,
      this.authState.bootstrapAdminToken,
    );
    if (bootstrap.token) {
      this.authState.bootstrapAdminUserId = bootstrap.user.id;
      this.authState.bootstrapAdminToken = bootstrap.token;
      this.saveAuthState();