piagent

type AdoptRequest struct {
	Session     string // DevX session name
	PaneID      string // exact tmux pane (%id) running the session's Pi
	PiSessionID string // Pi session ID of that conversation
	By          string
}

type AdoptResult struct {
	AgentID  string `json:"agent_id"`
	Session  string `json:"session"`
	Pane     string `json:"pane"`
	Replayed bool   `json:"replayed"`
}

type AdoptedSession struct {
	Name       string
	Path       string
	Project    string
	TmuxName   string
	InstanceID string
	CreatedAt  time.Time
}

type Agent struct {
	ID          string    `json:"id"`
	DevxSession string    `json:"devx_session"`
	Project     string    `json:"project,omitempty"`
	Worktree    string    `json:"worktree"`
	PiSessionID string    `json:"pi_session_id"`
	Binding     Binding   `json:"binding"`
	Lease       Lease     `json:"lease"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
	LaunchCount int       `json:"launch_count"`
	LaunchNonce string    `json:"launch_nonce,omitempty"`
	// LastLaunchAt is when the latest launch was recorded (before Pi starts).
	LastLaunchAt time.Time `json:"last_launch_at,omitempty"`
	// PaneLaunched is set once DevX has started Pi in the bound pane (a
	// launch or respawn completed). Until then an adopted agent's pane still
	// runs the human's own command.
	PaneLaunched  bool   `json:"pane_launched,omitempty"`
	CreatedBy     string `json:"created_by,omitempty"`
	StartTaskID   string `json:"start_task_id,omitempty"`
	StartIdemHash string `json:"start_idempotency_hash,omitempty"`
	// RetiredAt is set when the agent's DevX session was removed. A retired
	// agent keeps its records for inspection but accepts no new work.
	RetiredAt *time.Time `json:"retired_at,omitempty"`
	// Adopted marks an agent registered for an existing human-created DevX
	// session and Pi (devx agent adopt) rather than created by Start. Its
	// session is the owner's normal session: DevX never creates windows in
	// it and only ever respawns the exact adopted pane.
	Adopted bool `json:"adopted,omitempty"`
	// SessionInstanceID is the instance id of the exact DevX session record
	// this agent was bound to (at start or adoption, or by the reviewed
	// `devx session instances` migration). A session recreated under the same
	// name has a different id, so the agent is never bound to it implicitly.
	// Empty for agents from before instance ids that were not migrated.
	SessionInstanceID string `json:"session_instance_id,omitempty"`
	// SessionCreatedAt is the bound session record's created_at. It is the
	// identity witness when an older DevX writer dropped the record's
	// instance_id (see session.MatchesBoundInstance): authorization-relevant.
	SessionCreatedAt time.Time `json:"session_created_at,omitempty"`
}

type AgentPlanItem struct {
	AgentID           string `json:"agent_id"`
	Session           string `json:"session"`
	Action            string `json:"action"`
	Reason            string `json:"reason,omitempty"`
	SessionInstanceID string `json:"session_instance_id,omitempty"`
	// SessionCreatedAt is recorded on the agent as the drop-witness.
	SessionCreatedAt time.Time `json:"session_created_at,omitempty"`
	// Evidence for the owner (no secrets, no file contents).
	Marker          string `json:"marker"` // local_only | managed_agent | none
	SessionVsAgent  string `json:"session_created_vs_agent_created,omitempty"`
	Adopted         bool   `json:"adopted,omitempty"`
	Retired         bool   `json:"retired,omitempty"`
	CurrentBindings string `json:"current_binding,omitempty"`
	// Basis is what the binding rests on (see Basis* constants).
	Basis string `json:"basis,omitempty"`
}

type AgentView struct {
	Agent        *Agent  `json:"agent"`
	State        string  `json:"state"`
	BridgeOnline bool    `json:"bridge_online"`
	Bridge       *Bridge `json:"bridge,omitempty"`
	PaneAlive    bool    `json:"pane_alive"`
	// PaneForeign means the bound pane id exists but provably belongs to
	// something else (its start command is not this agent's launch script),
	// typically because a restarted tmux server reused the id.
	PaneForeign bool `json:"pane_foreign,omitempty"`
	// BridgeDead means the Pi that last reported is confirmed gone: it shut
	// down, or its heartbeat is stale and its process no longer exists.
	BridgeDead  bool   `json:"bridge_dead,omitempty"`
	BindingOK   bool   `json:"binding_ok"`
	Detail      string `json:"detail,omitempty"`
	CurrentTask string `json:"current_task,omitempty"`
	Waiting     int    `json:"waiting_tasks"`
	LastSeq     int64  `json:"last_event_seq"`
	AttachHint  string `json:"attach_hint"`
	// BridgeProtocol is what the agent's live bridge reports (0 = a bridge
	// from before protocol versioning). BridgeUpgradeNeeded means the
	// running Pi was launched with an older bridge than this build's: it
	// lacks some features until a human relaunches it (protocol < 2: running
	// cancel is refused; protocol < 3: no mid-task progress is reported).
	BridgeProtocol      int  `json:"bridge_protocol"`
	BridgeUpgradeNeeded bool `json:"bridge_upgrade_needed,omitempty"`
	// LatestProgress is the newest progress the bridge recorded for
	// CurrentTask (redacted, bounded); nil when there is no running task or
	// its bridge has not reported any (bridges before protocol 3 never do).
	LatestProgress *ProgressView `json:"latest_progress,omitempty"`
}

type Binding struct {
	TmuxSession string `json:"tmux_session"`
	WindowID    string `json:"window_id"`
	PaneID      string `json:"pane_id"`
}

type Bridge struct {
	Instance      string    `json:"instance"`
	Nonce         string    `json:"nonce"`
	HumanTyping   bool      `json:"human_typing,omitempty"`
	PID           int       `json:"pid"`
	Pane          string    `json:"pane"`
	PiSessionID   string    `json:"pi_session_id"`
	PiSessionFile string    `json:"pi_session_file,omitempty"`
	Idle          bool      `json:"idle"`
	CurrentTask   string    `json:"current_task,omitempty"`
	Heartbeat     time.Time `json:"heartbeat"`
	Mode          string    `json:"mode,omitempty"`
	// Protocol is the bridge's control protocol version (see
	// BridgeProtocol). Bridges from before versioning write none (0).
	Protocol int `json:"protocol,omitempty"`
}

type BridgeUpgradeError struct {
	Kind     string // BridgeKindUpgrade or BridgeKindUnavailable
	AgentID  string
	TaskID   string
	Protocol int // protocol of the bridge holding the task; -1 if not known
	Reason   string
}

type CancelRequest struct {
	AgentID          string // optional; when set, the task must belong to it
	TaskID           string
	ExpectedRevision *int64
}

type Config struct {
	// PiCommand is the Pi executable. Defaults to "pi".
	PiCommand string
	// PiCommandArgs are placed right after PiCommand (e.g. when PiCommand is
	// a wrapper such as env). Human-owned configuration only.
	PiCommandArgs []string
	// PiArgs are extra arguments appended to the Pi command line. They come
	// from human-owned configuration, never from MCP callers.
	PiArgs []string
	// PassEnv names environment variables copied into the launch script.
	PassEnv []string
	// AllowedProjects is the allowlist for start. Empty denies all starts.
	AllowedProjects []string
	// LaunchPolicyErr, when set, means the owner's launch policy could not
	// be loaded. Start, launch and relaunch then fail closed with this error;
	// read-only and control operations keep working.
	LaunchPolicyErr error
	// DevxExecutable lets the bridge raise DevX attention flags. Optional.
	DevxExecutable string
	// WindowName is the tmux window name for agents.
	WindowName string
}

type ConflictError struct {
	TaskID   string
	Expected int64
	Current  int64
	State    string
	Phase    string
	Reason   string
}

type CreatedSession struct {
	Name       string
	Path       string
	Project    string
	TmuxName   string
	InstanceID string
	CreatedAt  time.Time
}

type CreationEvent struct {
	Seq               int64  `json:"seq"`
	Session           string `json:"session"`
	SessionInstanceID string `json:"session_instance_id,omitempty"`
}

type EditResult struct {
	TaskID   string `json:"task_id"`
	Revision int64  `json:"revision"`
	Replayed bool   `json:"replayed"`
	// ReplacementTaskID is set by supersede.
	ReplacementTaskID string `json:"replacement_task_id,omitempty"`
}

type Event struct {
	Seq    int64          `json:"seq"`
	Time   time.Time      `json:"time"`
	Type   string         `json:"type"`
	TaskID string         `json:"task_id,omitempty"`
	Source string         `json:"source"`
	Data   map[string]any `json:"data,omitempty"`
}

type InstancePlan struct {
	Version  int               `json:"version"`
	Sessions []SessionPlanItem `json:"sessions"`
	Agents   []AgentPlanItem   `json:"agents"`
	Summary  map[string]int    `json:"summary"`
	// OwnerConfirmed lists the candidate agent ids the owner confirmed
	// (part of the hash: a different confirmation set is a different plan).
	OwnerConfirmed []string `json:"owner_confirmed,omitempty"`
	// UnknownConfirmations are --confirm ids that are not candidates in
	// this plan; the command refuses to apply such a plan.
	UnknownConfirmations []string `json:"unknown_confirmations,omitempty"`
	Hash                 string   `json:"plan_hash"`
	Notes                []string `json:"notes,omitempty"`
}

type InstanceStores struct {
	// MutateSessions applies fn to the latest session records under the
	// sessions lock and persists them atomically.
	MutateSessions func(fn func(map[string]*session.Session) error) error
	// LoadSessions reads the latest session records (no lock needed: the
	// sessions file is replaced atomically).
	LoadSessions func() (map[string]*session.Session, error)
	Agents       *Store
	// Journal appends one entry durably (fsync) before returning.
	Journal func(JournalEntry) error
	Now     func() time.Time
}

type JournalEntry struct {
	Time       time.Time `json:"time"`
	Kind       string    `json:"kind"` // session | agent
	Name       string    `json:"name"`
	InstanceID string    `json:"instance_id"`
	Restored   bool      `json:"restored_existing_id,omitempty"`
	Basis      string    `json:"basis,omitempty"`
	// PlanHash names the plan this step belongs to. Journals written
	// before it existed omit it; membership is still checked exactly.
	PlanHash string `json:"plan_hash,omitempty"`
}

type Lease struct {
	Holder     string    `json:"holder"`
	Generation int64     `json:"generation"`
	Since      time.Time `json:"since"`
	Reason     string    `json:"reason,omitempty"`
	By         string    `json:"by,omitempty"`
}

type MCPServer struct {
	M       *Manager
	Name    string
	Version string
	Client  string // identity recorded on agents created through this server
	// Extra optionally contributes additional tools (nil = none).
	Extra ToolProvider
}

type Manager struct {
	Store   *Store
	Tmux    Tmux
	Creator SessionCreator
	Config  Config
	// contains filtered or unexported fields
}

type MarkerBackup struct {
	Path     string
	SHA256   string
	Sessions map[string]*session.Session
}

type MarkerBackupRef struct {
	Path   string `json:"path"`
	SHA256 string `json:"sha256"`
}

type MarkerJournalEntry struct {
	Time              time.Time             `json:"time"`
	Kind              string                `json:"kind"` // "local_only_marker"
	Session           string                `json:"session"`
	SessionCreatedAt  time.Time             `json:"session_created_at"`
	SessionPath       string                `json:"session_path"`
	SessionInstanceID string                `json:"session_instance_id,omitempty"`
	AgentID           string                `json:"agent_id"`
	Marker            session.LocalOnlyMeta `json:"marker"`
	PlanHash          string                `json:"plan_hash"`
}

type MarkerPlan struct {
	Version              int               `json:"version"`
	Backups              []MarkerBackupRef `json:"backups"`
	Items                []MarkerPlanItem  `json:"items"`
	OwnerConfirmed       []string          `json:"owner_confirmed,omitempty"`
	UnknownConfirmations []string          `json:"unknown_confirmations,omitempty"`
	Summary              map[string]int    `json:"summary"`
	Notes                []string          `json:"notes,omitempty"`
	Hash                 string            `json:"plan_hash"`
}

type MarkerPlanItem struct {
	AgentID string `json:"agent_id"`
	Session string `json:"session"`
	Action  string `json:"action"`
	Reason  string `json:"reason,omitempty"`
	// Identity of the exact record (apply refuses any other).
	SessionCreatedAt  time.Time `json:"session_created_at,omitempty"`
	SessionPath       string    `json:"session_path,omitempty"`
	SessionInstanceID string    `json:"session_instance_id,omitempty"`
	// Identity of the exact agent.
	AgentCreatedAt time.Time `json:"agent_created_at,omitempty"`
	AgentBoundID   string    `json:"agent_session_instance_id,omitempty"`
	// Evidence.
	SessionVsAgent string   `json:"session_created_vs_agent_created,omitempty"`
	CreationSeq    int64    `json:"agent_created_event_seq,omitempty"`
	TmuxTag        string   `json:"tmux_tag,omitempty"`
	Witnesses      []string `json:"backup_witnesses,omitempty"`
	// Marker is the exact marker that will be written (from the backups).
	Marker *session.LocalOnlyMeta `json:"marker,omitempty"`
}

type MarkerPlanOptions struct {
	Backups   []MarkerBackup
	Witnesses MarkerWitnesses
	Confirmed []string
}

type MarkerStores struct {
	// MutateSessions applies fn to the latest records under the sessions
	// lock and persists them atomically (no write if fn returns an error).
	MutateSessions func(fn func(map[string]*session.Session) error) error
	Agents         *Store
	// VerifyBackup re-reads a reviewed backup and returns its sha256.
	VerifyBackup func(path string) (string, error)
	// TmuxTag re-checks the live tmux tag at apply time.
	TmuxTag func(sessionName string) (string, bool, error)
	// Journal appends one entry durably (fsync) before returning.
	Journal func(MarkerJournalEntry) error
	Now     func() time.Time
}

type MarkerWitnesses struct {
	// Creation returns the agent's agent_created event (ok=false if none).
	Creation func(agentID string) (CreationEvent, bool, error)
	// TmuxTag returns the DEVX_LOCAL_ONLY_AGENT value of the live tmux
	// session with exactly this name; present=false if no such session.
	TmuxTag func(sessionName string) (value string, present bool, err error)
}

type PaneInfo struct {
	Exists bool
	// QueryFailed means tmux could not be asked (server busy or restarting,
	// timeout, tmux missing). It is NOT evidence that the pane is gone.
	QueryFailed bool
	SessionName string
	WindowID    string
	Dead        bool
	PID         string
	// LinkedSessions lists every session the pane's window is linked into.
	// Grouped sessions (e.g. DevX's "<name>-web" viewer) share windows, and
	// tmux reports whichever of them was used most recently as SessionName.
	LinkedSessions []string
	// Command is the pane's current foreground command (pane_current_command).
	Command string
	// StartCommand is the command the pane was created or last respawned
	// with (pane_start_command). HasStartCommand is false when tmux did not
	// report the field at all, so callers can tell "unknown" from "empty".
	StartCommand    string
	HasStartCommand bool
}

type PermissionError struct{ Msg string }

type PlanOptions struct {
	// Recorded looks up an agent's binding in its event log (optional).
	Recorded RecordedBindingFunc
	// Confirmed is the set of candidate agent ids (no marker) the owner
	// explicitly confirmed. Nothing else turns a candidate into a binding.
	Confirmed []string
}

type Progress struct {
	TaskID           string    `json:"task_id"`
	Turn             int       `json:"turn"`
	At               time.Time `json:"at"`
	Excerpt          string    `json:"excerpt"`
	ExcerptTruncated bool      `json:"excerpt_truncated,omitempty"`
	LastTool         string    `json:"last_tool,omitempty"`
}

type ProgressView struct {
	At               time.Time `json:"at"`
	Turn             int       `json:"turn"`
	Excerpt          string    `json:"excerpt"`
	ExcerptTruncated bool      `json:"excerpt_truncated,omitempty"`
	LastTool         string    `json:"last_tool,omitempty"`
}

type QueueItem struct {
	TaskID        string     `json:"task_id"`
	Order         int64      `json:"order"`
	State         string     `json:"state"`
	Phase         string     `json:"phase"`
	Revision      int64      `json:"revision"`
	WaitingReason string     `json:"waiting_reason,omitempty"`
	CancelOutcome string     `json:"cancel_outcome,omitempty"`
	AgeSeconds    int64      `json:"age_seconds"`
	CreatedAt     time.Time  `json:"created_at"`
	DeliveredAt   *time.Time `json:"delivered_at,omitempty"`
	AcceptedAt    *time.Time `json:"accepted_at,omitempty"`
	AcceptedAs    string     `json:"accepted_as,omitempty"`
	FinishedAt    *time.Time `json:"finished_at,omitempty"`
	PromptBytes   int        `json:"prompt_bytes"`
	PromptPreview string     `json:"prompt_preview"`
	PreviewTrunc  bool       `json:"prompt_preview_truncated,omitempty"`
	Supersedes    string     `json:"supersedes,omitempty"`
	SupersededBy  string     `json:"superseded_by,omitempty"`
	Note          string     `json:"note,omitempty"`
	Editable      bool       `json:"editable"`
}

type QueueView struct {
	AgentID  string      `json:"agent_id"`
	State    string      `json:"agent_state"`
	Control  string      `json:"control"`
	LeaseGen int64       `json:"lease_generation"`
	InFlight []QueueItem `json:"in_flight"`
	Pending  []QueueItem `json:"pending"`
	// PendingTotal counts all queued tasks; Pending holds at most
	// MaxQueuePending of them, in delivery order.
	PendingTotal     int         `json:"pending_total"`
	PendingTruncated bool        `json:"pending_truncated,omitempty"`
	Recent           []QueueItem `json:"recent"`
	LastSeq          int64       `json:"last_event_seq"`
}

type RecordedBindingFunc func(agentID string) (string, time.Time, error)

type ResultChunk struct {
	TaskID     string `json:"task_id"`
	State      string `json:"state"`
	Available  bool   `json:"available"`
	Offset     int    `json:"offset"`
	NextOffset int    `json:"next_offset"`
	TotalBytes int    `json:"total_bytes"`
	EOF        bool   `json:"eof"`
	Text       string `json:"text"`
}

type SendRequest struct {
	AgentID        string
	Prompt         string
	IdempotencyKey string
}

type SendResult struct {
	TaskID   string `json:"task_id"`
	Replayed bool   `json:"replayed"`
}

type SessionAdopter interface {
	Adopt(name, agentID string) (AdoptedSession, error)
	ReleaseAdoption(name, agentID string) error
	VerifyAdopted(name string, a *Agent) (AdoptedSession, error)
}

type SessionCreator interface {
	// Create makes a new session owned by agentID. If the session already
	// exists it may be adopted only when it was created for this same agent
	// by an earlier interrupted attempt of this start. Anything else belongs
	// to someone else: fail.
	Create(name, project, agentID string) (CreatedSession, error)
	// EnsureTmux makes sure the session's tmux session exists and belongs
	// to agent a. For an agent bound to a session instance the session
	// record must be that instance (session.MatchesBoundInstance); a
	// recreated session is refused even if its marker names the agent.
	EnsureTmux(name string, a *Agent) error
	// Exists reports whether a DevX session with this name exists.
	Exists(name string) (bool, error)
}

type SessionPlanItem struct {
	Session    string `json:"session"`
	Action     string `json:"action"`
	InstanceID string `json:"instance_id,omitempty"`
	Existing   bool   `json:"existing_id,omitempty"`
	Reason     string `json:"reason,omitempty"`
	// Identity of the exact record the id is written to: apply refuses if
	// the record at this name no longer has this created_at and path.
	CreatedAt time.Time `json:"created_at"`
	Path      string    `json:"path"`
}

type StartRequest struct {
	Project        string
	SessionName    string
	Prompt         string
	IdempotencyKey string
	By             string
}

type StartResult struct {
	AgentID     string `json:"agent_id"`
	TaskID      string `json:"task_id"`
	Session     string `json:"session"`
	PiSessionID string `json:"pi_session_id"`
	Replayed    bool   `json:"replayed"`
}

type Store struct {
	Root string
	// contains filtered or unexported fields
}

type SupersedePendingRequest struct {
	AgentID          string
	TaskID           string
	Prompt           string
	ExpectedRevision int64
	IdempotencyKey   string
}

type Task struct {
	ID              string     `json:"id"`
	AgentID         string     `json:"agent_id"`
	Order           int64      `json:"order"`
	Prompt          string     `json:"prompt"`
	IdempotencyHash string     `json:"idempotency_hash"`
	State           string     `json:"state"`
	CreatedAt       time.Time  `json:"created_at"`
	UpdatedAt       time.Time  `json:"updated_at"`
	DeliveredAt     *time.Time `json:"delivered_at,omitempty"`
	ConfirmedAt     *time.Time `json:"confirmed_at,omitempty"`
	// AcceptedAs is how Pi took the prompt: "turn" (Pi was idle and started
	// a turn for it) or "followUp" (Pi was already busy and queued it
	// internally; the bridge never delivers as steer).
	AcceptedAs      string     `json:"accepted_as,omitempty"`
	FinishedAt      *time.Time `json:"finished_at,omitempty"`
	BridgeInstance  string     `json:"bridge_instance,omitempty"`
	LeaseGeneration int64      `json:"lease_generation_at_delivery,omitempty"`
	CancelRequested bool       `json:"cancel_requested,omitempty"`
	// CancelRequestedAt and CancelLeaseGeneration record when, and under
	// which lease generation, a running task's cancellation was requested.
	// The bridge aborts only while the lease is still managed at that same
	// generation; any control change in between withholds the abort.
	CancelRequestedAt     *time.Time `json:"cancel_requested_at,omitempty"`
	CancelLeaseGeneration int64      `json:"cancel_lease_generation,omitempty"`
	// CancelProtocol is the protocol of the bridge holding the task when a
	// running cancellation was requested. 0 means the request predates
	// protocol gating (made by an older DevX against an older bridge).
	CancelProtocol int `json:"cancel_protocol,omitempty"`
	// AbortSentAt is written by the bridge under the lock immediately
	// before it calls ctx.abort() (at most once per task).
	AbortSentAt *time.Time `json:"abort_sent_at,omitempty"`
	// AbortWithheld explains why the bridge refused to abort a requested
	// cancellation (human control, human input, Pi-queued messages).
	AbortWithheld   string `json:"abort_withheld,omitempty"`
	HumanIntervened bool   `json:"human_intervened,omitempty"`
	// Revision increments on every write (Go and bridge). Edits of pending
	// work are compare-and-swap on it.
	Revision int64 `json:"revision,omitempty"`
	// EditKeys holds the idempotency hashes of edits applied to this task
	// (bounded), so a retried edit is recognised as already applied.
	EditKeys []string `json:"edit_keys,omitempty"`
	// Supersedes/SupersededBy link a pending task to its replacement.
	Supersedes   string `json:"supersedes,omitempty"`
	SupersededBy string `json:"superseded_by,omitempty"`
	StopReason   string `json:"stop_reason,omitempty"`
	Error        string `json:"error,omitempty"`
	ResultBytes  int64  `json:"result_bytes,omitempty"`
	Note         string `json:"note,omitempty"`
}

type TaskView struct {
	TaskID          string     `json:"task_id"`
	AgentID         string     `json:"agent_id"`
	State           string     `json:"state"`
	Phase           string     `json:"phase"`
	Revision        int64      `json:"revision"`
	WaitingReason   string     `json:"waiting_reason,omitempty"`
	CancelRequested bool       `json:"cancel_requested,omitempty"`
	CancelOutcome   string     `json:"cancel_outcome,omitempty"`
	AbortSentAt     *time.Time `json:"abort_sent_at,omitempty"`
	AbortWithheld   string     `json:"abort_withheld,omitempty"`
	AcceptedAt      *time.Time `json:"accepted_at,omitempty"`
	AcceptedAs      string     `json:"accepted_as,omitempty"`
	Supersedes      string     `json:"supersedes,omitempty"`
	SupersededBy    string     `json:"superseded_by,omitempty"`
	HumanIntervened bool       `json:"human_intervened,omitempty"`
	StopReason      string     `json:"stop_reason,omitempty"`
	Error           string     `json:"error,omitempty"`
	Note            string     `json:"note,omitempty"`
	CreatedAt       time.Time  `json:"created_at"`
	DeliveredAt     *time.Time `json:"delivered_at,omitempty"`
	FinishedAt      *time.Time `json:"finished_at,omitempty"`
	ResultBytes     int        `json:"result_bytes,omitempty"`
	Excerpt         string     `json:"result_excerpt,omitempty"`
	ExcerptTrunc    bool       `json:"result_excerpt_truncated,omitempty"`
	// LatestProgress is the newest mid-task progress the bridge recorded
	// for this task (redacted, bounded). Absent until the first completed
	// assistant turn is recorded, and always absent with bridges older than
	// protocol 3. After the task finishes it is the last progress recorded
	// before the result; read the result itself with pi_result.
	LatestProgress *ProgressView `json:"latest_progress,omitempty"`
}

type Tmux struct {
	// Exec, when set, receives the argv (without "tmux") instead of running
	// tmux directly.
	Exec func(args ...string) (string, error)
}

type Tool = tool

type ToolProvider interface {
	// Tools returns the provider's currently enabled tools. Disabled
	// capabilities must not be listed.
	Tools() []Tool
	// CallTool returns a complete MCP tool result, or handled=false when
	// name is not one of the provider's enabled tools.
	CallTool(name string, args json.RawMessage) (result map[string]any, handled bool)
	// TaskArtifacts lists artifacts produced while a task ran, for
	// inclusion in pi_status. It returns nil when not applicable or not
	// authorized; it never fails the status call.
	TaskArtifacts(agent *Agent, task *TaskView) []map[string]any
	// Instructions is appended to the initialize instructions when non-empty.
	Instructions() string
}

type UpdatePendingRequest struct {
	AgentID          string
	TaskID           string
	Prompt           string
	ExpectedRevision int64
	IdempotencyKey   string
}