bgp

type Event struct {
	// Sent events use top-level type (string: may carry non-BGP event types like "cache", "request").
	Type     string        `json:"type"`
	TypeKind rpc.EventKind `json:"-"`
	MsgID    uint64        `json:"msg-id"`

	// Received events use message wrapper (includes type, id, direction).
	Message *MessageInfo `json:"message,omitempty"`

	// Peer info - uses RawMessage to handle both flat and nested formats.
	Peer json.RawMessage `json:"peer"`

	// State event field.
	State string `json:"state,omitempty"`

	// UPDATE fields - new command-style format.
	// Family operations are parsed from raw JSON (dynamic keys like "ipv4/unicast").
	// Format: {"ipv4/unicast": [{"next-hop": "...", "action": "add", "nlri": [...]}]}.
	// Keys are typed family.Family -- the JSON "afi/safi" string is resolved via
	// family.LookupFamily at parse time and unregistered families are dropped.
	FamilyOps map[family.Family][]FamilyOperation `json:"-"` // Populated by ParseEvent

	// Path attributes at top level.
	Origin              string   `json:"origin,omitempty"`
	ASPath              []uint32 `json:"as-path,omitempty"`
	MED                 *uint32  `json:"med,omitempty"`
	LocalPreference     *uint32  `json:"local-preference,omitempty"`
	Communities         []string `json:"communities,omitempty"`
	LargeCommunities    []string `json:"large-communities,omitempty"`
	ExtendedCommunities []string `json:"extended-communities,omitempty"`
	AIGP                *uint64  `json:"aigp,omitempty"`

	// Request fields.
	Serial  string   `json:"serial,omitempty"`
	Command string   `json:"command,omitempty"`
	Args    []string `json:"args,omitempty"`

	// Route refresh fields (RFC 7313). JSON text form uses the registered
	// AFI/SAFI names (e.g. "ipv4"/"unicast") via family.AFI/SAFI TextMarshaler.
	AFI  family.AFI  `json:"afi,omitempty"`
	SAFI family.SAFI `json:"safi,omitempty"`

	// Pool storage raw fields (format=full only).
	// Hex-encoded wire bytes for pool-based storage. The per-family maps use
	// typed family.Family keys; ParseEvent resolves JSON "afi/safi" strings via
	// family.LookupFamily and drops entries whose family is not registered.
	RawAttributes string                   `json:"raw-attributes,omitempty"` // Path attributes (without MP_REACH/UNREACH)
	RawNLRI       map[family.Family]string `json:"-"`                        // family -> hex bytes; populated by ParseEvent
	RawWithdrawn  map[family.Family]string `json:"-"`                        // family -> hex bytes; populated by ParseEvent

	// Decoded byte caches: set directly by structured producers to skip the
	// hex encode/decode round-trip. Accessors return these when present,
	// falling back to hex decoding the string fields for JSON-sourced events.
	RawAttributeBytes []byte                   `json:"-"`
	RawNLRIBytes      map[family.Family][]byte `json:"-"`
	RawWithdrawnBytes map[family.Family][]byte `json:"-"`

	// RFC 7911: ADD-PATH per-family flags from negotiated capabilities (format=full only).
	// When true for a family, NLRI wire bytes include 4-byte path-ID prefix.
	AddPath map[family.Family]bool `json:"-"` // Populated by parseRawFields from raw.add-path

	// RouteMeta carries route-level metadata through events (e.g., "src-role" for OTC filtering).
	// Set from ReceivedUpdate.Meta on sent events; stored on Route.Meta in ribOut.
	RouteMeta map[string]any `json:"route-meta,omitempty"`
}

type FamilyOperation struct {
	NextHop string             `json:"next-hop,omitempty"` // Only for "add" operations
	Action  routeaction.Action `json:"action"`
	NLRIs   []any              `json:"nlri"` // Strings or {"prefix":"...", "path-id":N}
}

type MessageInfo struct {
	Type      rpc.EventKind        `json:"type"`
	ID        uint64               `json:"id,omitempty"`
	Direction rpc.MessageDirection `json:"direction,omitempty"`
}

type PeerInfoJSON struct {
	Name   string         `json:"name,omitempty"`
	Group  string         `json:"group,omitempty"`
	Remote PeerRemoteInfo `json:"remote"`
	Local  *PeerLocalInfo `json:"local,omitempty"`
	State  string         `json:"state,omitempty"`
}

type PeerLocalInfo struct {
	Address string `json:"address,omitempty"`
	AS      uint32 `json:"as,omitempty"`
}

type PeerRemoteInfo struct {
	Address string `json:"address,omitempty"`
	AS      uint32 `json:"as"`
}

type Route struct {
	MsgID     uint64        `json:"msg-id,omitempty"`
	Family    family.Family `json:"family"`
	Prefix    string        `json:"prefix"`
	PathID    uint32        `json:"path-id,omitempty"` // RFC 7911: ADD-PATH path identifier
	NextHop   string        `json:"next-hop"`
	Timestamp time.Time     `json:"timestamp,omitzero"`

	// Path attributes for full route resend.
	Origin              *attribute.Origin             `json:"origin,omitempty"`
	ASPath              []uint32                      `json:"as-path,omitempty"`
	MED                 *uint32                       `json:"med,omitempty"`
	LocalPreference     *uint32                       `json:"local-preference,omitempty"`
	Communities         []attribute.Community         `json:"communities,omitempty"`
	LargeCommunities    []attribute.LargeCommunity    `json:"large-communities,omitempty"`
	ExtendedCommunities []attribute.ExtendedCommunity `json:"extended-communities,omitempty"`

	// RawAttrs is the hex-encoded path attributes from format=full sent events.
	// When non-empty, FormatAnnounceCommand uses "update hex attr set <hex>" format
	// instead of per-field text format. This preserves ALL transitive attributes
	// (including OTC, unknown attributes) through RIB replay.
	RawAttrs string `json:"raw-attrs,omitempty"`

	// Meta carries route-level metadata through the RIB for egress filtering on replay.
	// Set by handleSent from ReceivedUpdate.Meta (e.g., "src-role" for OTC suppression).
	// When the RIB replays routes through ForwardUpdate, egress filters read this.
	Meta map[string]any `json:"meta,omitempty"`

	// SourcePeer is the address of the peer that originally sent this route.
	// Set in ribOut entries to scope GR/LLGR stale propagation to the restarting peer.
	SourcePeer string `json:"source-peer,omitempty"`

	// StaleLevel tracks LLGR stale status for ribOut routes.
	// 0 = fresh, 1 = GR stale, 2 = LLGR stale (depreference threshold).
	// Set by markStaleCommand when propagating stale to ribOut.
	// Used by sendRoutes to carry meta["stale"] through ForwardUpdate to egress filters.
	StaleLevel uint8 `json:"stale-level,omitempty"`

	// VPN fields — used by watchdog and future VPN route replay.
	RD     string   `json:"rd,omitempty"`     // Route Distinguisher ("ASN:NN" or "IP:NN")
	Labels []uint32 `json:"labels,omitempty"` // MPLS label stack
}