ancla

type Config struct {
	// DisablePartnerIDs, if true, will allow wrpEventStreams to register without
	// checking the validity of the partnerIDs in the request.
	DisablePartnerIDs bool

	// Validation provides options for validating the wrpEventStream's URL and TTL
	// related fields. Some validation happens regardless of the configuration:
	// URLs must be a valid URL structure, the Matcher.DeviceID values must
	// compile into regular expressions, and the Events field must have at
	// least one value and all values must compile into regular expressions.
	Validation schema.SchemaURLValidatorConfig
}

type DefaultListenerOut struct {
	fx.Out

	Watchers []Watch `group:"watchers,flatten"`
}

type DefaultListenersIn struct {
	fx.In

	// Metric for wrpEventStream list size, used by the wrpEventStream list size watcher listener.
	WRPEventStreamListSizeGauge prometheus.Gauge `name:"wrp_event_stream_list_size"`
}

type HandlerConfig struct {
	V                 webhook.Validators
	DisablePartnerIDs bool
	GetLogger         func(context.Context) *zap.Logger
}

type ListenerIn struct {
	fx.In

	Shutdowner fx.Shutdowner
	// Watchers are called by the Listener when new wrpEventStreams are fetched.
	Watchers []Watch `group:"watchers"`
}

type ListenerOut struct {
	fx.Out

	Option chrysom.ListenerOption `group:"listener_options"`
}

type Service interface {
	// Add adds the given owned wrpEventStream to the current list of wrpEventStreams. If the operation
	// succeeds, a non-nil error is returned.
	Add(ctx context.Context, owner string, iw schema.Manifest) error

	// GetAll lists all the current registered wrpEventStreams.
	GetAll(ctx context.Context) ([]schema.Manifest, error)
}

type ServiceIn struct {
	fx.In

	// PushReader is the user provided db client.
	PushReader chrysom.PushReader `optional:"true"`
}

type Watch interface {
	Update([]schema.Manifest)
}

type WatchFunc func([]schema.Manifest)