teamrouter

type AttentionItem struct {
	Worker         string `json:"worker"`
	WorkerName     string `json:"workerName"`
	Channel        string `json:"channel"`
	Unread         int    `json:"unread"`
	UnreadMentions int    `json:"unreadMentions"`
	FirstUnreadSeq *int   `json:"firstUnreadSeq"`
	// LastRelevantSeq is the highest seq that counts for this worker: for a
	// mention-only row, its latest mention. 0 = none.
	LastRelevantSeq int `json:"lastRelevantSeq"`
	LastSeq         int `json:"lastSeq"`
}

type AttentionPage struct {
	ScanComplete   bool            `json:"scanComplete"`
	NextPage       string          `json:"nextPage"`
	AdoptableSince string          `json:"adoptableSince"`
	Items          []AttentionItem `json:"items"`
}

type AttentionRequest struct {
	Since string
	Page  string
}

type Config struct {
	// Fingerprint identifies the exact bytes loaded, without exposing state tokens.
	Fingerprint string        `json:"-"`
	App         string        `json:"app"`
	Channel     string        `json:"channel"`
	OrcaCli     string        `json:"orcaCli"`
	StateDir    string        `json:"stateDir"`
	Roster      []RosterEntry `json:"roster"`
	// BusyWaitMS is the idle gate's tui-idle wait (default 60 s).
	BusyWaitMS int `json:"busyWaitMs"`
	// SubmitWaitS is `orca terminal send --wait-submit` (default 15 s).
	SubmitWaitS int `json:"submitWaitS"`
	// CoordinatorWatchMin is the #1826 liveness rule's N: minutes of
	// continuous idle a flagged worker must exceed (strictly) before its
	// liveness nudge may fire. Positive and finite; default 20.
	CoordinatorWatchMin float64 `json:"coordinatorWatchMinutes"`
}

type CursorResult struct {
	LastSeen  *int
	FieldErrs []string
}

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

type Ledger struct {
	Base   string                 `json:"base"`
	Nudged map[string]LedgerNudge `json:"nudged"`
	// Reported is each held worker's last LOGGED reason (by name), so a hold
	// is logged once per token, not once per poll.
	Reported map[string]string `json:"reported"`
	// DraftNotes: stale-draft discards already logged under this token.
	DraftNotes map[string]string `json:"draftNotes"`
	// HeldSince: epoch ms a worker's current hold began (cleared on delivery).
	HeldSince map[string]int64 `json:"heldSince"`
	// HeldLoggedAt: epoch ms the last long-hold line was logged per worker.
	HeldLoggedAt map[string]int64 `json:"heldLoggedAt"`
}

type LedgerNudge struct {
	// RelevantSeq is the worker's last RELEVANT (mention) seq the nudge was about.
	RelevantSeq int    `json:"relevantSeq"`
	At          int64  `json:"at"`
	Stages      string `json:"stages"`
}

type LivenessRecord struct {
	// IdleSince is the epoch ms the continuous idle episode began; nil while reset.
	IdleSince *int64 `json:"idleSince,omitempty"`
	// Handle is the terminal the clock is measured on; a change is a replaced
	// terminal, which resets the clock.
	Handle string `json:"handle,omitempty"`
	// CoveredFrontier is the channel head at the last DELIVERED liveness
	// nudge; re-eligibility needs head > this.
	CoveredFrontier *int `json:"coveredFrontier,omitempty"`
}

type LivenessStatus struct {
	IdleMinutes     *int64 `json:"idleMinutes"`
	CoveredFrontier *int   `json:"coveredFrontier"`
}

type OrcaRunner func(ctx context.Context, argv []string) RunResult

type Outcome struct {
	Nudged []string `json:"nudged"`
	// Dropped: workers that read their chat themselves while the nudge waited (#1616).
	Dropped []string          `json:"dropped"`
	Covered []string          `json:"covered"`
	Held    map[string]string `json:"held"`
	Adopted bool              `json:"adopted"`
	// Liveness: flagged workers the liveness rule woke this poll (#1826).
	Liveness []string `json:"liveness"`
	// LivenessDropped: flagged workers that caught up while a liveness nudge
	// waited out its gates.
	LivenessDropped []string `json:"livenessDropped"`
}

type RegisterRow struct {
	NamedBy     string `json:"namedBy"`
	ChannelID   string `json:"channel"`
	MentionOnly bool   `json:"mentionOnly"`
	OwnerType   string `json:"ownerType,omitempty"`
}

type ReloadReceipt struct {
	Fingerprint string    `json:"fingerprint"`
	At          time.Time `json:"at"`
}

type RosterEntry struct {
	// Worker is the Worker's permanent id.
	Worker string `json:"worker"`
	Name   string `json:"name"`
	// Worktree is the Orca worktree this worker is driven in.
	Worktree string `json:"worktree"`
	// Terminal (#1845) pins the handle of this worker's MAIN terminal. A pin
	// resolves FIRST, but only ever to a terminal IN this row's worktree,
	// connected and writable — a stale pin falls through with its reason.
	Terminal string `json:"terminal,omitempty"`
	// Coordinator / Lifecycle (#1826) opt the row into the liveness rule:
	// a watch a passive wait can strand.
	Coordinator bool `json:"coordinator,omitempty"`
	Lifecycle   bool `json:"lifecycle,omitempty"`
}

type RouterError struct {
	Reason string
}

type RunResult struct {
	Code   int
	Stdout string
	Stderr string
}

type Screen struct {
	Source string
	Tail   []string
	Draft  string
}

type Server interface {
	AttentionPage(ctx context.Context, req AttentionRequest) (AttentionPage, error)
	RegisterRow(ctx context.Context, workerID string) (RegisterRow, error)
	ReadCursor(ctx context.Context, workerID string) (CursorResult, error)
	ChannelHead(ctx context.Context, channelRef string) (int, error)
}

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

type StatusReport struct {
	StateDir                string                     `json:"stateDir"`
	TokenAdopted            bool                       `json:"tokenAdopted"`
	NudgedUnderCurrentToken []string                   `json:"nudgedUnderCurrentToken"`
	Held                    map[string]string          `json:"held"`
	Locked                  bool                       `json:"locked"`
	Roster                  []string                   `json:"roster"`
	Liveness                map[string]*LivenessStatus `json:"liveness"`
}

type Terminal struct {
	Handle        string  `json:"handle"`
	WorktreePath  string  `json:"worktreePath"`
	AgentIdentity *string `json:"agentIdentity"`
	Connected     bool    `json:"connected"`
	Writable      bool    `json:"writable"`
	LastOutputAt  *int64  `json:"lastOutputAt"` // nil = untracked (#7398)
}