db

type DocumentKey[K any] struct {
	Key *K `bson:"_id,omitempty"`
}

type Event[K any, E any] struct {
	Doc     DocumentKey[K]        `bson:"documentKey,omitempty"`
	Op      string                `bson:"operationType,omitempty"`
	Time    bson.Timestamp        `bson:"clusterTime,omitempty"`
	Ns      *Namespace            `bson:"ns,omitempty"`
	Entry   *E                    `bson:"fullDocument,omitempty"`
	Updates *UpdateDescription[E] `bson:"updateDescription,omitempty"`
}

type EventLogger[K any, E any] struct {
	// contains filtered or unexported fields
}

type MongoConfig struct {
	Host     string
	Port     string
	Uri      string
	Username string
	Password string
}

type Namespace struct {
	Database   string `bson:"db,omitempty"`
	Collection string `bson:"coll,omitempty"`
}

type Store interface {
	// Gets collection corresponding to the collection name
	GetCollection(col string) StoreCollection

	// Gets Name of the database corresponding to the store
	Name() string
}

type StoreClient interface {
	// Get the Data Store interface given the client interface
	GetDataStore(dbName string) Store

	// Gets collection corresponding to the collection name inside
	// the requested database name
	GetCollection(dbName, col string) StoreCollection

	// Health Check, if the Store is connectable and healthy
	// returns the status of health of the server by means of
	// error if error is nil the health of the DB store can be
	// considered healthy
	HealthCheck(ctx context.Context) error
}

type StoreCollection interface {
	// Set KeyType for the collection, this is not mandatory
	// while the key type will be used by the interface implementer
	// mainly for Watch Callback for providing decoded key, if not
	// set watch will be working with the default decoders of
	// interface implementer
	// only pointer key type is supported as of now
	// returns error if the key type is not a pointer
	SetKeyType(keyType reflect.Type) error

	// insert one entry to the collection for the given key and data
	InsertOne(ctx context.Context, key any, data any) error

	// update one entry in the collection for the given key and data
	// if upsert flag is set, it would insert an entry if it doesn't
	// exist while updating
	UpdateOne(ctx context.Context, key any, data any, upsert bool) error

	// Find one entry from the store collection for the given key, where the data
	// value is returned based on the object type passed to it
	FindOne(ctx context.Context, key any, data any) error

	// Find multiple entries from the store collection for the given filter, where the data
	// value is returned as a list based on the object type passed to it
	FindMany(ctx context.Context, filter any, data any, opts ...any) error

	// Return count of entries matching the provided filter
	Count(ctx context.Context, filter any) (int64, error)

	// remove one entry from the collection matching the given key
	DeleteOne(ctx context.Context, key any) error

	// Delete Many entries matching the delete criteria
	// returns number of entries deleted and if there is any error processing the request
	DeleteMany(ctx context.Context, filter any) (int64, error)

	// watch allows getting notified whenever a change happens to a document
	// in the collection
	// allow provisiong for a filter to be passed on, where the callback
	// function to receive only conditional notifications of the events
	// listener is interested about
	Watch(ctx context.Context, filter any, cb WatchCallbackfn) error
	// contains filtered or unexported methods
}

type UpdateDescription[E any] struct {
	UpdatedFields *E       `bson:"updatedFields,omitempty"`
	RemovedFields []string `bson:"removedFields,omitempty"`
}

type WatchCallbackfn func(op string, key any)