Struct Libp2pSyncTransport 

pub struct Libp2pSyncTransport { /* private fields */ }

A libp2p SyncTransport (native) — a noise-encrypted request-response pipe to a single peer or relay. It wraps the core-db BlockingSyncClient: each SyncOperation is serialized to a CBOR op frame on publish and decoded back on pull, so the wire carries only opaque signed-op bytes. A dumb pipe like the in-memory and HTTP backends — it never validates or trusts. Undecodable inbound frames are skipped (they could never be admitted anyway; the fail-closed inbox is the trust boundary), so a hostile peer injecting junk cannot break sync for well-formed operations.

Implementations

impl Libp2pSyncTransport

pub fn connect(peer_id: &str, peer_addr: &str) -> Result<Self, String>

Connect to peer_addr (a libp2p multiaddr, e.g. /ip4/1.2.3.4/tcp/4001) identified by peer_id (base58). The connection is established lazily on the first publish/pull.

pub fn local_peer_id(&self) -> String

This node’s own libp2p peer id (base58) — so a peer can be told how to reach us back.

Trait Implementations

impl SyncTransport for Libp2pSyncTransport

Available on non-WebAssembly only.

fn publish(&self, ops: &[SyncOperation]) -> Result<(), String>

Publish local operations to the relay/peer. Must be idempotent at the relay (dedup by operation id), so re-publishing a queued op is harmless.

fn pull(&self, since: u64) -> Result<Vec<SyncOperation>, String>

Pull operations the relay holds after cursor since (0 = from the start). Returns them in relay order. Re-pulling is safe: the inbox dedups by operation id on admission.