remotestate

type Claim struct {
	SchemaVersion int       `yaml:"schema_version" json:"schema_version"`
	Task          string    `yaml:"task" json:"task"`
	Login         string    `yaml:"login" json:"login"`
	Machine       string    `yaml:"machine" json:"machine"`
	ClaimedAt     time.Time `yaml:"claimed_at" json:"claimed_at"`
	Note          string    `yaml:"note,omitempty" json:"note,omitempty"`
}

type ClaimEntry struct {
	Claim Claim  `json:"claim"`
	Error string `json:"error,omitempty"`
}

type ClaimMode int

type ClaimOutcome struct {
	Kind     ClaimOutcomeKind `json:"kind"`
	Current  Claim            `json:"current"`
	Previous *Claim           `json:"previous,omitempty"` // set on took_over
	Location string           `json:"location,omitempty"` // commit SHA / URL
}

type ClaimOutcomeKind string

type Config struct {
	Provider  string        `yaml:"provider"`
	Repo      string        `yaml:"repo"`
	URL       string        `yaml:"url"`
	TokenFile string        `yaml:"token_file"`
	Machine   string        `yaml:"machine"`
	Publish   PublishConfig `yaml:"publish"`
}

type Entry struct {
	Snapshot Snapshot `json:"snapshot"`
	Error    string   `json:"error,omitempty"`
}

type Provider interface {
	// Publish overwrites the caller's own login/machine entry. It is
	// self-contained: implementations refresh their own view of the store
	// before writing, so callers never need a separate refresh step first.
	Publish(ctx context.Context, snapshot Snapshot) (PublishResult, error)
	// List returns every machine currently in the store, including the
	// caller's own last-published entry, sorted by Key(). It is also
	// self-contained, refreshing the store view itself before reading.
	List(ctx context.Context) ([]Entry, error)
	// Claim acquires or refreshes a claim on a task. It is self-contained:
	// implementations refresh the store view before acting. The provider never
	// judges staleness; ClaimTakeOverStale merely authorizes replacing another
	// holder — commands establish staleness first.
	//
	// expectedHolder is the "<login>/<machine>" the caller judged stale and
	// is authorizing replacement of; it is "" for ClaimNormal and
	// ClaimForce, which do not need one. For ClaimTakeOverStale it is a
	// precondition: a hub provider maps this to a conditional PUT keyed on
	// the current holder, and a git-backed provider re-checks it against
	// the freshly fetched store before writing. If the actual current
	// holder no longer matches (they released and a third party claimed,
	// or refreshed away their own staleness, between the caller's judgment
	// and this call), the provider must not replace them — it reports an
	// ordinary ClaimHeld naming the real current holder instead.
	Claim(ctx context.Context, claim Claim, mode ClaimMode, expectedHolder string) (ClaimOutcome, error)
	// Release removes a claim. It is self-contained, refreshing the store view
	// before acting.
	Release(ctx context.Context, task, login, machine string, force bool) (ReleaseOutcome, error)
	// Claims returns every claim currently in the store, sorted by task name.
	// It is self-contained, refreshing the store view itself before reading.
	Claims(ctx context.Context) ([]ClaimEntry, error)
}

type PublishConfig struct {
	Unpushed Redaction `yaml:"unpushed"`
}

type PublishResult struct {
	Location string `json:"location"`
}

type PullRequestState struct {
	Number int    `yaml:"number" json:"number"`
	URL    string `yaml:"url" json:"url"`
	State  string `yaml:"state" json:"state"`
}

type Redaction string

type ReleaseOutcome struct {
	Kind     ReleaseOutcomeKind `json:"kind"`
	Current  *Claim             `json:"current,omitempty"`
	Location string             `json:"location,omitempty"`
}

type ReleaseOutcomeKind string

type RepositoryInput struct {
	Repository string
	Path       string
	Status     gitops.RepoStatus
	Tracking   gitops.TrackingState
	Err        error
}

type RepositoryState struct {
	Repository       string                  `yaml:"repository" json:"repository"`
	Path             string                  `yaml:"path" json:"path"`
	Status           string                  `yaml:"status" json:"status"` // attention | error
	Summary          string                  `yaml:"summary,omitempty" json:"summary,omitempty"`
	Branch           string                  `yaml:"branch,omitempty" json:"branch,omitempty"`
	Upstream         string                  `yaml:"upstream,omitempty" json:"upstream,omitempty"`
	Ahead            int                     `yaml:"ahead,omitempty" json:"ahead,omitempty"`
	Behind           int                     `yaml:"behind,omitempty" json:"behind,omitempty"`
	Modified         []string                `yaml:"modified,omitempty" json:"modified,omitempty"`
	Untracked        []string                `yaml:"untracked,omitempty" json:"untracked,omitempty"`
	Conflicted       []string                `yaml:"conflicted,omitempty" json:"conflicted,omitempty"`
	Unpushed         []string                `yaml:"unpushed,omitempty" json:"unpushed,omitempty"`
	UnpushedBranches []gitops.UnpushedBranch `yaml:"unpushed_branches,omitempty" json:"unpushed_branches,omitempty"`
	UnpushedCount    int                     `yaml:"unpushed_count,omitempty" json:"unpushed_count,omitempty"`
	Stashed          []string                `yaml:"stashed,omitempty" json:"stashed,omitempty"`
	Error            string                  `yaml:"error,omitempty" json:"error,omitempty"`
}

type Snapshot struct {
	SchemaVersion int       `yaml:"schema_version" json:"schema_version"`
	Login         string    `yaml:"login" json:"login"`
	Machine       string    `yaml:"machine" json:"machine"`
	PublishedAt   time.Time `yaml:"published_at" json:"published_at"`
	// LastSeenAt records the last time this machine acted through the store
	// via a claim mutation (claim, refresh, release, take-over); it is
	// stamped by the provider, never by Build. Zero means no claim activity
	// has been recorded. See Heartbeat.
	LastSeenAt          time.Time         `yaml:"last_seen_at,omitempty" json:"last_seen_at,omitempty"`
	WBVersion           string            `yaml:"wb_version" json:"wb_version"`
	RemoteStore         string            `yaml:"remote_store,omitempty" json:"remote_store,omitempty"`
	ProjectsRoot        string            `yaml:"projects_root" json:"projects_root"`
	RepositoriesScanned int               `yaml:"repositories_scanned" json:"repositories_scanned"`
	KnownRepositories   []string          `yaml:"known_repositories,omitempty" json:"known_repositories,omitempty"`
	Repositories        []RepositoryState `yaml:"repositories" json:"repositories"`
	Worktrees           []WorktreeState   `yaml:"worktrees" json:"worktrees"`
}

type StatusProvider interface {
	Status(ctx context.Context) (StatusSnapshot, error)
}

type StatusSnapshot struct {
	Machines []Entry      `json:"machines"`
	Claims   []ClaimEntry `json:"claims"`
}

type UnconfiguredError struct {
	Path    string
	Missing []string
	Snippet string
}

type WorktreeState struct {
	Task        string `yaml:"task" json:"task"`
	TaskSummary string `yaml:"task_summary,omitempty" json:"task_summary,omitempty"`
	Stream      string `yaml:"stream,omitempty" json:"stream,omitempty"`
	Repository  string `yaml:"repository" json:"repository"`
	Branch      string `yaml:"branch" json:"branch"`
	HeadSHA     string `yaml:"head_sha" json:"head_sha"`
	Dir         string `yaml:"dir" json:"dir"`
	Lifecycle   string `yaml:"lifecycle,omitempty" json:"lifecycle,omitempty"`
	// OwnerState is worktrees.ListResult.OwnerState: "active", "orphaned", or
	// "unknown". Empty only if the underlying scan left it unset.
	OwnerState     string            `yaml:"owner_state,omitempty" json:"owner_state,omitempty"`
	Owner          string            `yaml:"owner,omitempty" json:"owner,omitempty"`
	LastActivityAt time.Time         `yaml:"last_activity_at,omitempty" json:"last_activity_at,omitempty"`
	NeedsAttention bool              `yaml:"needs_attention,omitempty" json:"needs_attention,omitempty"`
	Attention      string            `yaml:"attention,omitempty" json:"attention,omitempty"`
	PullRequest    *PullRequestState `yaml:"pull_request,omitempty" json:"pull_request,omitempty"`
}