Struct GossipModelSync 

pub struct GossipModelSync { /* private fields */ }

GossipSub-based model synchronisation protocol.

Broadcasts ModelUpdate announcements via a shared in-process channel so that tests can exercise the full send/receive/verify loop without a live libp2p swarm.

Implementations

impl GossipModelSync

pub fn new(local_peer_id: impl Into<String>) -> Self

Create a new GossipModelSync backed by a broadcast channel of capacity 64.

pub fn subscribe(&self, peer_id: impl Into<String>) -> Self

Create a second endpoint subscribed to the same broadcast channel (for tests).

pub async fn broadcast_update( &self, model_cid: &str, round_id: u32, ) -> Result<()>

Broadcast a local model-update CID to all mesh peers.

pub async fn collect_updates( &mut self, expected_peers: usize, timeout_ms: u64, ) -> Result<Vec<ModelUpdate>>

Collect model-update CIDs from peers for up to timeout_ms milliseconds.

Returns as soon as expected_peers distinct peer updates are received or the timeout expires.

pub fn verify_update(&self, update: &ModelUpdate) -> bool

Verify that a ModelUpdate has not been tampered with.

The current implementation checks that model_cid is a non-empty, valid CIDv1 or CIDv0 string and that peer_id is non-empty. Tampered updates with an empty or whitespace-only CID fail verification.