escalation

type ActiveStep struct {
	StepID          string
	PolicyID        string
	AlertID         int
	LastEscalation  time.Time
	LoopCount       int
	ForceEscalation bool
	StepNumber      int
}

type ActiveStepReader interface {
	ActiveStep(ctx context.Context, alertID int, policyID string) (*ActiveStep, error)

	// FindOneStep will return a single escalation policy step.
	// Note: it does not currently fetch the Targets.
	FindOneStep(context.Context, string) (*Step, error)
	FindOneStepTx(context.Context, *sql.Tx, string) (*Step, error)
	FindOneStepForUpdateTx(context.Context, *sql.Tx, string) (*Step, error)

	// FindAllSteps will return escalation policy steps for the given policy ID.
	// Note: it does not currently fetch the Targets.
	FindAllSteps(context.Context, string) ([]Step, error)
	FindAllStepsTx(context.Context, *sql.Tx, string) ([]Step, error)
	FindAllOnCallStepsForUserTx(ctx context.Context, tx *sql.Tx, userID string) ([]Step, error)
}

type Config struct {
	NCStore         notificationchannel.Store
	LogStore        alertlog.Store
	SlackLookupFunc func(ctx context.Context, channelID string) (*slack.Channel, error)
}

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

type Manager interface {
	ActiveStepReader

	FindOnePolicy(context.Context, string) (*Policy, error)
}

type Policy struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	Description string `json:"description"`
	Repeat      int    `json:"repeat"`
}

type PolicyStore interface {
	FindOnePolicy(context.Context, string) (*Policy, error)
	FindOnePolicyTx(context.Context, *sql.Tx, string) (*Policy, error)
	FindOnePolicyForUpdateTx(context.Context, *sql.Tx, string) (*Policy, error)
	FindAllPolicies(context.Context) ([]Policy, error)
	CreatePolicy(context.Context, *Policy) (*Policy, error)
	CreatePolicyTx(context.Context, *sql.Tx, *Policy) (*Policy, error)
	UpdatePolicy(context.Context, *Policy) error
	UpdatePolicyTx(context.Context, *sql.Tx, *Policy) error
	DeletePolicy(ctx context.Context, id string) error
	DeletePolicyTx(ctx context.Context, tx *sql.Tx, id string) error
	FindAllStepTargets(ctx context.Context, stepID string) ([]assignment.Target, error)
	FindAllStepTargetsTx(ctx context.Context, tx *sql.Tx, stepID string) ([]assignment.Target, error)
	AddStepTarget(ctx context.Context, stepID string, tgt assignment.Target) error
	AddStepTargetTx(ctx context.Context, tx *sql.Tx, stepID string, tgt assignment.Target) error
	DeleteStepTarget(ctx context.Context, stepID string, tgt assignment.Target) error
	DeleteStepTargetTx(ctx context.Context, tx *sql.Tx, stepID string, tgt assignment.Target) error
	FindAllPoliciesBySchedule(ctx context.Context, scheduleID string) ([]Policy, error)
	FindManyPolicies(ctx context.Context, ids []string) ([]Policy, error)
	DeleteManyPoliciesTx(ctx context.Context, tx *sql.Tx, ids []string) error

	Search(context.Context, *SearchOptions) ([]Policy, error)
}

type SearchCursor struct {
	Name string `json:"n,omitempty"`
}

type SearchOptions struct {
	Search string       `json:"s,omitempty"`
	After  SearchCursor `json:"a,omitempty"`

	// Omit specifies a list of policy IDs to exclude from the results.
	Omit []string `json:"o,omitempty"`

	Limit int `json:"-"`
}

type Step struct {
	ID           string `json:"id"`
	PolicyID     string `json:"escalation_policy_id"`
	DelayMinutes int    `json:"delay_minutes"`
	StepNumber   int    `json:"step_number"`

	Targets []assignment.Target
}

type StepStore interface {
	// CreateStep is replaced by CreateStepTx.
	CreateStep(context.Context, *Step) (*Step, error)

	// CreateStepTx will create an escalation policy step within the given transaction.
	// Note: Targets are not assigned during creation.
	CreateStepTx(context.Context, *sql.Tx, *Step) (*Step, error)
	UpdateStepNumberTx(context.Context, *sql.Tx, string, int) error

	// Update step allows updating a steps delay
	// Note: it does not update the Targets.
	UpdateStep(context.Context, *Step) error
	UpdateStepDelayTx(context.Context, *sql.Tx, string, int) error
	DeleteStep(context.Context, string) (string, error)
	DeleteStepTx(context.Context, *sql.Tx, string) (string, error)
	MoveStep(context.Context, string, int) error
}

type Store interface {
	PolicyStore
	StepStore
	ActiveStepReader
}