restapi

type ChannelInfo struct {
	Name               string
	ChannelExists      bool
	ChannelIsArchived  bool
	ManagerIsInChannel bool
	UserCount          int
}

type ChannelInfoProvider interface {
	// GetChannelInfo returns [ChannelInfo] for the given Slack channel ID. The result
	// is served from an internal cache and refreshed periodically in the background.
	// A cache miss triggers a direct Slack API lookup.
	GetChannelInfo(ctx context.Context, channel string) (*ChannelInfo, error)

	// MapChannelNameToIDIfNeeded converts a human-readable channel name (e.g. "alerts")
	// to its Slack channel ID. If the input is already a channel ID, it is returned
	// unchanged. This allows alert clients to use either form interchangeably.
	MapChannelNameToIDIfNeeded(channelName string) string

	// ManagedChannels returns the current list of Slack channels the bot is a member of.
	ManagedChannels() []*internal.ChannelSummary
}

type FifoQueueConsumer interface {
	Receive(ctx context.Context, sinkCh chan<- *types.FifoQueueItem) error
}

type FifoQueueProducer interface {
	Send(ctx context.Context, slackChannelID, dedupID, body string) error
}

type Hooks struct {
	// OnStartup is called once after Slack connects and channel info is
	// initialized, but before the TCP listener opens. Signals the end of the
	// startup phase — the process is past initialization but not yet accepting
	// traffic. Use it to pass a startup probe and enable a liveness probe.
	OnStartup func()

	// OnReady is called once after net.Listen succeeds and the TCP port is
	// bound. At this point the server is accepting HTTP connections. Use it
	// to pass a readiness probe.
	OnReady func()

	// OnNotReady is called when shutdown begins (context cancelled), before
	// srv.Close() drains in-flight connections. Flip your readiness flag here
	// so the load balancer stops routing traffic before connections are torn
	// down.
	OnNotReady func()

	// OnShutdown is called once when [Server.Run] returns, regardless of
	// whether shutdown was caused by context cancellation or a fatal error.
	// Use it to flip your liveness flag to false.
	OnShutdown func()
}

type PrometheusAlert struct {
	Status       string            `json:"status,omitempty"`
	Labels       map[string]string `json:"labels,omitempty"`
	Annotations  map[string]string `json:"annotations,omitempty"`
	StartsAt     time.Time         `json:"startsAt"`
	EndsAt       time.Time         `json:"endsAt"`
	GeneratorURL string            `json:"generatorURL,omitempty"` //nolint:tagliatelle
	Fingerprint  string            `json:"fingerprint,omitempty"`
}

type PrometheusWebhook struct {
	Version           string             `json:"version,omitempty"`
	GroupKey          string             `json:"groupKey,omitempty"`
	TruncatedAlerts   int                `json:"truncatedAlerts,omitempty"`
	Status            string             `json:"status,omitempty"`
	Receiver          string             `json:"receiver,omitempty"`
	GroupLabels       map[string]string  `json:"groupLabels,omitempty"`
	CommonLabels      map[string]string  `json:"commonLabels,omitempty"`
	CommonAnnotations map[string]string  `json:"commonAnnotations,omitempty"`
	ExternalURL       string             `json:"externalURL,omitempty"` //nolint:tagliatelle
	Alerts            []*PrometheusAlert `json:"alerts,omitempty"`
}

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

type SlackClient interface {
	GetChannelInfo(ctx context.Context, channelID string) (*slack.Channel, error)
	GetUserIDsInChannel(ctx context.Context, channelID string) (map[string]struct{}, error)
	BotIsInChannel(ctx context.Context, channelID string) (bool, error)
	ListBotChannels(ctx context.Context) ([]*internal.ChannelSummary, error)
}