serve

type ArtifactSnapshot struct {
	Kind    string `json:"kind"`
	Path    string `json:"path"`
	Label   string `json:"label"`
	AddedAt string `json:"added_at"`
	Missing bool   `json:"missing,omitempty"`
}

type BoardGroup struct {
	Repo   string       `json:"repo"`
	Quests []BoardQuest `json:"quests"`
}

type BoardQuest struct {
	Quest   quest.Quest          `json:"quest"`
	Runtime QuestRuntimeSnapshot `json:"runtime"`
}

type BoardSnapshot struct {
	ObservedAt time.Time    `json:"observed_at"`
	Groups     []BoardGroup `json:"groups"`
}

type Change struct {
	Topics     []string
	QuestIDs   []string
	SessionIDs []string
	Clock      bool
	// BroadTracker marks a session-agnostic tracker change (e.g. a repo-colors
	// edit) that must rebuild the full tracker snapshot. It survives coalescing
	// so a broad change merged with per-session changes inside the debounce
	// window is not silently demoted to a per-session delta.
	BroadTracker bool
}

type ChangeSource interface {
	Subscribe(context.Context) (<-chan Change, func())
	Close() error
}

type CurrentSession struct {
	ID          string `json:"id"`
	Title       string `json:"title,omitempty"`
	SessionType string `json:"session_type,omitempty"`
}

type Envelope struct {
	ProtocolVersion int             `json:"protocol_version"`
	Type            string          `json:"type"`
	ID              json.RawMessage `json:"id,omitempty"`
	OK              *bool           `json:"ok,omitempty"`
	Topic           string          `json:"topic,omitempty"`
	Data            any             `json:"data,omitempty"`
	Error           string          `json:"error,omitempty"`
}

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

type MutationCommandRunner interface {
	RunMutationCommand(context.Context, []string, []byte) ([]byte, error)
}

type QuestRuntimeSnapshot struct {
	Sessions       []string               `json:"sessions"`
	SessionDetails []QuestSessionSnapshot `json:"session_details,omitempty"`
	Adventurers    []QuestSessionSnapshot `json:"adventurers,omitempty"`
	Agent          string                 `json:"agent"`
	Gates          map[string]string      `json:"gates,omitempty"`
	GatesAt        map[string]time.Time   `json:"gates_at,omitempty"`
	ObservedAt     time.Time              `json:"observed_at"`
	Loop           *quest.LoopRuntime     `json:"loop,omitempty"`
}

type QuestSessionSnapshot struct {
	ID    string             `json:"id"`
	Agent string             `json:"agent,omitempty"`
	State string             `json:"state,omitempty"`
	Since time.Time          `json:"since,omitempty"`
	Loop  *quest.LoopRuntime `json:"loop,omitempty"`
}

type QuestSnapshot struct {
	Quest      *quest.Quest         `json:"quest"`
	Runtime    QuestRuntimeSnapshot `json:"runtime"`
	ObservedAt time.Time            `json:"observed_at"`
}

type RepoSnapshot struct {
	Identity string `json:"identity,omitempty"`
	Name     string `json:"name,omitempty"`
	Color    string `json:"color,omitempty"`
}

type Request struct {
	ID      json.RawMessage `json:"id,omitempty"`
	Method  string          `json:"method"`
	Topics  []string        `json:"topics,omitempty"`
	QuestID string          `json:"quest_id,omitempty"`
	Data    json.RawMessage `json:"data,omitempty"`
}

type Server struct {
	SocketPath    string
	Snapshotter   *Snapshotter
	ClockInterval time.Duration

	ChangeSource ChangeSource

	// MutationRunner is injectable for tests; production re-execs this binary
	// for CLI-owned session lifecycle mutations.
	MutationRunner MutationCommandRunner
	TmuxClient     *tmux.Client
	DirQuerier     dirsuggest.DirQuerier
}

type SessionSnapshot struct {
	ID             string             `json:"id"`
	Title          string             `json:"title,omitempty"`
	Status         string             `json:"status"`
	State          string             `json:"state,omitempty"`
	ElapsedMS      int64              `json:"elapsed_ms"`
	ElapsedSince   *time.Time         `json:"elapsed_since,omitempty"`
	LatestActivity string             `json:"latest_activity,omitempty"`
	LastKind       string             `json:"last_kind,omitempty"`
	WorktreePath   string             `json:"worktree_path,omitempty"`
	PrimaryAgent   string             `json:"primary_agent,omitempty"`
	SessionType    string             `json:"session_type,omitempty"`
	ParentID       string             `json:"parent_id,omitempty"`
	WorkerCount    int                `json:"worker_count"`
	IsCurrent      bool               `json:"is_current"`
	QuestID        string             `json:"quest_id,omitempty"`
	QuestTitle     string             `json:"quest_title,omitempty"`
	QuestLoop      *quest.LoopRuntime `json:"quest_loop,omitempty"`
	Artifacts      []ArtifactSnapshot `json:"artifacts,omitempty"`
	Repo           RepoSnapshot       `json:"repo,omitempty"`
	DisplayColor   string             `json:"display_color,omitempty"`
}

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

type TrackerSnapshot struct {
	ObservedAt time.Time         `json:"observed_at"`
	Current    *CurrentSession   `json:"current,omitempty"`
	Sessions   []SessionSnapshot `json:"sessions"`
}