event

type Database interface {
	UseHook(ctx context.Context, hook db.TransactionHook)
}

type Resolver interface {
	Resolve(ctx context.Context, anything interface{}) (err error)
}

type ResolverImpl struct {
	Users ResolverUserQueries
}

type ResolverUserQueries interface {
	Get(ctx context.Context, id string, role accesscontrol.Role) (*model.User, error)
}

type Service struct {
	AppID           config.AppID
	RemoteIP        httputil.RemoteIP
	UserAgentString httputil.UserAgentString
	HTTPRequestURL  httputil.HTTPRequestURL
	Database        Database
	Clock           clock.Clock
	Localization    *config.LocalizationConfig
	Store           Store
	Resolver        Resolver
	Sinks           []Sink

	NonBlockingPayloads []event.NonBlockingPayload `wire:"-"`
	NonBlockingEvents   []*event.Event             `wire:"-"`
	DatabaseHooked      bool                       `wire:"-"`
	IsDispatchEventErr  bool                       `wire:"-"`
}

type Sink interface {
	ReceiveBlockingEvent(ctx context.Context, e *event.Event) error
	ReceiveNonBlockingEvent(ctx context.Context, e *event.Event) error
}

type Store interface {
	NextSequenceNumber(ctx context.Context) (int64, error)
}

type StoreImpl struct {
	SQLBuilder  *appdb.SQLBuilder
	SQLExecutor *appdb.SQLExecutor
}