Add or update a peer in the registry

Parse a command from user input

Get all active peers

Registers a new peer and returns the assigned peer ID and public address.

Create a test socket address with a given port

Returns a list of all registered peers.

Processes a client message and returns an optional response.

Remove all timed-out peers

Sends a message to the bootstrap server.

Unregisters a peer by ID.

Updates the last_seen timestamp for a peer.

Format the message for display

Handles a single WebSocket connection.

Get the local address the service is listening on

Get announcement interval as Duration

Background task that periodically removes stale peers.

Connects to the bootstrap server.

Default value functions for serde

Gets the public address for a peer.

Check if this peer has timed out

Get peer timeout as Duration

Update the last_seen timestamp

Registers with the bootstrap server.

Removes peers that have not sent a heartbeat within the timeout period.

Requests the peer list from the bootstrap server.

Run the application

Main event loop for the bootstrap client.

Send a message to a peer by nickname

Spawn the input handler task

Updates the peer registry with peers from the bootstrap server.

Disconnects from the bootstrap server.

Print an error message

Create a peer ID from a socket address (deterministic)

Load configuration from a TOML file

Handle an incoming TCP connection

Handle the /peers command

Get help text for a command

Print a regular informational message

Returns the local address the server is bound to.

Print a message received from a peer

Create a new text message

Creates a new bootstrap client.

Create a new discovery service

Create a new random peer ID

Create a new config with a nickname and dynamic port

Creates a new PeerInfo instance.

Creates a new bootstrap server bound to the given address.

Creates a new empty peer registry.

Returns the total number of registered peers.

Print the peer list

Processes a server message.

Print without a newline and flush

Generate a random port number for testing

Receives and processes a message from the bootstrap server.

Run the messaging service This accepts incoming TCP connections and handles them concurrently.

Runs the bootstrap client with reconnection logic.

Run the discovery service This function runs two concurrent tasks: 1. Periodically announce our presence 2. Listen for announcements from other peers

Runs the bootstrap server, accepting and handling connections.

Sends a heartbeat to the bootstrap server.

Spawn the event handler task

Print a success message

Create a test socket address with a random IP and given port