libp2p Host

The XE host is a standard libp2p node configured for TCP transport with persistent identity, connection management, and multiple discovery mechanisms.

#Host Creation

func NewHost(ctx context.Context, port int, dataDir string, version string, enableRelay bool) (host.Host, error)

The host listens on all interfaces:

/ip4/0.0.0.0/tcp/{port}

#Connection Manager

The connection manager keeps the number of active peer connections within bounds:

When the number of connections exceeds the high watermark, the connection manager begins pruning connections down toward the low watermark. New connections are not pruned within the grace period.

cm, err := connmgr.NewConnManager(100, 400, connmgr.WithGracePeriod(time.Minute))

#Persistent Identity

When dataDir is provided, the host generates an Ed25519 keypair on first run and persists it to {dataDir}/host.key. On subsequent starts, the key is loaded from disk, giving the node a stable peer ID across restarts.

{dataDir}/host.key    # Ed25519 private key (libp2p marshaled format, mode 0600)

If dataDir is empty (e.g., in tests), a new ephemeral identity is generated each time.

#User-Agent

The host identifies itself with:

xe/{version}

This appears in the libp2p identify protocol and can be used for version-aware peer selection.

#Relay Support

When enableRelay is true, the host enables three capabilities:

This allows nodes behind NAT or firewalls to participate in the network by routing connections through relay-capable peers.

#Discovery

#mDNS (Local Network)

mDNS discovery is started automatically via SetupDiscovery(). It uses the service tag xe-poc and connects to any discovered peer on the local network.

func SetupDiscovery(ctx context.Context, h host.Host) error

When a peer is found via mDNS, the node connects automatically. Peers with the same peer ID (self) are ignored.

#Bootstrap Peers

Bootstrap peers are specified via the -dial CLI flag as comma-separated multiaddrs:

$ xe-node -dial "/ip4/1.2.3.4/tcp/9000/p2p/12D3KooW...,/ip4/5.6.7.8/tcp/9000/p2p/12D3KooW..."

The node dials each address on startup with a 10-second timeout per peer. If any connections fail, a background goroutine retries every 10 seconds until all bootstrap peers are connected.

Startup  │  ├─ Dial peer A ─── success  ├─ Dial peer B ─── fail  │  └─ Start retry loop (every 10s)       ├─ Check: A connected? yes, skip       ├─ Check: B connected? no, dial again       └─ All connected? → stop loop

#Kademlia DHT

The DHT provides network-wide peer discovery beyond the local network and bootstrap list. See DHT below.

#DHT Setup

func SetupDHT(ctx context.Context, h host.Host) (*dht.IpfsDHT, error)

The DHT is configured with:

The /xe protocol prefix ensures XE nodes form their own DHT, isolated from the public IPFS DHT. Server mode means the node stores and serves routing records, not just queries them.

After creation, Bootstrap() is called to populate the routing table from the existing peerstore.

The DHT is used by the Messenger to resolve peer IDs to addresses via FindPeer() when a target peer is not already known.

#Peer Dialing

The DialPeer function connects to a peer given a multiaddr string:

func DialPeer(ctx context.Context, h host.Host, addr string) error

The ParsePeerAddr helper extracts peer address info from a multiaddr:

func ParsePeerAddr(addr string) (*peer.AddrInfo, error)

#Configuration Summary

#Lifecycle

1. Create host -- NewHost() sets up TCP transport, connection manager, and identity
2. Start mDNS -- SetupDiscovery() enables local network discovery
3. Bootstrap DHT -- SetupDHT() creates and bootstraps the Kademlia DHT
4. Dial bootstrap peers -- bootstrapWithRetry() connects to known peers with retry
5. Register protocols -- Sync, messaging, and gossip handlers are registered on the host
6. Shutdown -- Host is closed, all streams and connections are terminated