import { AlreadyExistsError, InvalidOperation, NotFoundError } from "./base.errors-CGFHc3DK.cjs";
import { BaseEntity } from "./base.entity-DPTPwQSw.cjs";
import { Paginated, PaginationOptions } from "./pagination-DOJ1uHHA.cjs";
import { Result } from "@carbonteq/fp";

//#region src/domain/base.repository.d.ts
type RepositoryError = NotFoundError | AlreadyExistsError | InvalidOperation;
type CommonRepoErrors = InvalidOperation;
type RepositoryResult<T, E = CommonRepoErrors> = Result<T, E | CommonRepoErrors>;
declare abstract class BaseRepository<T extends BaseEntity> {
  abstract insert(entity: T): Promise<RepositoryResult<T, AlreadyExistsError>>;
  abstract update(entity: T): Promise<RepositoryResult<T, NotFoundError>>;
  fetchAll?(): Promise<RepositoryResult<T[]>>;
  fetchPaginated?(options: PaginationOptions): Promise<RepositoryResult<Paginated<T>>>;
  fetchById?(id: BaseEntity["id"]): Promise<RepositoryResult<T, NotFoundError>>;
  deleteById?(Id: BaseEntity["id"]): Promise<RepositoryResult<T, NotFoundError>>;
  fetchBy?<U extends keyof T>(prop: U, val: T[U]): Promise<RepositoryResult<T, NotFoundError>>;
  existsBy?<U extends keyof T>(prop: U, val: T[U]): Promise<RepositoryResult<boolean>>;
  deleteBy?<U extends keyof T>(prop: U, val: T[U]): Promise<RepositoryResult<T, NotFoundError>>;
}

//#endregion
export { BaseRepository, RepositoryError, RepositoryResult };
//# sourceMappingURL=base.repository-14PF_592.d.cts.map