api

type AgentView struct {
	wire.Presence
	Short    string    `json:"short"`
	Status   string    `json:"status"`
	Sharing  bool      `json:"sharing,omitempty"` // self only: publishing presence
	Direct   bool      `json:"direct,omitempty"`  // connected to this host right now
	Received time.Time `json:"received,omitzero"`
	Via      string    `json:"via,omitempty"` // the peer it arrived from
	Hops     int       `json:"hops"`
}

type BlobInfo struct {
	Name     string `json:"name,omitempty"`
	Mime     string `json:"mime,omitempty"`
	Size     int64  `json:"size"`
	Received int64  `json:"received"`
	Status   string `json:"status"`
	Path     string `json:"path,omitempty"`
}

type ConnectParams struct {
	Address   string `json:"address"`
	TimeoutMS int    `json:"timeout_ms,omitempty"`
}

type ConnectResult struct {
	Peer     PeerView `json:"peer"`
	Existing bool     `json:"existing,omitempty"`
}

type Event struct {
	Seq      int64               `json:"seq"`
	At       time.Time           `json:"at"`
	Dir      string              `json:"dir"`  // in, out or sys
	Type     string              `json:"type"` // msg, state, grant, introduce, err, blob, bye, connected, ...
	Peer     string              `json:"peer"`
	PeerName string              `json:"peer_name,omitempty"`
	Th       string              `json:"th,omitempty"`
	Subject  string              `json:"subject,omitempty"` // the thread's subject
	ID       string              `json:"id,omitempty"`
	Acked    bool                `json:"acked,omitempty"`
	Msg      json.RawMessage     `json:"msg,omitempty"`
	Meta     map[string]any      `json:"meta,omitempty"`
	Blobs    map[string]BlobInfo `json:"blobs,omitempty"`
}

type GrantParams struct {
	Peer string   `json:"peer"`
	Caps []string `json:"caps"`
	TTL  string   `json:"ttl,omitempty"` // Go duration, default 1h
}

type IntroduceParams struct {
	To   string   `json:"to"`
	Peer string   `json:"peer"`
	Caps []string `json:"caps,omitempty"`
	TTL  string   `json:"ttl,omitempty"`
	Th   string   `json:"th,omitempty"`
}

type ModelParams struct {
	Model string `json:"model"`
}

type ModelResult struct {
	Model   string `json:"model"`
	Changed bool   `json:"changed"`
}

type Network struct {
	Self   AgentView   `json:"self"`
	Agents []AgentView `json:"agents"` // most recently heard first
}

type PeerParams struct {
	Peer   string `json:"peer,omitempty"`
	Reason string `json:"reason,omitempty"`
	Alias  string `json:"alias,omitempty"`
	Hash   string `json:"hash,omitempty"`
}

type PeerRef struct {
	Key  string `json:"key"`
	Name string `json:"name,omitempty"`
}

type PeerView struct {
	Key         string       `json:"key"`
	Short       string       `json:"short"`
	Name        string       `json:"name,omitempty"`
	Alias       string       `json:"alias,omitempty"`
	About       string       `json:"about,omitempty"`
	Caps        []string     `json:"caps,omitempty"`    // message families from its hello
	Granted     []string     `json:"granted,omitempty"` // capabilities it holds on us
	Connected   bool         `json:"connected"`
	Via         string       `json:"via,omitempty"`
	Outbound    bool         `json:"outbound,omitempty"`
	Since       time.Time    `json:"since,omitzero"`
	Dialing     bool         `json:"dialing,omitempty"`
	DialErr     string       `json:"dial_error,omitempty"`
	RTTms       int64        `json:"rtt_ms,omitempty"` // the connection\'s last ping round trip
	Parked      bool         `json:"parked,omitempty"`
	Outbox      int          `json:"outbox"`
	OpenThreads int          `json:"open_threads"`
	Unread      int          `json:"unread"`
	LastSeen    time.Time    `json:"last_seen,omitzero"`
	Addrs       []store.Addr `json:"addrs,omitempty"`
}

type PrivateParams struct {
	Peer string `json:"peer,omitempty"`
	Th   string `json:"th"`
}

type ReadParams struct {
	Peer   string `json:"peer,omitempty"`
	Th     string `json:"th,omitempty"`
	Inbox  bool   `json:"inbox,omitempty"`  // only received messages and notable local events
	Unread bool   `json:"unread,omitempty"` // only records not yet marked read
	Since  int64  `json:"since,omitempty"`  // after this seq
	Limit  int    `json:"limit,omitempty"`
	Mark   bool   `json:"mark,omitempty"` // mark returned records read
	// Mirrors includes lines other agents share with this host.
	Mirrors bool `json:"mirrors,omitempty"`
}

type ReadResult struct {
	Events   []Event       `json:"events"`
	Cursor   int64         `json:"cursor"`
	TimedOut bool          `json:"timed_out,omitempty"`
	Matched  bool          `json:"matched,omitempty"` // wait: the thread reached one of the states asked for
	Thread   *store.Thread `json:"thread,omitempty"`
}

type SendParams struct {
	Peer    string      `json:"peer,omitempty"`
	Th      string      `json:"th,omitempty"`
	Subject string      `json:"subject,omitempty"`
	Re      string      `json:"re,omitempty"`
	Parts   []wire.Part `json:"parts,omitempty"`
	Files   []string    `json:"files,omitempty"` // absolute paths
	// WaitAck is how long to wait for the peer's ack, in milliseconds. Zero
	// means the default: one second when the peer is connected, none
	// otherwise. A negative value does not wait.
	WaitAck int `json:"wait_ack_ms,omitempty"`
}

type SendResult struct {
	ID        string `json:"id"`
	Th        string `json:"th"`
	Thread    string `json:"thread"` // th again, under the name the --thread flag uses
	Peer      string `json:"peer"`
	PeerName  string `json:"peer_name,omitempty"`
	NewThread bool   `json:"new_thread,omitempty"`
	Connected bool   `json:"connected"`
	Acked     bool   `json:"acked"`
}

type ShareParams struct {
	With []string `json:"with"`
}

type StateParams struct {
	Peer  string `json:"peer,omitempty"`
	Th    string `json:"th"`
	State string `json:"state"`
	Note  string `json:"note,omitempty"`
}

type Status struct {
	Key         string     `json:"key"`
	Short       string     `json:"short"`
	Name        string     `json:"name"`
	About       string     `json:"about"`
	Harness     string     `json:"harness,omitempty"`    // the agent harness this daemon runs in
	ShareWith   []PeerRef  `json:"share_with,omitempty"` // hosts this agent mirrors its conversations to
	Model       string     `json:"model,omitempty"`      // the model the agent runs on, as last reported
	Active      *time.Time `json:"active,omitempty"`     // when the agent last acted through awp
	Waiting     bool       `json:"waiting,omitempty"`    // blocked in awp wait now
	Host        string     `json:"host,omitempty"`       // this machine's hostname
	Fingerprint string     `json:"fingerprint"`
	Version     string     `json:"version"`
	Home        string     `json:"home"`
	PID         int        `json:"pid"`
	Started     time.Time  `json:"started"`
	Addresses   []string   `json:"addresses"`
	Tailcat     string     `json:"tailcat,omitempty"` // bare tc... address to share
	TailcatErr  string     `json:"tailcat_error,omitempty"`
	TailcatWant bool       `json:"tailcat_enabled"`
	Presence    bool       `json:"presence,omitempty"` // publishing presence (see NOTES.md)
	Serve       []string   `json:"serve,omitempty"`
	Accept      string     `json:"accept"`
	Peers       []PeerView `json:"peers"`
	Unread      int        `json:"unread"`  // messages and states from peers not yet read
	Notices     int        `json:"notices"` // unread local notices (connection, sharing and file events)
	Outbox      int        `json:"outbox"`
}

type SubscribeParams struct {
	Peer  string `json:"peer,omitempty"`
	Th    string `json:"th,omitempty"`
	Since *int64 `json:"since,omitempty"`
	Inbox bool   `json:"inbox,omitempty"`
	Mark  bool   `json:"mark,omitempty"`
	// Mirrors includes lines other agents share with this host.
	Mirrors bool `json:"mirrors,omitempty"`
}

type WaitParams struct {
	Peer      string   `json:"peer,omitempty"`
	Th        string   `json:"th,omitempty"`
	States    []string `json:"states,omitempty"`
	TimeoutMS int      `json:"timeout_ms,omitempty"`
}