import type { NonEmptyReadonlyArray } from "effect-app/Array"; import type * as Context from "effect-app/Context"; import * as Effect from "effect-app/Effect"; import type * as S from "effect-app/Schema"; import type { StoreConfig, StoreMaker } from "../../Store.js"; import type { FieldValues } from "../filter/types.js"; import { type ExtendedRepository } from "./ext.js"; import { RepositoryRegistry } from "./Registry.js"; import type { Repository } from "./service.js"; export interface RepositoryOptions { /** * Specify the idKey of the Type side, if it's different from the default "id". * Does not change the Encoded side, which is always "id" to support database drivers. * At this time as queries are operating on the Encoded side, the queries must still specify "id" regardless. */ idKey: IdKey; /** * just in time Migration: for complex migrations that aren't just default simple values * use the config.defaultValues instead for simple default values */ jitM?: (pm: Encoded) => Encoded; config?: Omit, "partitionValue"> & { partitionValue?: (e?: Encoded) => string; }; /** * Optional handler to be able to publish events after successfull save. */ publishEvents?: (evt: NonEmptyReadonlyArray) => Effect.Effect; /** * Optional creator for initial data in the table when it's created for the first itme. */ makeInitial?: Effect.Effect | undefined; /** * Optional context to be provided to Schema decode/encode. * Useful for effectful transformations like XWithItems, where items is a transformation retrieving elements from another database table or other source. */ schemaContext?: Context.Context; overrides?: (repo: Repository, RPublish, RCtx>) => Repository, RPublish, RCtx>; } /** * Create a repository instance. * @param itemType an identifier used for the table name and e.g NotFoundError * @param schema the Schema used for this Repository * @param options @see RepositoryOptions * @returns a Repository */ export declare const makeRepo: { (itemType: ItemType, schema: S.Codec, options: RepositoryOptions): Effect.Effect, RPublish, RCtx>, E, RInitial | StoreMaker | RepositoryRegistry>; (itemType: ItemType, schema: S.Codec, options: Omit, "idKey">): Effect.Effect, RPublish, RCtx>, E, RInitial | StoreMaker | RepositoryRegistry>; }; //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibWFrZVJlcG8uZC50cyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uL3NyYy9Nb2RlbC9SZXBvc2l0b3J5L21ha2VSZXBvLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQVFBLE9BQU8sS0FBSyxFQUFFLHFCQUFxQixFQUFFLE1BQU0sa0JBQWtCLENBQUE7QUFDN0QsT0FBTyxLQUFLLEtBQUssT0FBTyxNQUFNLG9CQUFvQixDQUFBO0FBQ2xELE9BQU8sS0FBSyxNQUFNLE1BQU0sbUJBQW1CLENBQUE7QUFDM0MsT0FBTyxLQUFLLEtBQUssQ0FBQyxNQUFNLG1CQUFtQixDQUFBO0FBQzNDLE9BQU8sS0FBSyxFQUFFLFdBQVcsRUFBRSxVQUFVLEVBQUUsTUFBTSxnQkFBZ0IsQ0FBQTtBQUM3RCxPQUFPLEtBQUssRUFBRSxXQUFXLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQTtBQUNyRCxPQUFPLEVBQUUsS0FBSyxrQkFBa0IsRUFBYyxNQUFNLFVBQVUsQ0FBQTtBQUU5RCxPQUFPLEVBQUUsa0JBQWtCLEVBQUUsTUFBTSxlQUFlLENBQUE7QUFDbEQsT0FBTyxLQUFLLEVBQUUsVUFBVSxFQUFFLE1BQU0sY0FBYyxDQUFBO0FBRTlDLE1BQU0sV0FBVyxpQkFBaUIsQ0FDaEMsS0FBSyxTQUFTLE1BQU0sQ0FBQyxHQUFHLE1BQU0sT0FBTyxFQUNyQyxPQUFPLFNBQVMsV0FBVyxFQUMzQixDQUFDLEVBQ0QsUUFBUSxTQUFTLE1BQU0sRUFDdkIsR0FBRyxHQUFHLEtBQUssRUFDWCxRQUFRLEdBQUcsS0FBSyxFQUNoQixDQUFDLEdBQUcsS0FBSyxFQUNULFFBQVEsR0FBRyxLQUFLLEVBQ2hCLElBQUksR0FBRyxLQUFLLEVBQ1osT0FBTyxHQUFHLEtBQUs7SUFFZjs7OztPQUlHO0lBQ0gsS0FBSyxFQUFFLEtBQUssQ0FBQTtJQUNaOzs7T0FHRztJQUNILElBQUksQ0FBQyxFQUFFLENBQUMsRUFBRSxFQUFFLE9BQU8sS0FBSyxPQUFPLENBQUE7SUFDL0IsTUFBTSxDQUFDLEVBQUUsSUFBSSxDQUFDLFdBQVcsQ0FBQyxPQUFPLENBQUMsRUFBRSxnQkFBZ0IsQ0FBQyxHQUFHO1FBQ3RELGNBQWMsQ0FBQyxFQUFFLENBQUMsQ0FBQyxDQUFDLEVBQUUsT0FBTyxLQUFLLE1BQU0sQ0FBQTtLQUN6QyxDQUFBO0lBQ0Q7O09BRUc7SUFDSCxhQUFhLENBQUMsRUFBRSxDQUFDLEdBQUcsRUFBRSxxQkFBcUIsQ0FBQyxHQUFHLENBQUMsS0FBSyxNQUFNLENBQUMsTUFBTSxDQUFDLElBQUksRUFBRSxLQUFLLEVBQUUsUUFBUSxDQUFDLENBQUE7SUFDekY7O09BRUc7SUFDSCxXQUFXLENBQUMsRUFBRSxNQUFNLENBQUMsTUFBTSxDQUFDLFNBQVMsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxFQUFFLFFBQVEsQ0FBQyxHQUFHLFNBQVMsQ0FBQTtJQUNsRTs7O09BR0c7SUFDSCxhQUFhLENBQUMsRUFBRSxPQUFPLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFBO0lBRXJDLFNBQVMsQ0FBQyxFQUFFLENBQ1YsSUFBSSxFQUFFLFVBQVUsQ0FBQyxDQUFDLEVBQUUsT0FBTyxFQUFFLEdBQUcsRUFBRSxRQUFRLEVBQUUsS0FBSyxFQUFFLE9BQU8sQ0FBQyxPQUFPLEVBQUUsSUFBSSxDQUFDLEVBQUUsUUFBUSxFQUFFLElBQUksQ0FBQyxLQUN2RixVQUFVLENBQUMsQ0FBQyxFQUFFLE9BQU8sRUFBRSxHQUFHLEVBQUUsUUFBUSxFQUFFLEtBQUssRUFBRSxPQUFPLENBQUMsT0FBTyxFQUFFLElBQUksQ0FBQyxFQUFFLFFBQVEsRUFBRSxJQUFJLENBQUMsQ0FBQTtDQUMxRjtBQUVEOzs7Ozs7R0FNRztBQUNILGVBQU8sTUFBTSxRQUFRLEVBQUU7SUFDckIsQ0FDRSxRQUFRLFNBQVMsTUFBTSxFQUN2QixPQUFPLEVBQ1AsT0FBTyxTQUFTLFdBQVcsRUFDM0IsQ0FBQyxFQUNELEtBQUssU0FBUyxNQUFNLENBQUMsR0FBRyxNQUFNLE9BQU8sRUFDckMsQ0FBQyxHQUFHLEtBQUssRUFDVCxHQUFHLEdBQUcsS0FBSyxFQUNYLFFBQVEsR0FBRyxLQUFLLEVBQ2hCLFFBQVEsR0FBRyxLQUFLLEVBQ2hCLElBQUksR0FBRyxLQUFLLEVBRVosUUFBUSxFQUFFLFFBQVEsRUFDbEIsTUFBTSxFQUFFLENBQUMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxFQUFFLE9BQU8sRUFBRSxPQUFPLENBQUMsRUFDcEMsT0FBTyxFQUFFLGlCQUFpQixDQUFDLEtBQUssRUFBRSxPQUFPLEVBQUUsQ0FBQyxFQUFFLFFBQVEsRUFBRSxHQUFHLEVBQUUsUUFBUSxFQUFFLENBQUMsRUFBRSxRQUFRLEVBQUUsSUFBSSxFQUFFLE9BQU8sQ0FBQyxHQUNqRyxNQUFNLENBQUMsTUFBTSxDQUNkLGtCQUFrQixDQUFDLENBQUMsRUFBRSxPQUFPLEVBQUUsR0FBRyxFQUFFLFFBQVEsRUFBRSxLQUFLLEVBQUUsT0FBTyxDQUFDLE9BQU8sRUFBRSxJQUFJLENBQUMsRUFBRSxRQUFRLEVBQUUsSUFBSSxDQUFDLEVBQzVGLENBQUMsRUFDRCxRQUFRLEdBQUcsVUFBVSxHQUFHLGtCQUFrQixDQUMzQyxDQUFBO0lBQ0QsQ0FDRSxRQUFRLFNBQVMsTUFBTSxFQUN2QixPQUFPLEVBQ1AsT0FBTyxTQUFTLFdBQVcsRUFDM0IsQ0FBQyxTQUFTO1FBQUUsRUFBRSxFQUFFLE9BQU8sQ0FBQTtLQUFFLEVBQ3pCLENBQUMsR0FBRyxLQUFLLEVBQ1QsR0FBRyxHQUFHLEtBQUssRUFDWCxRQUFRLEdBQUcsS0FBSyxFQUNoQixRQUFRLEdBQUcsS0FBSyxFQUNoQixJQUFJLEdBQUcsS0FBSyxFQUVaLFFBQVEsRUFBRSxRQUFRLEVBQ2xCLE1BQU0sRUFBRSxDQUFDLENBQUMsS0FBSyxDQUFDLENBQUMsRUFBRSxPQUFPLEVBQUUsT0FBTyxDQUFDLEVBQ3BDLE9BQU8sRUFBRSxJQUFJLENBQUMsaUJBQWlCLENBQUMsSUFBSSxFQUFFLE9BQU8sRUFBRSxDQUFDLEVBQUUsUUFBUSxFQUFFLEdBQUcsRUFBRSxRQUFRLEVBQUUsQ0FBQyxFQUFFLFFBQVEsRUFBRSxJQUFJLEVBQUUsT0FBTyxDQUFDLEVBQUUsT0FBTyxDQUFDLEdBQy9HLE1BQU0sQ0FBQyxNQUFNLENBQ2Qsa0JBQWtCLENBQUMsQ0FBQyxFQUFFLE9BQU8sRUFBRSxHQUFHLEVBQUUsUUFBUSxFQUFFLElBQUksRUFBRSxPQUFPLENBQUMsT0FBTyxFQUFFLElBQUksQ0FBQyxFQUFFLFFBQVEsRUFBRSxJQUFJLENBQUMsRUFDM0YsQ0FBQyxFQUNELFFBQVEsR0FBRyxVQUFVLEdBQUcsa0JBQWtCLENBQzNDLENBQUE7Q0FpQ0MsQ0FBQSJ9