subscription

type Filter struct {
	NamespaceID                uint64
	Match                      map[string]string
	NotificationMatch          map[string]string
	Metadata                   map[string]any
	SilenceID                  string
	IDs                        []int64
	SubscriptionReceiverLabels map[string]string
	ReceiverID                 uint64
	WithSubscriptionReceiver   bool
}

type LogService interface {
	ListSubscriptionIDsBySilenceID(ctx context.Context, silenceID string) ([]int64, error)
}

type NamespaceService interface {
	List(context.Context) ([]namespace.Namespace, error)
	Create(context.Context, *namespace.Namespace) error
	Get(context.Context, uint64) (*namespace.Namespace, error)
	Update(context.Context, *namespace.Namespace) error
	Delete(context.Context, uint64) error
}

type NotFoundError struct {
	ID uint64
}

type Receiver struct {
	ID                         uint64            `json:"id"`
	Configuration              map[string]any    `json:"configuration"`
	SubscriptionReceiverLabels map[string]string `json:"subscription_receiver_labels"`

	// Type won't be exposed to the end-user, this is used to add more details for notification purposes
	Type string
}

type ReceiverService interface {
	List(ctx context.Context, flt receiver.Filter) ([]receiver.Receiver, error)
	PostHookDBTransformConfigs(ctx context.Context, receiverType string, configs map[string]any) (map[string]any, error)
}

type ReceiverView struct {
	ID             uint64            `json:"id"` // receiver_id
	Name           string            `json:"name"`
	Labels         map[string]string `json:"labels"`
	Type           string            `json:"type"`
	Configurations map[string]any    `json:"configurations"`
	ParentID       uint64            `json:"parent_id"`
	CreatedAt      time.Time         `json:"created_at"`
	UpdatedAt      time.Time         `json:"updated_at"`
	SubscriptionID uint64            `json:"subscription_id"`
	Match          map[string]string `json:"match"`
}

type Repository interface {
	Transactor
	List(context.Context, Filter) ([]Subscription, error)
	Create(context.Context, *Subscription) error
	Get(context.Context, uint64) (*Subscription, error)
	Update(context.Context, *Subscription) error
	Delete(context.Context, uint64) error
	MatchLabelsFetchReceivers(ctx context.Context, flt Filter) ([]ReceiverView, error)
}

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

type Subscription struct {
	ID        uint64            `json:"id"`
	URN       string            `json:"urn"`
	Namespace uint64            `json:"namespace"`
	Receivers []Receiver        `json:"receivers"`
	Match     map[string]string `json:"match"`
	Metadata  map[string]any    `json:"metadata"`
	CreatedAt time.Time         `json:"created_at"`
	UpdatedAt time.Time         `json:"updated_at"`
	CreatedBy string            `json:"created_by"`
	UpdatedBy string            `json:"updated_by"`

	// for v1 api cases
	ReceiversRelation []subscriptionreceiver.Relation `json:"receivers_relation"`
}

type SubscriptionReceiverService interface {
	List(context.Context, subscriptionreceiver.Filter) ([]subscriptionreceiver.Relation, error)
	BulkCreate(context.Context, []subscriptionreceiver.Relation) error
	BulkUpsert(context.Context, []subscriptionreceiver.Relation) error
	BulkSoftDelete(context.Context, subscriptionreceiver.DeleteFilter) error
	BulkDelete(context.Context, subscriptionreceiver.DeleteFilter) error
}

type Transactor interface {
	WithTransaction(ctx context.Context) context.Context
	Rollback(ctx context.Context, err error) error
	Commit(ctx context.Context) error
}