Merge pull request #53 from dogmatiq/config

Migrate configkit

config/aggregate.go

@@ -0,0 +1,90 @@
+package config
+
+import (
+	"github.com/dogmatiq/dogma"
+	"github.com/dogmatiq/enginekit/optional"
+	"github.com/dogmatiq/enginekit/protobuf/identitypb"
+)
+
+// AggregateAsConfigured contains the raw unvalidated properties of an
+// [Aggregate].
+type AggregateAsConfigured struct {
+	// Source describes the type and value that produced the configuration, if
+	// available.
+	Source optional.Optional[Value[dogma.AggregateMessageHandler]]
+
+	// Identities is the list of identities configured for the handler.
+	Identities []Identity
+
+	// Routes is the list of routes configured on the handler.
+	Routes []Route
+
+	// IsDisabled is true if the handler was disabled via the configurer, if
+	// known.
+	IsDisabled optional.Optional[bool]
+
+	// Fidelity describes the configuration's accuracy in comparison to the
+	// actual configuration that would be used at runtime.
+	Fidelity Fidelity
+}
+
+// Aggregate represents the (potentially invalid) configuration of a
+// [dogma.AggregateMessageHandler] implementation.
+type Aggregate struct {
+	AsConfigured AggregateAsConfigured
+}
+
+func (h *Aggregate) String() string {
+	return renderEntity("aggregate", h, h.AsConfigured.Source)
+}
+
+// Identity returns the entity's identity.
+//
+// It panics if no single valid identity is configured.
+func (h *Aggregate) Identity() *identitypb.Identity {
+	return finalizeIdentity(newFinalizeContext(h), h)
+}
+
+// Fidelity returns information about how well the configuration represents
+// the actual configuration that would be used at runtime.
+func (h *Aggregate) Fidelity() Fidelity {
+	return h.AsConfigured.Fidelity
+}
+
+// HandlerType returns [HandlerType] of the handler.
+func (h *Aggregate) HandlerType() HandlerType {
+	return AggregateHandlerType
+}
+
+// RouteSet returns the routes configured for the handler.
+//
+// It panics if the routes are incomplete or invalid.
+func (h *Aggregate) RouteSet() RouteSet {
+	return finalizeRouteSet(newFinalizeContext(h), h)
+}
+
+// IsDisabled returns true if the handler was disabled via the configurer.
+func (h *Aggregate) IsDisabled() bool {
+	return h.AsConfigured.IsDisabled.Get()
+}
+
+// Interface returns the [dogma.AggregateMessageHandler] instance that the
+// configuration represents, or panics if it is not available.
+func (h *Aggregate) Interface() dogma.AggregateMessageHandler {
+	return h.AsConfigured.Source.Get().Value.Get()
+}
+
+func (h *Aggregate) normalize(ctx *normalizeContext) Component {
+	h.AsConfigured.Fidelity, h.AsConfigured.Source = normalizeValue(ctx, h.AsConfigured.Fidelity, h.AsConfigured.Source)
+	h.AsConfigured.Identities = normalizeIdentities(ctx, h)
+	h.AsConfigured.Routes = normalizeRoutes(ctx, h)
+	return h
+}
+
+func (h *Aggregate) identitiesAsConfigured() []Identity {
+	return h.AsConfigured.Identities
+}
+
+func (h *Aggregate) routesAsConfigured() []Route {
+	return h.AsConfigured.Routes
+}