Function withWorkOSStub

apps/cloud/src/auth/workos.node.test.ts:121–175

(
  keypair: Keypair,
  use: (stub: WorkOSStub) => Promise<A>,
)

};

const withWorkOSStub = async <A>(
  keypair: Keypair,
  use: (stub: WorkOSStub) => Promise<A>,
): Promise<A> => {
  let keys: ReadonlyArray<JWK> = [keypair.publicJwk];
  const requests: RecordedRequest[] = [];
  const server = createServer((request, response) => {
    // oxlint-disable-next-line executor/no-promise-catch -- boundary: Node's request callback cannot await, so the fixture converts async failures into a stable HTTP 500
    void (async () => {
      const path = request.url ?? "/";
      const body = request.method === "POST" ? await readJsonBody(request) : null;
      requests.push({ method: request.method ?? "GET", path, body });

      if (request.method === "GET" && path === `/sso/jwks/${CLIENT_ID}`) {
        writeJson(response, 200, { keys: keys.map((key) => ({ ...key })) } satisfies JSONWebKeySet);
        return;
      }

      if (request.method === "POST" && path === "/user_management/authenticate") {
        const refreshed = await signAccessToken(keypair, {
          sessionId: "session_refreshed",
        });
        writeJson(response, 200, {
          user: workosUserResponse,
          organization_id: "org_test",
          access_token: refreshed,
          refresh_token: "refresh_next",
          authentication_method: "Password",
        });
        return;
      }

      writeJson(response, 404, { error: "unexpected request" });
    })().catch((_error: unknown) => {
      writeJson(response, 500, {
        error: "fixture server failed",
      });
    });
  });

  await new Promise<void>((resolve) => server.listen(0, "127.0.0.1", resolve));
  const address = server.address() as AddressInfo;
  const stub: WorkOSStub = {
    baseUrl: `http://127.0.0.1:${address.port}`,
    requests: () => requests,
    setKeys: (next) => {
      keys = next;
    },
  };

  return use(stub).finally(() => {
    server.closeAllConnections();
    server.close();
  });
};

const runAuthenticate = (sessionData: string, baseUrl: string) => {
  Object.assign(env, {