admin_common

type DB interface {
	ListAdminUsers() ([]*orisun.User, error)
	GetProjectorLastPosition(projectorName string) (*orisun.Position, error)
	UpdateProjectorPosition(name string, position *orisun.Position) error
	UpsertUser(user orisun.User) error
	DeleteUser(id string) error
	GetUserByUsername(username string) (orisun.User, error)
	GetUserById(username string) (orisun.User, error)
	GetUsersCount() (uint32, error)
	SaveUsersCount(uint32) error
	GetEventsCount(boundary string) (int, error)
	SaveEventCount(int, string) error
	orisun.BoundaryIndexManager
}

type GetEventsType = func(ctx context.Context, in *orisun.GetEventsRequest) (*orisun.GetEventsResponse, error)

type GetProjectorLastPositionType = func(projectorName string) (*orisun.Position, error)

type IndexCondition = orisun.BoundaryIndexCondition

type IndexField = orisun.BoundaryIndexField

type PublishRequest struct {
	Id      string `json:"id"`
	Subject string `json:"subject"`
	Data    []byte `json:"data"`
}

type PublishToPubSubType = func(ctx context.Context, req *PublishRequest) error

type SaveEventsType = func(ctx context.Context, in *orisun.SaveEventsRequest) (resp *orisun.WriteResult, err error)

type SubscribeToEventStoreType = func(
	ctx context.Context,
	boundary string,
	subscriberName string,
	pos *orisun.Position,
	query *orisun.Query,
	handler *orisun.MessageHandler[orisun.Event],
) error

type UpdateProjectorPositionType = func(projectorName string, position *orisun.Position) error