import { Effect } from "@effect/io/Effect";
import { Opt } from "@effect-ts-app/core/Option";
import { Chunk } from "@fp-ts/data/Chunk";
import { Predicate } from "@fp-ts/data/Predicate";
import { PureEnvEnv } from "@effect-ts-app/boilerplate-prelude/_ext/Pure";
import { NonEmptyReadonlyArray } from "@fp-ts/data/ReadonlyArray";
import type { InvalidStateError, OptimisticConcurrencyException } from "../errors.js";
import { NotFoundError } from "../errors.js";
import type { RequestContext } from "../lib/RequestContext.js";
import { ContextMap } from "../services/Store.js";
import type { Filter } from "../services/Store.js";
import type { FixEnv, PureLogT } from "@effect-ts-app/boilerplate-prelude/_ext/Pure";
import { Pure } from "@effect-ts-app/boilerplate-prelude/_ext/Pure";
import type { ParserEnv } from "@effect-ts-app/schema/custom/Parser";
/**
 * @tsplus type Repository
 */
export interface Repository<T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, Id extends string, ItemType extends string> {
    itemType: ItemType;
    find: (id: Id) => Effect<ContextMap | RequestContext, never, Opt<T>>;
    all: Effect<ContextMap, never, Chunk<T>>;
    save: (items: Iterable<T>, events?: Iterable<Evt>) => Effect<ContextMap | RequestContext, InvalidStateError | OptimisticConcurrencyException, void>;
    utils: {
        mapReverse: (pm: PM, setEtag: (id: string, eTag: string | undefined) => void) => unknown;
        parse: (a: unknown, env?: ParserEnv | undefined) => T;
        all: Effect<never, never, Chunk<PM>>;
        filter: (filter: Filter<PM>, cursor?: {
            limit?: number;
            skip?: number;
        }) => Effect<never, never, Chunk<PM>>;
    };
}
export interface PureDSL<S, S2, W> {
    get: ReturnType<typeof Pure.get<S>>;
    set: typeof Pure.set<S2>;
    log: (...w: W[]) => PureLogT<W>;
}
export declare const AnyPureDSL: PureDSL<any, any, any>;
/**
 * @tsplus fluent Repository get
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function get<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>, id: Id): import("@effect/io/Effect").Effect<RequestContext | ContextMap, NotFoundError<ItemType>, T>;
/**
 * @tsplus fluent Repository filter
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function filter<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>, filter: Predicate<T>): import("@effect/io/Effect").Effect<ContextMap, never, import("@fp-ts/data/Chunk").Chunk<T>>;
/**
 * @tsplus fluent Repository filterAll
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function filterAll<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S extends T>(self: Repository<T, PM, Evt, Id, ItemType>, map: (items: Chunk<T>) => Chunk<S>): import("@effect/io/Effect").Effect<ContextMap, never, import("@fp-ts/data/Chunk").Chunk<S>>;
/**
 * @tsplus fluent Repository collect
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function collect<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S extends T>(self: Repository<T, PM, Evt, Id, ItemType>, collect: (item: T) => Opt<S>): import("@effect/io/Effect").Effect<ContextMap, never, import("@fp-ts/data/Chunk").Chunk<S>>;
/**
 * @tsplus getter Repository log
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function log<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string>(_: Repository<T, PM, Evt, Id, ItemType>): (evt: Evt) => PureLogT<any>;
/**
 * TODO: project inside the db.
 * @tsplus fluent Repository projectEffect
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function projectEffect<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S, R, E>(self: Repository<T, PM, Evt, Id, ItemType>, map: Effect<R, E, {
    filter?: Filter<PM>;
    collect: (t: PM) => Opt<S>;
    limit?: number;
    skip?: number;
}>): import("@effect/io/Effect").Effect<R, E, import("@fp-ts/data/Chunk").Chunk<S>>;
/**
 * TODO: project inside the db.
 * @tsplus fluent Repository project
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function project<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S>(self: Repository<T, PM, Evt, Id, ItemType>, map: {
    filter?: Filter<PM>;
    collect: (t: PM) => Opt<S>;
    limit?: number;
    skip?: number;
}): import("@effect/io/Effect").Effect<never, never, import("@fp-ts/data/Chunk").Chunk<S>>;
/**
 * @tsplus fluent Repository queryEffect
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function queryEffect<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, R, E, S>(self: Repository<T, PM, Evt, Id, ItemType>, map: Effect<R, E, {
    filter?: Filter<PM>;
    collect: (t: T) => Opt<S>;
    limit?: number;
    skip?: number;
}>): import("@effect/io/Effect").Effect<ContextMap | R, E, import("@fp-ts/data/Chunk").Chunk<S>>;
/**
 * @tsplus fluent Repository queryOneEffect
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function queryOneEffect<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, R, E, S>(self: Repository<T, PM, Evt, Id, ItemType>, map: Effect<R, E, {
    filter?: Filter<PM>;
    collect: (t: T) => Opt<S>;
}>): import("@effect/io/Effect").Effect<ContextMap | R, E | NotFoundError<ItemType>, S>;
/**
 * @tsplus fluent Repository query
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function query<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S>(self: Repository<T, PM, Evt, Id, ItemType>, map: {
    filter?: Filter<PM>;
    collect: (t: T) => Opt<S>;
    limit?: number;
    skip?: number;
}): import("@effect/io/Effect").Effect<ContextMap, never, import("@fp-ts/data/Chunk").Chunk<S>>;
/**
 * @tsplus fluent Repository queryOne
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function queryOne<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S>(self: Repository<T, PM, Evt, Id, ItemType>, map: {
    filter?: Filter<PM>;
    collect: (t: T) => Opt<S>;
}): import("@effect/io/Effect").Effect<ContextMap, NotFoundError<ItemType>, S>;
/**
 * @tsplus fluent Repository queryAndSavePureEffect
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function queryAndSavePureEffect<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, R, E, S extends T = T>(self: Repository<T, PM, Evt, Id, ItemType>, map: Effect<R, E, {
    filter: Filter<PM>;
    collect: (t: T) => Opt<S>;
    limit?: number;
    skip?: number;
}>): <R2, A, E2, S2 extends T>(pure: import("@effect/io/Effect").Effect<FixEnv<R2, Evt, import("@fp-ts/data/Chunk").Chunk<S>, Iterable<S2>>, E2, A>) => import("@effect/io/Effect").Effect<RequestContext | ContextMap | R | Exclude<R2, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, import("@fp-ts/data/Chunk").Chunk<S>, Iterable<S2>>;
}>, InvalidStateError | OptimisticConcurrencyException | E | E2, A>;
/**
 * @tsplus fluent Repository queryAndSavePure
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function queryAndSavePure<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string, S extends T = T>(self: Repository<T, PM, Evt, Id, ItemType>, map: {
    filter: Filter<PM>;
    collect: (t: T) => Opt<S>;
    limit?: number;
    skip?: number;
}): <R2, A, E2, S2 extends T>(pure: import("@effect/io/Effect").Effect<FixEnv<R2, Evt, import("@fp-ts/data/Chunk").Chunk<S>, Iterable<S2>>, E2, A>) => import("@effect/io/Effect").Effect<RequestContext | ContextMap | Exclude<R2, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, import("@fp-ts/data/Chunk").Chunk<S>, Iterable<S2>>;
}>, InvalidStateError | OptimisticConcurrencyException | E2, A>;
/**
 * @tsplus getter Repository saveManyWithPure
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function saveManyWithPure<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>): <R, A, E, S1 extends T, S2 extends T>(pure: import("@effect/io/Effect").Effect<FixEnv<R, Evt, import("@fp-ts/data/Chunk").Chunk<S1>, Iterable<S2>>, E, A>) => (items: Iterable<S1>) => import("@effect/io/Effect").Effect<RequestContext | ContextMap | Exclude<R, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, import("@fp-ts/data/Chunk").Chunk<S1>, Iterable<S2>>;
}>, InvalidStateError | OptimisticConcurrencyException | E, A>;
/**
 * @tsplus fluent Repository byIdAndSaveWithPure
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function byIdAndSaveWithPure<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>, id: Id): <R, A, E, S2 extends T>(pure: import("@effect/io/Effect").Effect<FixEnv<R, Evt, T, S2>, E, A>) => import("@effect/io/Effect").Effect<RequestContext | ContextMap | Exclude<R, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, T, S2>;
}>, InvalidStateError | OptimisticConcurrencyException | E | NotFoundError<ItemType>, A>;
/**
 * NOTE: it's not as composable, only useful when the request is simple, and only this part needs request args.
 * @tsplus getter Repository handleByIdAndSaveWithPure
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function handleByIdAndSaveWithPure<Id extends string, T extends {
    id: Id;
}, PM extends {
    id: string;
}, Evt, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>): <Req extends {
    id: Id;
}, Context_1, R, A, E, S2 extends T>(pure: (req: Req, ctx: Context_1) => import("@effect/io/Effect").Effect<FixEnv<R, Evt, T, S2>, E, A>) => (req: Req, ctx: Context_1) => import("@effect/io/Effect").Effect<RequestContext | ContextMap | Exclude<R, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, T, S2>;
}>, InvalidStateError | OptimisticConcurrencyException | E | NotFoundError<ItemType>, A>;
/**
 * @tsplus fluent Repository saveManyWithPure_
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function saveManyWithPure_<Id extends string, R, T extends {
    id: Id;
}, PM extends {
    id: string;
}, A, E, Evt, S1 extends T, S2 extends T, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>, items: Iterable<S1>, pure: Effect<FixEnv<R, Evt, Chunk<S1>, Iterable<S2>>, E, A>): import("@effect/io/Effect").Effect<RequestContext | ContextMap | Exclude<R, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, import("@fp-ts/data/Chunk").Chunk<S1>, Iterable<S2>>;
}>, InvalidStateError | OptimisticConcurrencyException | E, A>;
/**
 * @tsplus fluent Repository saveWithPure_
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function saveWithPure_<Id extends string, R, T extends {
    id: Id;
}, PM extends {
    id: string;
}, A, E, Evt, S1 extends T, S2 extends T, ItemType extends string>(self: Repository<T, PM, Evt, Id, ItemType>, item: S1, pure: Effect<FixEnv<R, Evt, S1, S2>, E, A>): import("@effect/io/Effect").Effect<RequestContext | ContextMap | Exclude<R, {
    env: import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnv<Evt, S1, S2>;
}>, InvalidStateError | OptimisticConcurrencyException | E, A>;
export type AllDSL<T, Evt> = (<R, A, E, S1 extends T, S2 extends T>(pure: (dsl: PureDSL<Chunk<S1>, Iterable<S2>, Evt>) => Effect<R, E, A>) => Effect<FixEnv<R, Evt, Chunk<S1>, Iterable<S2>>, E, A>) & AllDSLExt<T, Evt>;
/**
 * @tsplus type DSLExt
 */
export interface AllDSLExt<T, Evt> {
    modify: <R, E, A, S1 extends T, S2 extends T>(pure: (items: Chunk<S1>, dsl: PureDSL<Chunk<S1>, Iterable<S2>, Evt>) => Effect<R, E, A>) => Effect<FixEnv<R, Evt, Chunk<S1>, Iterable<S2>>, E, A>;
    update: <R, E, S1 extends T, S2 extends T>(pure: (items: Chunk<S1>, log: (...evt: Evt[]) => PureLogT<Evt>) => Effect<R, E, Iterable<S2>>) => Effect<FixEnv<R, Evt, Chunk<S1>, Iterable<S2>>, E, Iterable<S2>>;
}
export declare function makeAllDSL<T, Evt>(): AllDSL<T, Evt>;
export type OneDSL<T, Evt> = (<R, A, E, S1 extends T, S2 extends T>(pure: (dsl: PureDSL<S1, S2, Evt>) => Effect<FixEnv<R, Evt, S1, S2>, E, A>) => Effect<FixEnv<R, Evt, S1, S2>, E, A>) & OneDSLExt<T, Evt>;
/**
 * @tsplus type DSLExt
 */
export interface OneDSLExt<T, Evt> {
    modify: <R, E, A, S1 extends T, S2 extends T>(pure: (items: S1, dsl: PureDSL<S1, S2, Evt>) => Effect<FixEnv<R, Evt, S1, S2>, E, A>) => Effect<FixEnv<R, Evt, S1, S2> | PureEnvEnv<Evt, S1, S1>, E, A>;
    update: <R, E, S1 extends T, S2 extends T>(pure: (items: S1, log: (...evt: Evt[]) => PureLogT<Evt>) => Effect<FixEnv<R, Evt, S1, S2>, E, S2>) => Effect<FixEnv<R, Evt, S1, S2>, E, S2>;
}
/**
 * @tsplus fluent DSLExt updateWith
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function updateWithOne<T, Evt, S1 extends T, S2 extends T>(self: OneDSL<T, Evt>, upd: (item: S1) => S2): import("@effect/io/Effect").Effect<import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnvEnv<Evt, S1, S2>, never, S2>;
/**
 * @tsplus fluent DSLExt updateWith
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function updateWith<T, Evt, S1 extends T, S2 extends T>(self: AllDSL<T, Evt>, upd: (item: Chunk<S1>) => Iterable<S2>): import("@effect/io/Effect").Effect<import("@effect-ts-app/boilerplate-prelude/_ext/Pure").PureEnvEnv<Evt, import("@fp-ts/data/Chunk").Chunk<S1>, Iterable<S2>>, never, Iterable<S2>>;
export declare function makeOneDSL<T, Evt>(): OneDSL<T, Evt>;
export declare function makeDSL<S1, S2, Evt>(): (<R, A, E>(pure: (dsl: PureDSL<S1, S2, Evt>) => import("@effect/io/Effect").Effect<R, E, A>) => import("@effect/io/Effect").Effect<FixEnv<R, Evt, S1, S2>, E, A>) & {
    modify: <R_1, E_1, A_1>(pure: (items: S1, dsl: PureDSL<S1, S2, Evt>) => import("@effect/io/Effect").Effect<R_1, E_1, A_1>) => import("@effect/io/Effect").Effect<FixEnv<R_1, Evt, S1, S2>, E_1, A_1>;
    update: <R_2, E_2>(pure: (items: S1, log: (...evt: Evt[]) => PureLogT<Evt>) => import("@effect/io/Effect").Effect<R_2, E_2, S2>) => import("@effect/io/Effect").Effect<FixEnv<R_2, Evt, S1, S2>, E_2, S2>;
};
export interface DSLExt<S1, S2, Evt> extends ReturnType<typeof makeDSL<S1, S2, Evt>> {
}
export declare function ifAny<T, R, E, A>(fn: (items: NonEmptyReadonlyArray<T>) => Effect<R, E, A>): (items: Iterable<T>) => import("@effect/io/Effect").Effect<R, E, import("@fp-ts/data/Option").Option<A>>;
/**
 * @tsplus fluent Iterable ifAny
 * @tsplus location "@effect-ts-app/boilerplate-infra/services/Repository"
 */
export declare function ifAny_<T, R, E, A>(items: Iterable<T>, fn: (items: NonEmptyReadonlyArray<T>) => Effect<R, E, A>): import("@effect/io/Effect").Effect<R, E, import("@fp-ts/data/Option").Option<A>>;
//# sourceMappingURL=Repository.d.ts.map