Function makeTestHttpServer

packages/core/sdk/src/testing.ts:96–129

(
  serverLayer: Layer.Layer<never, any, any>,
)

> => makeTestHttpServer(serverLayer);

const makeTestHttpServer = (
  serverLayer: Layer.Layer<never, any, any>,
): Effect.Effect<
  TestHttpServerShape,
  TestHttpServerAddressError | TestHttpServerServeError,
  EffectScope.Scope
> =>
  Effect.gen(function* () {
    const context = yield* Layer.build(
      Layer.fresh(serverLayer.pipe(Layer.provideMerge(NodeHttpServer.layerTest))),
    ).pipe(Effect.mapError((cause) => new TestHttpServerServeError({ cause })));
    const server = Context.get(context, HttpServer.HttpServer);
    const address = server.address;
    if (!Predicate.isTagged(address, "TcpAddress")) {
      return yield* new TestHttpServerAddressError({ address });
    }
    const client = Context.get(context, HttpClient.HttpClient);
    // Under a loaded machine the listen callback can fire before the socket
    // reliably accepts; probe at the TCP level (no HTTP request, so handlers
    // that record requests never see it) until a connect succeeds.
    yield* Effect.callback<void, TestHttpServerServeError>((resume) => {
      const socket = createConnection({ host: "127.0.0.1", port: address.port }, () => {
        socket.end();
        resume(Effect.void);
      });
      socket.on("error", (cause) => resume(Effect.fail(new TestHttpServerServeError({ cause }))));
    }).pipe(Effect.retry(Schedule.both(Schedule.spaced("10 millis"), Schedule.recurs(100))));
    const baseUrl = `http://127.0.0.1:${address.port}`;
    return {
      baseUrl,
      httpClientLayer: Layer.succeed(HttpClient.HttpClient, client),
      url: (path = "") => new URL(path, baseUrl).toString(),
    };
  });