alert

type AlertDestination struct {
	ID         string        `json:"id" redis:"id"`
	TenantID   string        `json:"tenant_id" redis:"-"`
	Type       string        `json:"type" redis:"type"`
	Topics     models.Topics `json:"topics" redis:"-"`
	Config     models.Config `json:"config" redis:"-"`
	CreatedAt  time.Time     `json:"created_at" redis:"created_at"`
	DisabledAt *time.Time    `json:"disabled_at" redis:"disabled_at"`
}

type AlertEmitter interface {
	Emit(ctx context.Context, topic string, tenantID string, data any) error
}

type AlertEvaluator interface {
	// ShouldAlert determines if an alert should be sent and returns the alert level
	ShouldAlert(failures int) (level int, shouldAlert bool)
}

type AlertMonitor interface {
	HandleAttempt(ctx context.Context, attempt DeliveryAttempt) error
}

type AlertOption func(*alertMonitor)

type AlertStore interface {
	IncrementConsecutiveFailureCount(ctx context.Context, tenantID, destinationID, attemptID string) (FailureCountResult, error)
	// MarkAttemptEvaluated records that an attempt's alert evaluation fully
	// completed, so replays (MQ redelivery, producer re-publish) can skip
	// re-evaluating it.
	MarkAttemptEvaluated(ctx context.Context, tenantID, destinationID, attemptID string) error
	ResetConsecutiveFailureCount(ctx context.Context, tenantID, destinationID string) error
}

type ConsecutiveFailureData struct {
	TenantID            string              `json:"tenant_id"`
	Event               *models.Event       `json:"event"`
	Attempt             *models.Attempt     `json:"attempt"`
	Destination         *AlertDestination   `json:"destination"`
	ConsecutiveFailures ConsecutiveFailures `json:"consecutive_failures"`
}

type ConsecutiveFailureSetting struct {
	Enabled bool
	Count   int
}

type ConsecutiveFailures struct {
	Current   int `json:"current"`
	Max       int `json:"max"`
	Threshold int `json:"threshold"`
}

type DeliveryAttempt struct {
	Event       *models.Event
	Destination *AlertDestination
	Attempt     *models.Attempt
}

type DestinationDisabledData struct {
	TenantID    string            `json:"tenant_id"`
	Destination *AlertDestination `json:"destination"`
	DisabledAt  time.Time         `json:"disabled_at"`
	Reason      string            `json:"reason"`
	Event       *models.Event     `json:"event"`
	Attempt     *models.Attempt   `json:"attempt"`
}

type DestinationDisabler interface {
	DisableDestination(ctx context.Context, tenantID, destinationID string) error
}

type ExhaustedRetriesData struct {
	TenantID    string            `json:"tenant_id"`
	Event       *models.Event     `json:"event"`
	Attempt     *models.Attempt   `json:"attempt"`
	Destination *AlertDestination `json:"destination"`
}

type ExhaustedRetriesSetting struct {
	Enabled       bool
	WindowSeconds int
}

type FailureCountResult struct {
	Count            int  // current consecutive failure count
	NewlyCounted     bool // attempt was not previously counted (first delivery of this attempt)
	AlreadyEvaluated bool // attempt was fully evaluated before (marked via MarkAttemptEvaluated)
}

type Settings struct {
	ConsecutiveFailure     ConsecutiveFailureSetting
	ExhaustedRetries       ExhaustedRetriesSetting
	AutoDisableDestination bool
}