Function ContextProvider

packages/infra/src/ContextProvider.ts:93–134

(
  input: {
    effect: Effect.Effect<
      | Effect.Effect<ContextProviderA, never, ContextProviderR>
      | (() => Generator<
        Effect.Effect<any, never, ContextProviderR>,
        ContextProviderA
      >),
      MakeContextProviderE,
      MakeContextProviderR | Scope.Scope
    >
    dependencies?: Dependencies
  }
)

// Effect Rpc Middleware: for single tag providing, we could use Provides, for providing Context or Layer (bad boy) we could use Wrap..
export const ContextProvider = <
  ContextProviderA,
  MakeContextProviderE,
  MakeContextProviderR,
  ContextProviderR extends Scope.Scope,
  Dependencies extends NonEmptyReadonlyArray<Layer.Any>
>(
  input: {
    effect: Effect.Effect<
      | Effect.Effect<ContextProviderA, never, ContextProviderR>
      | (() => Generator<
        Effect.Effect<any, never, ContextProviderR>,
        ContextProviderA
      >),
      MakeContextProviderE,
      MakeContextProviderR | Scope.Scope
    >
    dependencies?: Dependencies
  }
) => {
  const ctx = Context.Service<
    ContextProviderId,
    Effect.Effect<ContextProviderA, never, ContextProviderR>
  >(
    "ContextProvider"
  )
  const e = input.effect.pipe(
    Effect.map((eg) => (eg as any)[Symbol.toStringTag] === "GeneratorFunction" ? Effect.fnUntraced(eg as any)() : eg)
  )
  const l = Layer.effect(ctx, e as any)
  return Object.assign(ctx, {
    Default: l.pipe(
      input.dependencies ? Layer.provide([...input.dependencies] as [Layer.Any, ...Layer.Any[]]) as any : (_: any) => _
    ) satisfies Layer.Layer<
      ContextProviderId,
      | MakeContextProviderE
      | LayerUtils.GetLayersError<Dependencies>,
      | Exclude<MakeContextProviderR, LayerUtils.GetLayersSuccess<Dependencies>>
      | LayerUtils.GetLayersContext<Dependencies>
    >
  })
}

// Note: the type here must be aligned with mergeContextProviders
export const MergedContextProvider = <