routing

type Config struct {
	GlobalConfig      `yaml:"global", json:"global"`
	SubtreeConfig     `yaml:"subtree", json:"subtree"`
	FinalizerConfig   `yaml:"finalizer", json:"finalizer"`
	NotificationConfg `yaml:"notification", json:"notification"`
}

type FinalizerConfig struct {
	InitialDelay       time.Duration `yaml:"initialDelay", json:"initialDelay"`
	ThrottlingDuration time.Duration `yaml:"throttlingDuration", json:"throttlingDuration"`
	RepeatInterval     time.Duration `yaml:"repeatInterval", json:"repeatInterval"`
}

type GlobalConfig struct {
	GroupWait      *model.Duration `yaml:"groupWait", json:"groupWait"`
	RepeatInterval *model.Duration `yaml:"repeatInterval", json:"repeatInterval"`
}

type NotificationConfg struct {
}

type OpniRouterV1 struct {
	DefaultReceiver config.WebhookConfig `yaml:"defaultReceiver,omitempty" json:"hookEndpoint,omitempty"`
	// Contains an AlertManager config not created and managed by Opni
	SyncedConfig *config.Config `yaml:"embeddedConfig,omitempty" json:"embeddedConfig,omitempty"`

	// defaultNamespaceValue -> endpointId -> OpniConfig
	DefaultNamespaceConfigs defaultNamespaceConfigs `yaml:"defaultNamespaceConfigs,omitempty" json:"defaultNamespaceConfigs,omitempty"`
	// namespace -> routeId -> endpointId -> OpniConfig
	NamespacedSpecs namespacedSpecs `yaml:"namespacedSpecs,omitempty" json:"namespacedSpecs,omitempty"`
	// namespace -> routeId -> 	rateLimitingConfig
	NamespacedRateLimiting namespaceRateLimiting `yaml:"namespacedRateLimiting,omitempty" json:"namespacedRateLimiting,omitempty"`
	// contains filtered or unexported fields
}

type OpniRouting interface {
	ProductionConfigSyncer
	RoutingIdentifer

	SetDefaultNamespaceConfig(endps []*alertingv1.AlertEndpoint) error
	SetNamespaceSpec(namespace string, routeId string, specs *alertingv1.FullAttachedEndpoints) error
	// When an already attached endpoint is updated, propagate updates to the routing tree
	UpdateEndpoint(id string, spec *alertingv1.AlertEndpoint) error
	// When an already attached endpoint is delete, propagate all deletions to the routing tree
	DeleteEndpoint(endpointId string) error

	// Converts OpniRouting to a valid AlertManager config
	// Returns a NotFound error if the a route to update or delete is not found
	// Returns a Conflict error if we try to insert a duplicate config, unique up to its keys
	BuildConfig() (*config.Config, error)
	Clone() OpniRouting
}

type ProductionConfigSyncer interface {
	// Walks the tree of routes in the config, calling the given function
	Walk(map[string]string, func(depth int, r *config.Route) error) error
	// Returns the routes that match the given labels
	Search(labels map[string]string) []*config.Route
	// Merges two OpniRouting objects (also includes merging plain AlertManager configs for users)
	Merge(other OpniRouting) (OpniRouting, error)
	// Converts a valid AlertManager config to OpniRouting
	// Returns an FailedPrecondition error if the config cannot be unmarshalled,
	// Returns an InternalServerError if the config is invalid
	SyncExternalConfig(content []byte) error
}

type RouteValues lo.Tuple2[string, rateLimitingConfig]

type RoutingIdentifer interface {
	HasLabels(routingId string) []*labels.Matcher
	HasReceivers(routingId string) []string
	// SetDefaultReceiver(endpoint url.URL)
	SetDefaultReceiver(config.WebhookConfig)
}

type SubtreeConfig struct {
	GroupWait      *model.Duration `yaml:"groupWait", json:"groupWait"`
	RepeatInterval *model.Duration `yaml:"repeatInterval", json:"repeatInterval"`
}