dht

type BootstrapSeed struct {
	Addr net.Addr
	Info protocol.NodeInfo
}

type Config struct {
	Transport transport.Transport
	Keystore  crypto.KeyStore
	// OnObservedAddr is called whenever a DHT response carries an observed_addr
	// (PONG, FIND_NODE_RESP, FIND_VALUE_RESP). reporter is the responding node's
	// NodeID; wire is the raw observed_addr bytes (6 or 18 bytes).
	// May be nil.
	OnObservedAddr func(reporter a2al.NodeID, wire []byte)
	// RecordAuth is an optional authority policy called by Store.Put after
	// signature/expiry verification passes (Phase 4: includes DHT key).
	// If nil, no authority check is performed (useful in tests).
	RecordAuth RecordAuthFunc
	// MaxStoreKeys limits the number of distinct DHT keys in the local store.
	// 0 uses DefaultMaxTotalKeys. Configurable per-node soft limit.
	MaxStoreKeys int
	// Logger is used for DHT-level diagnostics (send failures, RPC retries).
	// If nil, slog.Default() is used.
	Logger *slog.Logger
	// SeenPeersPath is the file path for persisting the seenPeers sliding-window
	// table across restarts (spec §7.3). Empty disables persistence (default in
	// tests). The file is written with mode 0600.
	SeenPeersPath string
}

type DebugStats struct {
	RxPackets             uint64 `json:"rx_packets_verified"`
	TxPackets             uint64 `json:"tx_packets"`
	RPCOK                 uint64 `json:"rpc_completed"`
	TotalPeers            int    `json:"total_peers"`
	Reach1h               int    `json:"reach_1h"`
	Reach24h              int    `json:"reach_24h"`
	Reach7d               int    `json:"reach_7d"`
	EstimatedNetworkSize  int    `json:"estimated_network_size"`
	UniqueNodesSinceStart uint64 `json:"unique_nodes_since_start"`
}

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

type PeerHealthState uint8

type PeerIdentity struct {
	Address      a2al.Address
	NodeID       a2al.NodeID
	ObservedWire []byte // BodyPong.observed_addr (how reporter sees us); may be nil
}

type Query struct {
	Alpha   int
	Stagger time.Duration
	// contains filtered or unexported fields
}

type RecordAuthFunc func(key a2al.NodeID, rec protocol.SignedRecord, now time.Time) error

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

type StoreRecordDebug struct {
	KeyNodeIDHex string `json:"key_node_id_hex"`
	AddressHex   string `json:"address_hex"`
	RecType      uint8  `json:"rec_type"`
	Seq          uint64 `json:"seq"`
	Timestamp    uint64 `json:"timestamp"`
	TTL          uint32 `json:"ttl_seconds"`
	PayloadLen   int    `json:"payload_cbor_len"`
}