Struct WebRTCManager 

pub struct WebRTCManager { /* private fields */ }

WebRTC manager handles peer discovery and connection management

Implementations

impl WebRTCManager

pub fn new(keys: Keys, config: WebRTCConfig) -> Self

Create a new WebRTC manager

pub fn new_with_classifier( keys: Keys, config: WebRTCConfig, classifier: PeerClassifier, ) -> Self

Create a new WebRTC manager with a peer classifier

pub fn new_with_store( keys: Keys, config: WebRTCConfig, store: Arc<dyn ContentStore>, ) -> Self

Create a new WebRTC manager with a content store for serving hash requests

pub fn new_with_store_and_classifier( keys: Keys, config: WebRTCConfig, store: Arc<dyn ContentStore>, classifier: PeerClassifier, ) -> Self

Create a new WebRTC manager with store and classifier

pub fn set_store(&mut self, store: Arc<dyn ContentStore>)

Set the content store for serving hash requests

pub fn set_peer_classifier(&mut self, classifier: PeerClassifier)

Set the peer classifier

pub fn set_nostr_relay(&mut self, relay: Arc<NostrRelay>)

Set the Nostr relay for data-channel relay messages

pub fn my_peer_id(&self) -> &PeerId

Get my peer ID

pub fn state(&self) -> Arc<WebRTCState>

Get shared state for external access

pub fn shutdown(&self)

Signal shutdown

pub async fn connected_count(&self) -> usize

Get connected peer count

pub async fn peer_statuses(&self) -> Vec<PeerStatus>

Get all peer statuses

pub async fn get_pool_counts(&self) -> (usize, usize, usize, usize)

Get pool counts Returns (follows_connected, follows_active, other_connected, other_active) “active” = Connected or Connecting (excludes Discovered and Failed)

pub async fn run(&mut self) -> Result<()>

Start the WebRTC manager - connects to relays and handles signaling