import { Collection, MongoClient, ObjectId } from 'mongodb';
import * as valleyed from 'valleyed';
import { PipeInput } from 'valleyed';
import { M as Model, E as Entity, D as DbChange, a as DbChangeConfig, b as DbChangeCallbacks, c as DbConfig, C as Config, T as Table } from '../../../core-tNlIMH9Y.js';
import { Db } from '../../index.js';
import '../../../events/adapters/kafka/index.js';
import '../../../overrides-6Hxg764S.js';
import '../../../events/index.js';

declare const mongoDbConfigPipe: () => valleyed.Pipe<{
    uri: string;
}, {
    uri: string;
}>;
type MongoDbConfig = PipeInput<ReturnType<typeof mongoDbConfigPipe>>;

declare class MongoDbChange<Model extends Model<{
    _id: string;
}>, Entity extends Entity> extends DbChange<Model, Entity> {
    #private;
    constructor(config: MongoDbConfig, change: DbChangeConfig, collection: Collection<Model>, callbacks: DbChangeCallbacks<Model, Entity>, mapper: (model: Model) => Entity);
}

type IdType = {
    _id: string;
};
declare class MongoDb extends Db<{
    _id: string;
}> {
    #private;
    private mongoConfig;
    client: MongoClient;
    constructor(mongoConfig: MongoDbConfig, dbConfig: DbConfig);
    session<T>(callback: () => Promise<T>): Promise<T>;
    id(): ObjectId;
    use<Model extends Model<{
        _id: string;
    }>, Entity extends Entity>(config: Config<Model, Entity>): Table<IdType, Model, Entity, {
        collection: Collection<Model>;
    }>;
}

export { MongoDb, MongoDbChange, type MongoDbConfig, mongoDbConfigPipe };