Function layer

packages/bun-test-effect/src/internal/internal.ts:182–247

(
    layer_: Layer.Layer<R, E>,
    options?: {
      readonly memoMap?: Layer.MemoMap;
      readonly timeout?: Duration.DurationInput;
      readonly excludeTestServices?: ExcludeTestServices;
    }
  )

/** @internal */
export const layer =
  <R, E, const ExcludeTestServices extends boolean = false>(
    layer_: Layer.Layer<R, E>,
    options?: {
      readonly memoMap?: Layer.MemoMap;
      readonly timeout?: Duration.DurationInput;
      readonly excludeTestServices?: ExcludeTestServices;
    }
  ): {
    (f: (it: Buntest.Buntest.MethodsNonLive<R, ExcludeTestServices>) => void): void;
    (name: string, f: (it: Buntest.Buntest.MethodsNonLive<R, ExcludeTestServices>) => void): void;
  } =>
  (
    ...args:
      | [name: string, f: (it: Buntest.Buntest.MethodsNonLive<R, ExcludeTestServices>) => void]
      | [f: (it: Buntest.Buntest.MethodsNonLive<R, ExcludeTestServices>) => void]
  ) => {
    const excludeTestServices = options?.excludeTestServices ?? false;
    const withTestEnv = excludeTestServices
      ? (layer_ as Layer.Layer<R | TestServices.TestServices, E>)
      : Layer.provideMerge(layer_, TestEnv);
    const memoMap = options?.memoMap ?? Effect.runSync(Layer.makeMemoMap);
    const scope = Effect.runSync(Scope.make());
    const runtimeEffect = Layer.toRuntimeWithMemoMap(withTestEnv, memoMap).pipe(
      Scope.extend(scope),
      Effect.orDie,
      Effect.cached,
      Effect.runSync
    );

    const makeIt = (): Buntest.Buntest.MethodsNonLive<R, ExcludeTestServices> => ({
      effect: makeTester<TestServices.TestServices | R>((effect) =>
        Effect.flatMap(runtimeEffect, (runtime) => effect.pipe(Effect.provide(runtime)))
      ),

      scoped: makeTester<TestServices.TestServices | Scope.Scope | R>((effect) =>
        Effect.flatMap(runtimeEffect, (runtime) =>
          effect.pipe(Effect.scoped, Effect.provide(runtime))
        )
      ),
      flakyTest,
      layer<R2, E2>(
        nestedLayer: Layer.Layer<R2, E2, R>,
        options?: {
          readonly timeout?: Duration.DurationInput;
        }
      ) {
        return layer(Layer.provideMerge(nestedLayer, withTestEnv), {
          ...options,
          memoMap,
          excludeTestServices,
        });
      },
    });

    if (args.length === 1) {
      beforeAll(() => runPromise()(Effect.asVoid(runtimeEffect)));
      afterAll(() => runPromise()(Scope.close(scope, Exit.void)));
      return args[0](makeIt());