wire

type Ack struct {
	Envelope
}

type Auth struct {
	Envelope
	// Sig is the Ed25519 signature, base64url, over "awp-auth-v0" || 0x00 ||
	// my hello line || 0x00 || peer hello line, the lines as sent and
	// received without the newline.
	Sig string `json:"sig" jsonschema:"pattern=^[A-Za-z0-9_-]+$"`
	// Grants are grant objects (section 10.2) the sender presents.
	Grants []json.RawMessage `json:"grants,omitempty"`
}

type Bye struct {
	Envelope
	// Reason says why, for the log.
	Reason string `json:"reason,omitempty"`
}

type Chunk struct {
	Envelope
	// Ref names the blob, as the sender chose it.
	Ref string `json:"ref"`
	// N is the chunk index, from 0.
	N int `json:"n" jsonschema:"minimum=0"`
	// Last is true on the final chunk.
	Last bool `json:"last"`
	// Data is the chunk's bytes, standard base64 (B64Pattern; the tag
	// syntax cannot carry the padding).
	Data string `json:"data"`
}

type Envelope struct {
	// T is the message type.
	T string `json:"t"`
	// ID is unique per sender. A ULID or UUIDv7 is recommended, so that ids
	// sort by time; resume compares ids as strings.
	ID string `json:"id" jsonschema:"minLength=1"`
	// TS is an RFC 3339 UTC timestamp.
	TS string `json:"ts" jsonschema:"format=date-time"`
	// Th is the thread id. Required for msg, state and ack.
	Th string `json:"th,omitempty"`
	// Re is the id of the message this one responds to.
	Re string `json:"re,omitempty"`
}

type Err struct {
	Envelope
	// Code is the error code.
	Code string `json:"code"`
	// Detail is human readable.
	Detail string `json:"detail,omitempty"`
	// Ref names the blob a blob_refused is about.
	Ref string `json:"ref,omitempty"`
}

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

	Raw json.RawMessage
}

type GrantMsg struct {
	Envelope
	// Grant is the grant object (section 10.2).
	Grant json.RawMessage `json:"grant"`
}

type GrantObject struct {
	// Iss is the granting key.
	Iss string `json:"iss" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Sub is the receiving key.
	Sub string `json:"sub" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Caps are the capability strings granted (section 10.1).
	Caps []string `json:"caps"`
	// Exp is when the grant expires, RFC 3339.
	Exp string `json:"exp" jsonschema:"format=date-time"`
	// Nonce makes each grant distinct, base64url.
	Nonce string `json:"nonce" jsonschema:"pattern=^[A-Za-z0-9_-]+$"`
	// Sig is the issuer's signature, base64url.
	Sig string `json:"sig" jsonschema:"pattern=^[A-Za-z0-9_-]+$"`
	// 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 `json:"aud,omitempty" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
}

type Hello struct {
	Envelope
	// V is the protocol major version. A peer that sees a version it does
	// not speak sends err version and closes.
	V int `json:"v" jsonschema:"minimum=0"`
	// Key is the long-term Ed25519 public key. Its bytes are the peer's
	// identity.
	Key string `json:"key" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Name is how the peer calls itself, "harness@host" by convention.
	Name string `json:"name,omitempty"`
	// Nonce is 32 random bytes, base64url. The auth signature covers the
	// whole hello line, nonce included.
	Nonce string `json:"nonce" jsonschema:"pattern=^[A-Za-z0-9_-]+$"`
	// Caps lists the supported message families beyond the mandatory chat
	// and resume: blob, grant, introduce, and any extension.
	Caps []string `json:"caps,omitempty"`
	// About is free text for the other agent's context. It is not
	// authenticated until auth completes.
	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 is the introduced peer's public key.
	Key string `json:"key" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Name is what the introduced peer calls itself.
	Name string `json:"name,omitempty"`
	// Address is where the introduced peer listens, a hint: the key is the
	// identity.
	Address string `json:"address,omitempty"`
}

type Introduce struct {
	Envelope
	// Peer is the introduced peer.
	Peer IntroPeer `json:"peer"`
	// Grant is issued by the introducer to the recipient, for the
	// introduced peer to honor.
	Grant json.RawMessage `json:"grant,omitempty"`
}

type Message struct {
	T    string
	Type reflect.Type
}

type Mirror struct {
	Envelope
	// Of is the other party of the mirrored thread (the sender is one side).
	Of string `json:"of" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// OfName is the other party's name.
	OfName string `json:"of_name,omitempty"`
	// Subject is the mirrored thread's subject.
	Subject string `json:"subject,omitempty"`
	// Dir says who wrote Line: "out" the sender, "in" the other party.
	Dir string `json:"dir,omitempty" jsonschema:"enum=out,enum=in"`
	// 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 is the thread's title, meaningful on its first message.
	Subject string `json:"subject,omitempty"`
	// Parts are the message's pieces, in order.
	Parts []Part `json:"parts"`
}

type Part struct {
	// K is the part kind: text, code, data or blob.
	K string `json:"k"`
	// Text is the text of a text or code part.
	Text string `json:"text,omitempty"`
	// Lang names a code part's language, as a fenced block would.
	Lang string `json:"lang,omitempty"`
	// Data is a data part's inline JSON.
	Data json.RawMessage `json:"data,omitempty"`
	// Mime is the media type of a data or blob part.
	Mime string `json:"mime,omitempty"`
	// Ref names the blob a blob part refers to, as the chunks carry it.
	Ref string `json:"ref,omitempty"`
	// Name is a blob part's file name.
	Name string `json:"name,omitempty"`
	// Size is a blob part's size in bytes, before encoding.
	Size int64 `json:"size,omitempty" jsonschema:"minimum=0"`
}

type PartKind struct {
	K        string
	Doc      string
	Required []string
	Optional []string
}

type Ping struct {
	Envelope
}

type Pong struct {
	Envelope
}

type Presence struct {
	// Origin is the key of the agent the document describes and is signed by.
	Origin string `json:"origin" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Name is the agent's name, as in hello.
	Name string `json:"name,omitempty"`
	// About is the agent's about text, as in hello.
	About string `json:"about,omitempty"`
	// Version is the agent's implementation version.
	Version string `json:"version,omitempty"`
	// Harness is the agent harness: claude, codex, cursor, ...
	Harness string `json:"harness,omitempty"`
	// Model is the model the agent runs on, as it reports it.
	Model string `json:"model,omitempty"`
	// Host is the hostname of the machine the agent runs on.
	Host string `json:"host,omitempty"`
	// Shares lists the keys of the hosts the agent mirrors its
	// conversations to.
	Shares []string `json:"shares,omitempty"`
	// Active is when the agent last did something through awp, to 30
	// seconds, RFC 3339.
	Active string `json:"active,omitempty" jsonschema:"format=date-time"`
	// Waiting says the agent is blocked waiting for a message.
	Waiting bool `json:"waiting,omitempty"`
	// Seq increases with every document the origin signs; a relay keeps the
	// highest it has seen.
	Seq int64 `json:"seq" jsonschema:"minimum=0"`
	// TS is when the document was signed, RFC 3339.
	TS string `json:"ts" jsonschema:"format=date-time"`
	// Peers are the origin's peers.
	Peers []PresencePeer `json:"peers,omitempty"`
	// Threads are the origin's threads.
	Threads []PresenceThread `json:"threads,omitempty"`
	// Outbox counts the origin's queued, unacked messages.
	Outbox int `json:"outbox,omitempty" jsonschema:"minimum=0"`
	// Unread counts the messages the origin has not read.
	Unread int `json:"unread,omitempty" jsonschema:"minimum=0"`
	// Sig is the origin's signature, base64url.
	Sig string `json:"sig,omitempty" jsonschema:"pattern=^[A-Za-z0-9_-]+$"`
}

type PresenceMsg struct {
	Envelope
	// Doc is the signed presence document (Presence), verbatim.
	Doc json.RawMessage `json:"doc"`
	// Hops counts the relays the document has been through; it is not
	// forwarded past PresenceMaxHops.
	Hops int `json:"hops" jsonschema:"minimum=0"`
}

type PresencePeer struct {
	// Key is the peer's key.
	Key string `json:"key" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Name is the peer's name.
	Name string `json:"name,omitempty"`
	// Up says the peer is connected right now.
	Up bool `json:"up,omitempty"`
	// RTT is the connection's last round trip time in milliseconds, to show
	// latency across the network; 0 if unknown.
	RTT int64 `json:"rtt,omitempty" jsonschema:"minimum=0"`
}

type PresenceThread struct {
	// Th is the thread id.
	Th string `json:"th"`
	// Peer is the key of the other party.
	Peer string `json:"peer" jsonschema:"pattern=^ed25519:[A-Za-z0-9_-]{43}$"`
	// Subject is the thread's subject.
	Subject string `json:"subject,omitempty"`
	// Mine is the origin's state in the thread.
	Mine string `json:"mine,omitempty"`
	// Theirs is the peer's state, as the origin last heard it.
	Theirs string `json:"theirs,omitempty"`
	// Updated is when the thread last changed, RFC 3339.
	Updated string `json:"updated,omitempty" jsonschema:"format=date-time"`
	// Unread counts the thread's messages the origin has not read.
	Unread int `json:"unread,omitempty" jsonschema:"minimum=0"`
}

type Private struct {
	Envelope
}

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

type Resume struct {
	Envelope
	// Seen maps each thread id to the last message id the sender has
	// durably received in it. Empty on a first connection.
	Seen map[string]string `json:"seen"`
}

type State struct {
	Envelope
	// State is the thread state: open, working, waiting, done, failed or
	// closed by convention; peers may use others.
	State string `json:"state" jsonschema:"example=open,example=working,example=waiting,example=done,example=failed,example=closed"`
	// Note says more, such as why a thread failed.
	Note string `json:"note,omitempty"`
}

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