Struct Libp2pNetwork 

pub struct Libp2pNetwork {
    pub swarm: Swarm<ChatBehaviour>,
    pub local_peer_id: PeerId,
    pub dht_discovery_enabled: bool,
    pub bootstrap_peer_ids: Vec<PeerId>,
    /* private fields */
}

Shared libp2p network implementation fields used by both native and WASM builds.

Fields

swarm: Swarm<ChatBehaviour>

local_peer_id: PeerId

dht_discovery_enabled: bool

bootstrap_peer_ids: Vec<PeerId>

Implementations

impl Libp2pNetwork

pub fn on_new_listen_addr(&self, address: Multiaddr) -> Option<NetworkEvent>

pub fn on_external_addr_confirmed( &self, address: Multiaddr, ) -> Option<NetworkEvent>

pub fn on_connection_established( &mut self, peer_id: PeerId, endpoint: ConnectedPoint, num_established: u32, ) -> Option<NetworkEvent>

pub fn on_connection_closed( &mut self, peer_id: PeerId, endpoint: ConnectedPoint, num_established: u32, ) -> Option<NetworkEvent>

pub fn on_history_message( &mut self, peer: PeerId, message: Message<Vec<u8>, Vec<u8>>, ) -> Option<NetworkEvent>

pub fn on_identify_received(&mut self, peer_id: PeerId, info: Info)

pub fn on_gossipsub_message( &self, propagation_source: PeerId, message: Message, ) -> Option<NetworkEvent>

pub fn handle_swarm_event( &mut self, event: SwarmEvent<ChatBehaviourEvent>, ) -> Option<NetworkEvent>

Shared swarm event handler. Native and WASM modules call this for all common events, handling only platform-specific arms themselves.

Trait Implementations

impl NetworkNode for Libp2pNetwork

fn local_id(&self) -> PeerId

Return the local peer/node/endpoint ID.

fn dial(&mut self, addr: &Multiaddr) -> NetworkResult<()>

Dial a peer by an opaque address string (multiaddr, endpoint ticket, etc.).

fn join_room(&mut self, room: &RoomId) -> NetworkResult<()>

Join a room/topic. The backend maps the room name to its internal topic mechanism.

fn publish_message(&mut self, data: Vec<u8>) -> NetworkResult<()>

Publish a message to the room topic (pubsub / gossip). All room members receive this via BroadcastReceived.

fn send_message( &mut self, peer_id: &PeerId, data: Vec<u8>, ) -> NetworkResult<RequestId>

Send a message to a specific peer. Returns an opaque request ID.

fn send_response( &mut self, request_id: &RequestId, data: Vec<u8>, ) -> NetworkResult<()>

Respond to a received message/request.

fn connected_peers(&self) -> Vec<PeerId>

Return connected peer IDs (excluding self).

fn is_dialing(&self, peer_id: &PeerId) -> bool

Return whether we have an in-flight dial to the given peer.

fn raw_stats(&self) -> RawStats

Return raw network stats.

fn bootstrap(&mut self) -> NetworkResult<()>

Bootstrap the network (DHT, relay, etc.).

fn dial_addrs(&self) -> Vec<Multiaddr>

Get currently known dialable addresses.

async fn next_event(&mut self) -> Option<NetworkEvent>

Return the next network event.