network

type Connection interface {
	// Read reads data from the connection.
	Read(p []byte) (n int, err error)

	// Write writes data to the connection.
	Write(p []byte) (n int, err error)

	// Close closes the connection.
	Close() error

	// RemoteID returns the remote node ID.
	RemoteID() core.ID

	// RemoteAddr returns the remote address.
	RemoteAddr() string

	// LocalAddr returns the local address.
	LocalAddr() string
}

type Dialer interface {
	// Dial dials a connection to the address.
	Dial(ctx context.Context, addr string) (Connection, error)
}

type Error string

type Handler interface {
	// Handle processes a message and optionally returns a response.
	Handle(ctx context.Context, msg *Message) (*Message, error)
}

type HandlerFunc func(ctx context.Context, msg *Message) (*Message, error)

type Listener interface {
	// Accept accepts a new connection.
	Accept() (Connection, error)

	// Close closes the listener.
	Close() error

	// Addr returns the listener address.
	Addr() string
}

type Message struct {
	// Type identifies the message type
	Type MessageType `json:"type"`

	// From is the sender's node ID
	From core.ID `json:"from"`

	// To is the recipient's node ID (empty for broadcast)
	To core.ID `json:"to,omitempty"`

	// Payload is the message data
	Payload []byte `json:"payload"`

	// Timestamp when the message was created
	Timestamp time.Time `json:"timestamp"`

	// Signature from the sender
	Signature []byte `json:"signature,omitempty"`
}

type MessageType uint8

type Peer struct {
	// ID is the peer's node ID
	ID core.ID `json:"id"`

	// Addr is the peer's network address
	Addr string `json:"addr"`

	// State is the connection state
	State PeerState `json:"state"`

	// PublicKey is the peer's public key (PQ-safe)
	PublicKey []byte `json:"publicKey,omitempty"`

	// LastSeen is when the peer was last seen
	LastSeen time.Time `json:"lastSeen"`

	// ConnectedAt is when the connection was established
	ConnectedAt time.Time `json:"connectedAt,omitempty"`

	// MessagesSent is the count of messages sent to this peer
	MessagesSent uint64 `json:"messagesSent"`

	// MessagesReceived is the count of messages received from this peer
	MessagesReceived uint64 `json:"messagesReceived"`

	// Latency is the measured round-trip latency
	Latency time.Duration `json:"latency"`
	// contains filtered or unexported fields
}

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

type PeerState uint8

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

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

type Transport interface {
	// Start starts the transport.
	Start(ctx context.Context) error

	// Stop stops the transport.
	Stop() error

	// Send sends a message to a specific node.
	Send(ctx context.Context, to core.ID, msg *Message) error

	// Broadcast sends a message to all known peers.
	Broadcast(ctx context.Context, msg *Message) error

	// Receive returns a channel for receiving messages.
	Receive() <-chan *Message

	// Connect connects to a peer.
	Connect(ctx context.Context, addr string) error

	// Disconnect disconnects from a peer.
	Disconnect(nodeID core.ID) error

	// Peers returns the list of connected peer IDs.
	Peers() []core.ID

	// LocalID returns the local node ID.
	LocalID() core.ID
}