clientinfra

type Collection struct {
	Coll *mongodriver.Collection
}

type Cursor struct {
	Cur *mongodriver.Cursor
}

type CursorReader interface {
	Next(ctx context.Context) bool
	Decode(val any) error
	Err() error
	Close(ctx context.Context) error
}

type FindCollection interface {
	Find(ctx context.Context, filter any, opts ...options.Lister[options.FindOptions]) (CursorReader, error)
}

type FindOneCollection interface {
	FindOne(ctx context.Context, filter any, opts ...options.Lister[options.FindOneOptions]) SingleResultDecoder
}

type IndexCreator interface {
	CreateOne(ctx context.Context, model mongodriver.IndexModel, opts ...options.Lister[options.CreateIndexesOptions]) (string, error)
}

type IndexView struct {
	View mongodriver.IndexView
}

type IndexedCollection interface {
	Indexes() IndexCreator
}

type InsertOneCollection interface {
	InsertOne(ctx context.Context, document any, opts ...options.Lister[options.InsertOneOptions]) (*mongodriver.InsertOneResult, error)
}

type SingleResult struct {
	Res *mongodriver.SingleResult
}

type SingleResultDecoder interface {
	Decode(val any) error
}

type UpdateOneCollection interface {
	UpdateOne(ctx context.Context, filter any, update any, opts ...options.Lister[options.UpdateOneOptions]) (*mongodriver.UpdateResult, error)
}