Function extendRepo

packages/effect-app/src/Model/Repository/ext.ts:34–363

(
  repo: Repository<T, Encoded, Evt, ItemType, IdKey, RSchema, RPublish, RProvided>
)

    : undefined

export const extendRepo = <
  T,
  Encoded extends FieldValues,
  Evt,
  ItemType extends string,
  IdKey extends keyof T & keyof Encoded,
  RSchema,
  RPublish,
  RProvided = never
>(
  repo: Repository<T, Encoded, Evt, ItemType, IdKey, RSchema, RPublish, RProvided>
) => {
  const get = (id: T[IdKey]) =>
    repo.find(id).pipe(
      Effect.flatMap(Option.match({
        onNone: () => Effect.fail(new NotFoundError<ItemType>({ type: repo.itemType, id })),
        onSome: Effect.succeed
      }))
    )
  function saveManyWithPure_<
    R,
    A,
    E,
    S1 extends T,
    S2 extends T
  >(
    items: Iterable<S1>,
    pure: Effect.Effect<A, E, FixEnv<R, Evt, readonly S1[], readonly S2[]>>
  ) {
    return saveAllWithEffectInt(
      runTerm(pure, [...items])
    )
  }

  function saveWithPure_<
    R,
    A,
    E,
    S1 extends T,
    S2 extends T
  >(
    item: S1,
    pure: Effect.Effect<A, E, FixEnv<R, Evt, S1, S2>>
  ) {
    return saveAllWithEffectInt(
      runTerm(pure, item)
        .pipe(Effect
          .map(([item, events, a]) => [[item], events, a]))
    )
  }

  function saveAllWithEffectInt<
    P extends T,
    R,
    E,
    A
  >(
    gen: Effect.Effect<readonly [Iterable<P>, Iterable<Evt>, A], E, R>