retention

type Job struct {
	Store    Store
	Outbox   Outbox
	Settings Settings
	Clock    clock.Clock
	Logger   *zap.Logger

	// Every is how often it runs. An hour when zero.
	Every time.Duration
}

type Outbox interface {
	Prune(ctx context.Context, before time.Time, limit int) (int64, error)
}

type Settings struct {
	// DeploymentsPerApp is how many of an app's newest deploys are kept
	// [P]: 50, what an app's deploy list shows. Older ones go, except one in
	// flight or waiting for approval and the newest successful deploy of
	// each revision the app ever pinned.
	DeploymentsPerApp int

	// Scans is how long a scan is kept [P]: 90 days. The newest scan of
	// each revision is kept however old.
	Scans time.Duration

	// Sessions is how long an expired or revoked session is kept [P]: 30
	// days.
	Sessions time.Duration

	// IdempotencyKeys is how long a key's answer is replayed [P]: a day
	// (migration 000011).
	IdempotencyKeys time.Duration

	// SSOFlows is how long a sign-in flow is kept after it expired [P]: a
	// day, so a person arriving late at a failed sign-in is told why.
	SSOFlows time.Duration

	// Events is how long the outbox keeps an event with nothing left to
	// deliver, and its deliveries and their attempts [P]: 30 days
	// (subscription.Retention).
	Events time.Duration

	// DeletedApps is how long a deleted app's detection and backup-attempt
	// record are kept [P]: 30 days.
	DeletedApps time.Duration

	// Batch is how many rows one delete removes. 1,000 when zero.
	Batch int
}

type Store interface {
	Deployments(ctx context.Context, keepPerApp, limit int) (int64, error)
	DeletedApps(ctx context.Context, before time.Time, limit int) (int64, error)
	Scans(ctx context.Context, before time.Time, limit int) (int64, error)
	Sessions(ctx context.Context, before time.Time, limit int) (int64, error)
	Notifications(ctx context.Context, now time.Time, limit int) (int64, error)
	IdempotencyKeys(ctx context.Context, before time.Time, limit int) (int64, error)
	SSOFlows(ctx context.Context, before, now time.Time, limit int) (int64, error)
}