Method handle

packages/memos-core/src/hub/server.ts:273–1075

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

  }

  private async handle(req: http.IncomingMessage, res: http.ServerResponse): Promise<void> {
    const url = new URL(req.url || "/", `http://127.0.0.1:${this.port}`);
    const routePath = url.pathname;

    if (req.method === "GET" && routePath === "/api/v1/hub/info") {
      return this.json(res, 200, {
        teamName: this.teamName,
        version: "0.0.0",
        apiVersion: "v1",
        hubInstanceId: this.hubInstanceId,
      });
    }

    if (req.method === "POST" && routePath === "/api/v1/hub/join") {
      const body = await this.readJson(req);
      if (!body || body.teamToken !== this.teamToken) {
        return this.json(res, 403, { error: "invalid_team_token" });
      }
      const username = String(body.username || `user-${randomUUID().slice(0, 8)}`);
      const joinIp = (typeof body.clientIp === "string" && body.clientIp)
        || (req.headers["x-client-ip"] as string)?.trim()
        || (req.headers["x-forwarded-for"] as string)?.split(",")[0]?.trim()
        || req.socket.remoteAddress || "";
      const identityKey = typeof body.identityKey === "string" ? body.identityKey.trim() : "";
      const dryRun = body.dryRun === true;

      const identityMatch = identityKey
        ? this.userManager.findByIdentityKey(identityKey)
        : null;

      if (identityMatch) {
        if (!dryRun) {
          try { this.opts.store.updateHubUserActivity(identityMatch.id, joinIp); } catch { /* best-effort */ }
        }

        if (identityMatch.status === "active") {
          if (dryRun) return this.json(res, 200, { status: "active", dryRun: true });
          const token = issueUserToken(
            { userId: identityMatch.id, username: identityMatch.username, role: identityMatch.role, status: "active" },
            this.authSecret,
          );
          this.userManager.approveUser(identityMatch.id, token);
          return this.json(res, 200, { status: "active", userId: identityMatch.id, userToken: token, identityKey: identityMatch.identityKey || identityKey });
        }
        if (identityMatch.status === "pending") {
          if (dryRun) return this.json(res, 200, { status: "pending", dryRun: true });
          this.notifyAdmins("user_join_request", "user", identityMatch.username, "", { dedup: true });
          return this.json(res, 200, { status: "pending", userId: identityMatch.id, identityKey: identityMatch.identityKey || identityKey });
        }
        if (identityMatch.status === "rejected") {
          if (dryRun) return this.json(res, 200, { status: "rejected", dryRun: true });
          if (body.reapply === true) {
            this.userManager.resetToPending(identityMatch.id);
            this.notifyAdmins("user_join_request", "user", identityMatch.username, "");
            this.opts.log.info(`Hub: rejected user "${identityMatch.username}" (${identityMatch.id}) re-applied, reset to pending`);
            return this.json(res, 200, { status: "pending", userId: identityMatch.id, identityKey: identityMatch.identityKey || identityKey });
          }
          return this.json(res, 200, { status: "rejected", userId: identityMatch.id });