wire

type Ack struct {
	Envelope
}

type Auth struct {
	Envelope
	Sig    string            `json:"sig"`
	Grants []json.RawMessage `json:"grants,omitempty"`
}

type Bye struct {
	Envelope
	Reason string `json:"reason,omitempty"`
}

type Chunk struct {
	Envelope
	Ref  string `json:"ref"`
	N    int    `json:"n"`
	Last bool   `json:"last"`
	Data string `json:"data"`
}

type Envelope struct {
	T  string `json:"t"`
	ID string `json:"id"`
	TS string `json:"ts"`
	Th string `json:"th,omitempty"`
	Re string `json:"re,omitempty"`
}

type Err struct {
	Envelope
	Code   string `json:"code"`
	Detail string `json:"detail,omitempty"`
	Ref    string `json:"ref,omitempty"`
}

type Grant struct {
	Iss   string
	Sub   string
	Caps  []string
	Exp   time.Time
	Nonce string
	Sig   string

	// Aud is an extension: when set, only the peer with this key should
	// honor the grant. Introductions use it so that a grant meant for the
	// introduced peer does not also give the recipient powers over the
	// introducer. Peers that do not know the field ignore it, which can
	// only make them honor less, never more, than the spec already says.
	Aud string

	Raw json.RawMessage
}

type GrantMsg struct {
	Envelope
	Grant json.RawMessage `json:"grant"`
}

type Hello struct {
	Envelope
	V     int      `json:"v"`
	Key   string   `json:"key"`
	Name  string   `json:"name,omitempty"`
	Nonce string   `json:"nonce"`
	Caps  []string `json:"caps,omitempty"`
	About string   `json:"about,omitempty"`

	// Addr is an extension: an address at which the sender can be reached,
	// so that either side can reconnect (section 4.3). Peers that do not
	// know it ignore it, as section 5 requires.
	Addr string `json:"addr,omitempty"`

	// Shares is an extension (mirror.go): the keys of the hosts this agent
	// mirrors its conversations to, so the other party knows.
	Shares []string `json:"shares,omitempty"`
}

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

type IntroPeer struct {
	Key     string `json:"key"`
	Name    string `json:"name,omitempty"`
	Address string `json:"address,omitempty"`
}

type Introduce struct {
	Envelope
	Peer  IntroPeer       `json:"peer"`
	Grant json.RawMessage `json:"grant,omitempty"`
}

type Mirror struct {
	Envelope
	// Of is the other party of the mirrored thread (the sender is one side).
	Of      string `json:"of"`
	OfName  string `json:"of_name,omitempty"`
	Subject string `json:"subject,omitempty"`
	// Dir says who wrote Line: "out" the sender, "in" the other party.
	Dir string `json:"dir,omitempty"`
	// Line is the original msg or state line, verbatim. A msg's blob parts
	// keep their name, type and size; the file itself is not mirrored.
	Line json.RawMessage `json:"line,omitempty"`
	// Withdraw asks the receiver to delete everything it has of the thread
	// th between the sender and Of.
	Withdraw bool `json:"withdraw,omitempty"`
}

type Msg struct {
	Envelope
	Subject string `json:"subject,omitempty"`
	Parts   []Part `json:"parts"`
}

type Part struct {
	K    string          `json:"k"`
	Text string          `json:"text,omitempty"`
	Lang string          `json:"lang,omitempty"`
	Data json.RawMessage `json:"data,omitempty"`
	Mime string          `json:"mime,omitempty"`
	Ref  string          `json:"ref,omitempty"`
	Name string          `json:"name,omitempty"`
	Size int64           `json:"size,omitempty"`
}

type Ping struct {
	Envelope
}

type Pong struct {
	Envelope
}

type Presence struct {
	Origin  string   `json:"origin"`
	Name    string   `json:"name,omitempty"`
	About   string   `json:"about,omitempty"`
	Version string   `json:"version,omitempty"`
	Harness string   `json:"harness,omitempty"` // the agent harness: claude, codex, cursor, ...
	Model   string   `json:"model,omitempty"`   // the model the agent runs on, as it reports it
	Host    string   `json:"host,omitempty"`    // the hostname of the machine it runs on
	Shares  []string `json:"shares,omitempty"`  // keys of the hosts it mirrors its conversations to
	// Active is when the agent last did something through awp, to 30
	// seconds; Waiting says it is blocked waiting for a message.
	Active  string           `json:"active,omitempty"`
	Waiting bool             `json:"waiting,omitempty"`
	Seq     int64            `json:"seq"`
	TS      string           `json:"ts"`
	Peers   []PresencePeer   `json:"peers,omitempty"`
	Threads []PresenceThread `json:"threads,omitempty"`
	Outbox  int              `json:"outbox,omitempty"`
	Unread  int              `json:"unread,omitempty"`
	Sig     string           `json:"sig,omitempty"`
}

type PresenceMsg struct {
	Envelope
	Doc  json.RawMessage `json:"doc"`
	Hops int             `json:"hops"`
}

type PresencePeer struct {
	Key  string `json:"key"`
	Name string `json:"name,omitempty"`
	Up   bool   `json:"up,omitempty"` // connected right now
	// RTT is the connection's last round trip time in milliseconds, an
	// extension to show latency across the network; 0 if unknown.
	RTT int64 `json:"rtt,omitempty"`
}

type PresenceThread struct {
	Th      string `json:"th"`
	Peer    string `json:"peer"`
	Subject string `json:"subject,omitempty"`
	Mine    string `json:"mine,omitempty"`   // the origin's state
	Theirs  string `json:"theirs,omitempty"` // the peer's state, as the origin last heard it
	Updated string `json:"updated,omitempty"`
	Unread  int    `json:"unread,omitempty"`
}

type Private struct {
	Envelope
}

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

type Resume struct {
	Envelope
	Seen map[string]string `json:"seen"`
}

type State struct {
	Envelope
	State string `json:"state"`
	Note  string `json:"note,omitempty"`
}

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