automatic

type Groups interface {
	List(context.Context) ([]reviewgroups.Group, error)
	Summary(context.Context, string) (reviewgroups.Summary, error)
}

type Overview struct {
	Enabled bool `json:"enabled"`
	// PullRequests is which pull requests get automatic reviews: both,
	// authored, requested or all.
	PullRequests string   `json:"pull_requests"`
	Repositories []Status `json:"repositories"`
}

type Queue interface {
	SubmitAutomatic(context.Context, jobs.AutomaticRequest) (jobs.Job, error)
	// Interrupted lists automatic jobs a daemon stop or restart cut short
	// that may be retried once.
	Interrupted() []jobs.Job
	// Refused lists automatic jobs cancelled before any model call without
	// using up their head (the PR turned draft, or its clone went away).
	Refused() []jobs.Job
	// CancelDisallowedAutomatic cancels queued automatic jobs the gate
	// (Scheduler.Gate) now refuses.
	CancelDisallowedAutomatic() []jobs.Job
	// QueuedAutomatic lists the automatic jobs waiting to start.
	QueuedAutomatic() []jobs.Job
}

type Registry interface {
	Repositories(context.Context) ([]repos.Repository, error)
	Preferences(context.Context) (repos.Preferences, error)
	UpdatePreferences(context.Context, func(repos.Preferences) repos.Preferences) (repos.Preferences, error)
	RepositorySettings(ctx context.Context, repository string) (repos.Settings, bool, error)
}

type Scheduler struct {
	Registry Registry
	Queue    Queue
	// Path is the application database recording what was already seen, so a
	// restart neither forgets pending work nor treats old heads as new.
	Path string
	// Discover polls one repository's open pull requests; Trigger and
	// CatchUp use it.
	Discover func(context.Context, github.Repository) (discovery.Snapshot, error)
	// Discovered, when set, receives CatchUp's polls in place of Observe: the
	// daemon passes background discovery's, which also brings the stack
	// groups up to date before CatchUp reads them.
	Discovered func(context.Context, discovery.Snapshot)
	// Reviewed returns the head of the PR's latest saved review, "" if none.
	// Nil uses SavedHead.
	Reviewed func(context.Context, repos.Clone, int) (string, error)
	// Groups holds the review groups; the reviews of stack groups follow
	// their members' (see passGroups). Nil generates no group review.
	Groups Groups
	// Hold reports that the daemon is stopping or waiting to restart as a
	// newer version; nothing is submitted meanwhile, and the new daemon's
	// passes submit what is pending.
	Hold func() bool
	// Notify publishes a repository's changed status (a notice) for the app
	// and the desktop app's notifications.
	Notify   func(Status)
	Now      func() time.Time
	Interval time.Duration
	Log      *slog.Logger
	// contains filtered or unexported fields
}

type Status struct {
	Repository string `json:"repository"`
	// Enabled is effective: the repository's explicit choice, else the
	// global preference.
	Enabled bool `json:"enabled"`
	// Notice is the latest reason a triggered PR got no job:
	// NoticeUnavailable or a jobs.NotAutomaticError reason.
	Notice  string `json:"notice,omitempty"`
	Pending int    `json:"pending"`
}