Function fixture

packages/core/api/src/server/request-scoped.test.ts:11–85

(
  options: {
    background?: boolean;
    failTask?: boolean;
    failRequest?: boolean;
    blockRequest?: boolean;
  } = {},
)

) {}

const fixture = (
  options: {
    background?: boolean;
    failTask?: boolean;
    failRequest?: boolean;
    blockRequest?: boolean;
  } = {},
) => {
  const resources: Resource["Service"][] = [];
  const gates: ReturnType<typeof Promise.withResolvers<void>>[] = [];
  const keptAlive: Promise<void>[] = [];
  const writes: number[] = [];
  const entered = Promise.withResolvers<void>();
  const resource = Layer.effect(Resource)(
    Effect.acquireRelease(
      Effect.sync(() => {
        const acquired = { id: resources.length, closed: false };
        resources.push(acquired);
        gates.push(Promise.withResolvers<void>());
        return acquired;
      }),
      (acquired) =>
        Effect.sync(() => {
          acquired.closed = true;
        }),
    ),
  );
  const routes = HttpRouter.add(
    "GET",
    "/",
    Effect.gen(function* () {
      const acquired = yield* Resource;
      if (options.background !== false) {
        const tasks = yield* RequestBackgroundTasks;
        const gate = gates[acquired.id];
        if (!gate) return yield* Effect.die("Missing request gate");
        const task = Effect.runPromise(
          Effect.gen(function* () {
            yield* Effect.promise(() => gate.promise);
            if (options.failTask) return yield* Effect.fail("Background failure");
            if (acquired.closed)
              return yield* Effect.fail("Resource closed before background write");
            writes.push(acquired.id);
          }),
        );
        keptAlive.push(tasks.retain(task));
      }
      entered.resolve();
      if (options.blockRequest) return yield* Effect.never;
      if (options.failRequest) return yield* Effect.die("Request failure");
      return HttpServerResponse.empty();
    }),
  );
  const app = HttpRouter.toWebHandler(
    routes.pipe(
      Layer.provide(requestScopedMiddleware(resource).layer),
      Layer.provideMerge(HttpServer.layerServices),
    ),