event

var (

	// ErrOutboxSinkRouteMismatch indicates a routing rule references the
	// outbox transport but excludes the configured outbox.sink from its
	// subscribable transports. Subscribers attached via such a route
	// would silently miss every event: the bus filters them onto the
	// route's non publish-only transports while the outbox relay
	// dispatches into the (unrelated) sink. The check runs once during
	// fx Start so misconfigurations fail loudly instead of producing a
	// silent broken pipe at runtime.
	ErrOutboxSinkRouteMismatch = errors.New("event outbox: sink missing from outbox-bearing route")
)

var InboxModule = fx.Module(
	"vef:event:inbox",
	fx.Provide(
		fx.Annotate(
			newInboxRepository,
			fx.As(fx.Self()),
			fx.As(new(inbox.Repository)),
		),
		fx.Annotate(
			newInboxMiddleware,
			fx.ResultTags(`group:"vef:event:consume-middlewares"`),
			fx.As(new(middleware.ConsumeMiddleware)),
		),
	),
	fx.Invoke(runInboxMigration),
	fx.Invoke(registerInboxCleanup),
)

var Module = fx.Module(
	"vef:event",
	fx.Provide(
		fx.Annotate(
			newMemoryTransport,
			fx.ResultTags(`group:"vef:event:transports"`),
			fx.As(new(transport.Transport)),
		),
		defaultErrorSink,
		defaultMetricsRecorder,

		fx.Annotate(
			newRecoverMiddleware,
			fx.ResultTags(`group:"vef:event:consume-middlewares"`),
			fx.As(new(middleware.ConsumeMiddleware)),
		),
		fx.Annotate(
			newLoggingPublishMiddleware,
			fx.ResultTags(`group:"vef:event:publish-middlewares"`),
			fx.As(new(middleware.PublishMiddleware)),
		),
		fx.Annotate(
			newLoggingConsumeMiddleware,
			fx.ResultTags(`group:"vef:event:consume-middlewares"`),
			fx.As(new(middleware.ConsumeMiddleware)),
		),
		fx.Annotate(
			newTracingPublishMiddleware,
			fx.ResultTags(`group:"vef:event:publish-middlewares"`),
			fx.As(new(middleware.PublishMiddleware)),
		),
		fx.Annotate(
			newTracingConsumeMiddleware,
			fx.ResultTags(`group:"vef:event:consume-middlewares"`),
			fx.As(new(middleware.ConsumeMiddleware)),
		),
		fx.Annotate(
			newMetricsPublishMiddleware,
			fx.ResultTags(`group:"vef:event:publish-middlewares"`),
			fx.As(new(middleware.PublishMiddleware)),
		),
		fx.Annotate(
			newMetricsConsumeMiddleware,
			fx.ResultTags(`group:"vef:event:consume-middlewares"`),
			fx.As(new(middleware.ConsumeMiddleware)),
		),
		fx.Annotate(
			newBus,
			fx.ParamTags(
				``,
				``,
				`group:"vef:event:transports"`,
				`group:"vef:event:publish-middlewares"`,
				`group:"vef:event:consume-middlewares"`,
				``,
				``,
			),
			fx.As(fx.Self()),
			fx.As(new(event.Bus)),
			fx.As(new(event.RouteInspector)),
		),
	),
)

var OutboxModule = fx.Module(
	"vef:event:outbox",
	fx.Provide(
		fx.Annotate(
			newOutboxRepository,
			fx.As(fx.Self()),
			fx.As(new(outbox.Repository)),
		),

		fx.Annotate(
			newOutboxTransport,
			fx.ResultTags(`group:"vef:event:transports"`),
			fx.As(new(transport.Transport)),
		),
	),
	fx.Invoke(runOutboxMigration),
	fx.Invoke(registerOutboxCleanup),
	fx.Invoke(
		fx.Annotate(
			bindOutboxSinkAndRelay,
			fx.ParamTags(``, ``, ``, `group:"vef:event:transports"`),
		),
	),
)

var RedisStreamTransportModule = fx.Module(
	"vef:event:redis_stream",
	fx.Provide(
		fx.Annotate(
			newRedisStreamTransport,
			fx.ParamTags(``, `optional:"true"`),
			fx.ResultTags(`group:"vef:event:transports"`),
			fx.As(new(transport.Transport)),
		),
		fx.Annotate(
			newRedisStreamInspector,
			fx.ParamTags(``, `optional:"true"`),
		),
	),
)