import { Db, Collection, ObjectId, Filter, UpdateFilter, ClientSession, BulkWriteResult, AnyBulkWriteOperation, BulkWriteOptions, AggregateOptions, Abortable, AggregationCursor, CountDocumentsOptions, DeleteOptions, FindOneAndUpdateOptions, FindOptions, FindOneOptions, InsertOneOptions } from 'mongodb';
import { Collection as UCollection } from '../Collection';
interface Document {
    _id?: ObjectId;
    [key: string]: any;
}
export declare abstract class MongoBaseRepository<T extends Document> {
    protected db: Db;
    protected collectionName: string;
    protected readonly session?: ClientSession;
    constructor(db: Db, collectionName: string, session?: ClientSession);
    protected get collection(): Collection<T>;
    forCollection(collectionName: string): MongoBaseRepository<any>;
    /**
     * Create a new document in the collection
     * @param doc object to be created {}
     * @returns doc with a _id: ObjectId
     */
    create(doc: Omit<T, '_id'>, options?: InsertOneOptions): Promise<T>;
    createMany(inputs: any[], options?: BulkWriteOptions): Promise<T[] | null>;
    createMany(inputs: UCollection<any>, options?: BulkWriteOptions): Promise<UCollection<T> | null>;
    /**
     * Find an item by its _id in the collection
     * @param id ObjectId | string
     * @returns {} | null
     */
    findById(id: ObjectId | string, options?: Omit<FindOneOptions, "timeoutMode"> & Abortable): Promise<T | null>;
    /**
     * Find the first item that match the filter in the collection
     * Use the options to further configuration
     * @param filter
     * @param options
     * @returns doc with _id: ObjectId or null
     */
    findOne(filter: Filter<T>, options?: Omit<FindOneOptions, "timeoutMode"> & Abortable): Promise<T & {
        _id: ObjectId;
    } | null>;
    /**
     * Return an array of items that match the filter object
     * @param filter
     * @param options
     * @returns T[]
     */
    findAll(filter?: Filter<T>, options?: FindOptions & Abortable): Promise<T[]>;
    update(filter: Filter<T>, updates: UpdateFilter<T>, options?: FindOneAndUpdateOptions): Promise<any>;
    updateById(id: ObjectId | string, updates: UpdateFilter<T>, options?: FindOneAndUpdateOptions): Promise<T | null>;
    deleteById(id: ObjectId | string, options?: DeleteOptions): Promise<boolean>;
    deleteAll(filter?: Filter<T>, options?: DeleteOptions): Promise<number>;
    count(filter?: Filter<T>, options?: CountDocumentsOptions & Abortable): Promise<number>;
    bulkWrite(operations: AnyBulkWriteOperation<T>[], options?: BulkWriteOptions): Promise<BulkWriteResult>;
    aggregate(pipeline?: Document[], options?: AggregateOptions & Abortable): AggregationCursor<Document>;
}
export {};
//# sourceMappingURL=MongoBaseRepository.d.ts.map