handler

type Config struct {
	Plugins          PluginCfg `yaml:"plugins"`
	Steps            []string
	Type             Type
	RegistryURL      string `yaml:"registryUrl"`
	Role             model.Role
	SubscriberID     string           `yaml:"subscriberId"`
	HttpClientConfig HttpClientConfig `yaml:"httpClientConfig"`
	// BasePath is the HTTP path prefix at which this module is mounted (e.g.
	// "/bap/receiver/"). Set by the module layer from module.Config.Path; not
	// read from YAML. Steps use it to strip the prefix before calling plugins.
	BasePath string `yaml:"-"`
	// OutputRoot previously named the catalogPublish handler's local output
	// directory directly. Storage is now supplied to the catalogPublisher
	// plugin via its own CatalogBlobStore plugin config
	// (Plugins.CatalogBlobStore, e.g. localcatalogblobstore's "root" key)
	// instead, so NewCatalogPublishHandler no longer reads this field. Kept
	// on Config only for backward-compat parsing of existing YAML that
	// still sets outputRoot -- YAML decoding in this package is not strict
	// (unknown keys are simply ignored), so removing the field entirely
	// would not break parsing, but that's a config-migration decision
	// better made deliberately, not as a side effect of this handler
	// change.
	OutputRoot string `yaml:"outputRoot,omitempty"`
	// AuthDisabled, when true, skips signature verification on handlers that
	// would otherwise require it (currently only catalogCrawlStatus). LOCAL
	// DEV / TESTING ONLY -- with this set, the caller's identity comes from
	// an unauthenticated subscriberId query param instead of a verified
	// Authorization header, so any caller can query any subscriber's crawl
	// status. Must stay false/unset for any network-facing deployment.
	AuthDisabled bool `yaml:"authDisabled,omitempty"`
}

type EndpointHandler[Req, Resp any] struct {
	Decode  func(ctx context.Context, r *http.Request) (Req, error)
	Execute func(ctx context.Context, req Req) (Resp, error)
	Encode  func(w http.ResponseWriter, r *http.Request, req Req, resp Resp, err error)
}

type HTTPMetrics struct {
	HttpRequestCount metric.Int64Counter
}

type HandlerDirection string

type HandlerMetrics struct {
	SignatureValidationsTotal metric.Int64Counter
	SchemaValidationsTotal    metric.Int64Counter
	RoutingDecisionsTotal     metric.Int64Counter
}

type HttpClientConfig struct {
	// MaxIdleConns controls the maximum number of idle (keep-alive)
	// connections across all hosts.
	MaxIdleConns int `yaml:"maxIdleConns"`

	// IdleConnTimeout is the maximum amount of time an idle
	// (keep-alive) connection will remain idle before closing itself.
	IdleConnTimeout time.Duration `yaml:"idleConnTimeout"`

	// MaxIdleConnsPerHost, if non-zero, controls the maximum idle
	// (keep-alive) connections to keep per-host.
	MaxIdleConnsPerHost int `yaml:"maxIdleConnsPerHost"`

	// ResponseHeaderTimeout, if non-zero, specifies the amount of time to wait
	// for a server's response headers after fully writing the request.
	ResponseHeaderTimeout time.Duration `yaml:"responseHeaderTimeout"`
}

type InstrumentedResponseStep struct {
	// contains filtered or unexported fields
}

type InstrumentedStep struct {
	// contains filtered or unexported fields
}

type PluginCfg struct {
	SchemaValidator       *plugin.Config  `yaml:"schemaValidator,omitempty"`
	PolicyChecker         *plugin.Config  `yaml:"checkPolicy,omitempty"`
	PayloadTransformer    *plugin.Config  `yaml:"payloadTransformer,omitempty"`
	SignValidator         *plugin.Config  `yaml:"signValidator,omitempty"`
	Publisher             *plugin.Config  `yaml:"publisher,omitempty"`
	Signer                *plugin.Config  `yaml:"signer,omitempty"`
	Router                *plugin.Config  `yaml:"router,omitempty"`
	Cache                 *plugin.Config  `yaml:"cache,omitempty"`
	Registry              *plugin.Config  `yaml:"registry,omitempty"`
	KeyManager            *plugin.Config  `yaml:"keyManager,omitempty"`
	ManifestLoader        *plugin.Config  `yaml:"manifestLoader,omitempty"`
	SchemaVersionMediator *plugin.Config  `yaml:"schemaVersionMediator,omitempty"`
	TransportWrapper      *plugin.Config  `yaml:"transportWrapper,omitempty"`
	PayloadStore          *plugin.Config  `yaml:"payloadStore,omitempty"`
	CatalogPublisher      *plugin.Config  `yaml:"catalogPublisher,omitempty"`
	CatalogBlobStore      *plugin.Config  `yaml:"catalogBlobStore,omitempty"`
	Middleware            []plugin.Config `yaml:"middleware,omitempty"`
	Steps                 []plugin.Config
}

type PluginManager interface {
	Middleware(ctx context.Context, cfg *plugin.Config) (func(http.Handler) http.Handler, error)
	SignValidator(ctx context.Context, cfg *plugin.Config) (definition.SignValidator, error)
	Validator(ctx context.Context, cfg *plugin.Config) (definition.SchemaValidator, error)
	Router(ctx context.Context, cfg *plugin.Config) (definition.Router, error)
	Publisher(ctx context.Context, cfg *plugin.Config) (definition.Publisher, error)
	Signer(ctx context.Context, cfg *plugin.Config) (definition.Signer, error)
	Step(ctx context.Context, cfg *plugin.Config) (definition.Step, error)
	PolicyChecker(ctx context.Context, manifestLoader definition.ManifestLoader, cfg *plugin.Config) (definition.PolicyChecker, error)
	SchemaVersionMediator(ctx context.Context, manifestLoader definition.ManifestLoader, cfg *plugin.Config) (definition.SchemaVersionMediator, error)
	Cache(ctx context.Context, cfg *plugin.Config) (definition.Cache, error)
	Registry(ctx context.Context, cache definition.Cache, cfg *plugin.Config) (definition.RegistryLookup, error)
	KeyManager(ctx context.Context, rLookup definition.RegistryLookup, cfg *plugin.Config) (definition.KeyManager, error)
	ManifestLoader(ctx context.Context, cache definition.Cache, lookup definition.RegistryMetadataLookup, cfg *plugin.Config) (definition.ManifestLoader, error)
	TransportWrapper(ctx context.Context, cfg *plugin.Config) (definition.TransportWrapper, error)
	SchemaValidator(ctx context.Context, cfg *plugin.Config) (definition.SchemaValidator, error)
	PayloadStore(ctx context.Context, cache definition.Cache, namespace string, cfg *plugin.Config) (definition.PayloadStore, error)
	CatalogPublisher(ctx context.Context, km definition.KeyManager, blobStore definition.CatalogBlobStore, registry definition.RegistryLookup, cfg *plugin.Config) (definition.CatalogPublisher, error)
	CatalogBlobStore(ctx context.Context, cfg *plugin.Config) (definition.CatalogBlobStore, error)
}

type ResponseStepRunner interface {
	RunOnResponse(*model.StepContext, *model.ResponseStepContext) error
}

type StatusError struct {
	Status int
	Err    error
}

type StepMetrics struct {
	StepExecutionDuration metric.Float64Histogram
	StepExecutionTotal    metric.Int64Counter
	StepErrorsTotal       metric.Int64Counter
}

type StepRunner interface {
	Run(*model.StepContext) error
}

type Type string