catalogapi

type CatalogReloader interface {
	PublishCatalogReload(catalogID string)
}

type CatalogStore interface {
	CreateCatalog(ctx context.Context, c apicatalog.Catalog) error
	GetCatalog(ctx context.Context, id string) (*apicatalog.Catalog, error)
	ListCatalogs(ctx context.Context) ([]apicatalog.Catalog, error)
	UpdateCatalog(ctx context.Context, id string, u apicatalog.Update) error
	DeleteCatalog(ctx context.Context, id string) error
	UpsertSpec(ctx context.Context, catalogID string, spec apicatalog.SpecEntry) error
	GetSpec(ctx context.Context, catalogID, specName string) (*apicatalog.SpecEntry, error)
	ListSpecs(ctx context.Context, catalogID string) ([]apicatalog.SpecEntry, error)
	DeleteSpec(ctx context.Context, catalogID, specName string) error
	ReferencingConnections(ctx context.Context, catalogID string) ([]apicatalog.ConnectionRef, error)
	UpsertOperationEmbeddings(ctx context.Context, catalogID, specName string, rows []apicatalog.OperationEmbedding) error
	ListOperationEmbeddings(ctx context.Context, catalogID, specName string) ([]apicatalog.OperationEmbedding, error)
	DeleteOperationEmbeddings(ctx context.Context, catalogID, specName string) error
	SetOperationCount(ctx context.Context, catalogID, specName string, count int) error
}

type Config struct {
	// Catalogs persists OpenAPI spec bundles. nil disables every route in
	// this package.
	Catalogs CatalogStore
	// EmbedJobs is the Postgres-backed embedding job queue. nil (no
	// database) disables the embedding visibility and retry routes; spec
	// writes still succeed without persisting embeddings.
	EmbedJobs catalogindex.Store
	// Reload broadcasts a catalog change to peer replicas. nil skips the
	// broadcast.
	Reload CatalogReloader
	// Toolkits is the live toolkit registry used to reload this replica's
	// api-gateway instances after a catalog mutation.
	Toolkits ToolkitReloader
	// Mutable reports database config mode; false registers the read
	// routes only, matching the other admin configuration surfaces.
	Mutable bool
	// Author resolves the acting admin for audit columns.
	Author func(*http.Request) string
	// Decode is the parent's strict JSON body decoder (unknown fields
	// rejected, size-capped); its error text is safe to return as the
	// problem detail.
	Decode func(w http.ResponseWriter, r *http.Request, dst any) error
	// DecodeLimit is Decode with a caller-supplied body cap, used by the
	// inline-spec write path whose `content` field legitimately carries
	// the same payload the multipart route allows up to 10 MiB.
	DecodeLimit func(w http.ResponseWriter, r *http.Request, dst any, maxBytes int64) error
}

type ToolkitReloader interface {
	All() []registry.Toolkit
}