web

type Activity struct {
	Seq     int64     `json:"seq"`
	At      time.Time `json:"at"`
	Kind    string    `json:"kind"`
	From    string    `json:"from"`
	To      string    `json:"to,omitempty"`
	Th      string    `json:"th,omitempty"`
	Subject string    `json:"subject,omitempty"`
	State   string    `json:"state,omitempty"`
	Text    string    `json:"text,omitempty"`
	Local   bool      `json:"local"`
}

type Agent struct {
	Key     string `json:"key"`
	Short   string `json:"short"`
	Name    string `json:"name"`
	About   string `json:"about,omitempty"`
	Version string `json:"version,omitempty"`
	Harness string `json:"harness,omitempty"` // claude, codex, ...: declared, else guessed from the name
	Model   string `json:"model,omitempty"`   // the model it runs on, as it reports it
	Host    string `json:"host,omitempty"`    // the hostname of the machine it runs on
	// LastActive is when it last did something through awp (to 30
	// seconds for other hosts); Listening says it is blocked in awp wait.
	LastActive *time.Time `json:"last_active,omitempty"`
	// How this host reaches it, for its direct peers: the transport of the
	// live connection (tailcat, tcp, unix) and its round trip; or, when
	// this host is trying and failing to reconnect, why.
	Transport   string     `json:"transport,omitempty"`
	RTTms       int64      `json:"rtt_ms,omitempty"`
	Unreachable string     `json:"unreachable,omitempty"`
	Listening   bool       `json:"listening,omitempty"`
	Status      string     `json:"status"`
	Sharing     bool       `json:"sharing"`
	Direct      bool       `json:"direct"`
	Via         string     `json:"via,omitempty"`
	Hops        int        `json:"hops"`
	Seen        *time.Time `json:"seen,omitempty"`
	Threads     int        `json:"threads"`
	Active      int        `json:"active"`
	Working     bool       `json:"working"`
	Waiting     bool       `json:"waiting"`
}

type Conversation struct {
	Peer     string    `json:"peer"`
	Th       string    `json:"th"`
	Subject  string    `json:"subject"`
	AState   string    `json:"a_state"`
	BState   string    `json:"b_state"`
	Messages []Message `json:"messages"`
}

type Link struct {
	A  string `json:"a"`
	B  string `json:"b"`
	Up bool   `json:"up"`
	// RTTms is the connection's round trip time as either end last
	// measured it (milliseconds; 0 unknown).
	RTTms int64 `json:"rtt_ms,omitempty"`
}

type Message struct {
	Seq   int64     `json:"seq"`
	At    time.Time `json:"at"`
	From  string    `json:"from"`
	Kind  string    `json:"kind"`
	Parts []WebPart `json:"parts,omitempty"`
	State string    `json:"state,omitempty"`
	Note  string    `json:"note,omitempty"`
	Acked *bool     `json:"acked,omitempty"`
}

type Server struct {
	C      *control.Client
	Assets fs.FS // nil: API only
	Log    func(format string, args ...any)
	// contains filtered or unexported fields
}

type State struct {
	At       time.Time `json:"at"`
	Version  string    `json:"version"`
	Self     string    `json:"self"`
	HostName string    `json:"host_name"`
	Presence bool      `json:"presence"`
	Address  string    `json:"address,omitempty"`
	// Listeners are the addresses this host accepts connections on, and
	// TailcatError why its tailcat listener is not up, if it is not.
	Listeners    []string `json:"listeners"`
	TailcatError string   `json:"tailcat_error,omitempty"`
	Agents       []Agent  `json:"agents"`
	Links        []Link   `json:"links"`
	Threads      []Thread `json:"threads"`
	Stats        Stats    `json:"stats"`
}

type Stats struct {
	Agents  int `json:"agents"`
	Up      int `json:"up"`
	Threads int `json:"threads"`
	Active  int `json:"active"`
	Working int `json:"working"`
	Waiting int `json:"waiting"`
}

type Thread struct {
	ID      string     `json:"id"`
	Th      string     `json:"th"`
	A       string     `json:"a"`
	B       string     `json:"b"`
	AState  string     `json:"a_state"`
	BState  string     `json:"b_state"`
	Subject string     `json:"subject"`
	Updated *time.Time `json:"updated,omitempty"`
	Local   bool       `json:"local"`
	Peer    string     `json:"peer,omitempty"`
	// SharedBy is the agent that shares this thread with this host
	// (wire/mirror.go), when this host is not part of it: its
	// conversation can be read too.
	SharedBy string `json:"shared_by,omitempty"`
	Unread   int    `json:"unread,omitempty"`
}

type WebPart struct {
	Type   string          `json:"type"`
	Text   string          `json:"text,omitempty"`
	Lang   string          `json:"lang,omitempty"`
	Data   json.RawMessage `json:"data,omitempty"`
	Name   string          `json:"name,omitempty"`
	Mime   string          `json:"mime,omitempty"`
	Size   *int64          `json:"size,omitempty"`
	Status string          `json:"status,omitempty"`
	// URL fetches a file this host has (awp web's /api/blob): received
	// and complete, or sent by this host.
	URL string `json:"url,omitempty"`
}