protocol

type AgentProfilePayload struct {
	Version    uint8          `cbor:"1,keyasint"`
	Name       string         `cbor:"2,keyasint,omitempty"`
	Brief      string         `cbor:"3,keyasint,omitempty"`
	Protocols  []string       `cbor:"4,keyasint,omitempty"`
	Skills     []string       `cbor:"5,keyasint,omitempty"`
	CardHash   []byte         `cbor:"6,keyasint,omitempty"`
	Modalities []string       `cbor:"8,keyasint,omitempty"`
	Meta       map[string]any `cbor:"9,keyasint,omitempty"`
}

type BodyDHTPush struct {
	Key    []byte       `cbor:"1,keyasint"` // 32 bytes
	Record SignedRecord `cbor:"2,keyasint"`
}

type BodyDHTPushACK struct {
	Key              []byte `cbor:"1,keyasint"` // 32 bytes
	MsgID            []byte `cbor:"2,keyasint"` // 32-byte SHA-256 of Record.Payload
	OneShotSubscribe bool   `cbor:"3,keyasint,omitempty"`
}

type BodyFindNode struct {
	Target []byte `cbor:"1,keyasint"` // 32 NodeID
}

type BodyFindNodeResp struct {
	Nodes        []NodeInfo `cbor:"1,keyasint"`
	ObservedAddr []byte     `cbor:"2,keyasint"`
}

type BodyFindValue struct {
	Target           []byte `cbor:"1,keyasint"`
	RecType          uint8  `cbor:"2,keyasint,omitempty"` // 0 = all types
	OneShotSubscribe bool   `cbor:"3,keyasint,omitempty"` // request DHT node to push new records via DHT_PUSH
}

type BodyFindValueResp struct {
	Nodes        []NodeInfo     `cbor:"1,keyasint"`
	Record       *SignedRecord  `cbor:"2,keyasint,omitempty"`
	ObservedAddr []byte         `cbor:"3,keyasint"`
	Records      []SignedRecord `cbor:"4,keyasint,omitempty"`
}

type BodyNATProbeEcho struct {
	Token []byte `cbor:"1,keyasint"` // 8-byte nonce echoed from BodyNATProbeReq
}

type BodyNATProbeReq struct {
	Token       []byte `cbor:"1,keyasint"` // 8-byte random nonce
	ClaimedAddr []byte `cbor:"2,keyasint"` // wire-encoded UDP address (6 or 18 bytes)
}

type BodyPing struct {
	Address []byte `cbor:"1,keyasint"` // 21
}

type BodyPong struct {
	Address      []byte `cbor:"1,keyasint"`
	ObservedAddr []byte `cbor:"2,keyasint"` // 6 or 18
}

type BodyStore struct {
	Record SignedRecord `cbor:"1,keyasint"`
	Key    []byte       `cbor:"2,keyasint,omitempty"` // 32-byte DHT key; omit = NodeID(Address)
}

type BodyStoreResp struct {
	Stored     bool        `cbor:"1,keyasint"`
	AlreadyHad bool        `cbor:"2,keyasint,omitempty"` // true when the node already held an equal-or-newer record
	Reason     StoreReason `cbor:"3,keyasint,omitempty"` // non-zero only on rejection; 0 from old nodes means unknown
}

type DecodedMessage struct {
	Header       Header
	SenderPubkey ed25519.PublicKey
	SenderAddr   a2al.Address
	Body         any
}

type DiscoverFilter struct {
	Protocols []string `json:"protocols,omitempty"`
	Tags      []string `json:"tags,omitempty"`
}

type EndpointPayload struct {
	Endpoints []string `cbor:"1,keyasint"`
	NatType   uint8    `cbor:"2,keyasint"`
	// Signal is the primary WebSocket base URL for ICE trickle signaling (no query; room is
	// appended by peers). Kept for backward compatibility with nodes that only read key 3.
	Signal string `cbor:"3,keyasint,omitempty"`
	// Turns lists optional turn:// URLs without credentials (public relay hints).
	Turns []string `cbor:"4,keyasint,omitempty"`
	// Signals lists additional WebSocket base URLs for ICE signaling (multi-center).
	// New nodes prefer this list; old nodes that only read Signal (key 3) still work.
	// When non-empty, Signal should equal Signals[0] for maximum compatibility.
	Signals []string `cbor:"5,keyasint,omitempty"`
}

type EndpointRecord struct {
	Address   a2al.Address
	Endpoints []string
	NatType   uint8
	Signal    string
	Turns     []string
	// Signals is the multi-center signal URL list from EndpointPayload.Signals (key 5).
	// When non-empty, callers should prefer this over Signal. Signal is kept for compat.
	Signals   []string
	Timestamp uint64
	Seq       uint64
	TTL       uint32
}

type Header struct {
	Version  uint8  `cbor:"1,keyasint"`
	Features uint16 `cbor:"2,keyasint"`
	MsgType  uint8  `cbor:"3,keyasint"`
	TxID     []byte `cbor:"4,keyasint"`
}

type MailboxFrame struct {
	MsgID  [32]byte
	Record SignedRecord
}

type MailboxMessage struct {
	Sender  a2al.Address
	MsgType uint8
	Body    []byte
	// Seq is copied from the outer SignedRecord.Seq; it is monotonically
	// increasing per sender and serves as a unique record identifier.
	Seq uint64
	// SenderPubkey is the sender's Ed25519 identity public key, taken from
	// SignedRecord.Pubkey after signature verification.  It is guaranteed to
	// correspond to Sender (same key that derived the AID).  Callers may use
	// this to encrypt a reply without an extra DHT lookup.
	SenderPubkey ed25519.PublicKey
}

type MailboxPayload struct {
	Recipient   []byte `cbor:"1,keyasint"`
	SenderAddr  []byte `cbor:"2,keyasint"`
	EphemeralPK []byte `cbor:"3,keyasint"`
	Ciphertext  []byte `cbor:"4,keyasint"`
	Nonce       []byte `cbor:"5,keyasint"`
}

type NodeInfo struct {
	Address []byte `cbor:"1,keyasint"` // 21 bytes
	NodeID  []byte `cbor:"2,keyasint"` // 32 bytes
	IP      []byte `cbor:"3,keyasint"` // 4 or 16 bytes
	Port    uint16 `cbor:"4,keyasint"`
}

type SignedRecord struct {
	Address    []byte `cbor:"1,keyasint"`
	RecType    uint8  `cbor:"2,keyasint"`
	Payload    []byte `cbor:"3,keyasint"`
	Seq        uint64 `cbor:"4,keyasint"`
	Timestamp  uint64 `cbor:"5,keyasint"`
	TTL        uint32 `cbor:"6,keyasint"`
	Pubkey     []byte `cbor:"7,keyasint"`
	Signature  []byte `cbor:"8,keyasint"`
	Delegation []byte `cbor:"9,keyasint,omitempty"`
}

type StoreReason uint8

type TopicEntry struct {
	Address   a2al.Address
	Seq       uint64
	Timestamp uint64
	TTL       uint32
	Version   uint8
	Topic     string
	Name      string
	Protocols []string
	Tags      []string
	Brief     string
	Meta      map[string]any
}

type TopicPayload struct {
	Version   uint8          `cbor:"1,keyasint"`
	Topic     string         `cbor:"2,keyasint"`
	Name      string         `cbor:"3,keyasint"`
	Protocols []string       `cbor:"4,keyasint"`
	Tags      []string       `cbor:"5,keyasint"`
	Brief     string         `cbor:"6,keyasint"`
	Meta      map[string]any `cbor:"7,keyasint,omitempty"`
}