Enum NetworkCommand 

pub enum NetworkCommand {
    JoinNetwork {
        network_id: String,
    },
    LeaveNetwork {
        network_id: String,
    },
    Announce {
        network_id: String,
        payload: Vec<u8>,
    },
    AnnounceIndex {
        network_id: String,
        payload: Vec<u8>,
    },
    Dial {
        addr: Multiaddr,
    },
    PushFragment {
        peer_id: PeerId,
        chunk_id: String,
        fragment_id: String,
        data: Vec<u8>,
    },
    FetchChunkFragments {
        peer_id: PeerId,
        chunk_id: String,
        resp_tx: Sender<FragmentResponse>,
    },
    Shutdown,
    DialRelay {
        relay_addr: Multiaddr,
    },
    Ping {
        peer_id: PeerId,
        sent_at_ms: u64,
        resp_tx: Sender<u64>,
    },
    ProofOfStorage {
        peer_id: PeerId,
        chunk_id: String,
        fragment_id: String,
        nonce: u64,
        resp_tx: Sender<bool>,
    },
}

Commands the daemon can send to the network task over the [mpsc] channel.

The network loop runs inside a dedicated tokio::spawned task and receives these commands via the cmd_rx half of the channel created in run_daemon.

Variants

JoinNetwork

Subscribe to the gossipsub topic for network_id.

Fields

network_id: String

LeaveNetwork

Unsubscribe from the gossipsub topic for network_id.

Fields

network_id: String

Announce

Publish a serialised NodeInfo on the gossipsub topic for network_id.

Fields

network_id: String

Network whose topic to publish on.

payload: Vec<u8>

Serialised NodeInfo bytes.

AnnounceIndex

Publish a serialised FragmentIndexAnnouncement on the index gossip topic (billpouch/v1/{network_id}/index) for network_id.

Fields

network_id: String

Network whose index topic to publish on.

payload: Vec<u8>

Serialised FragmentIndexAnnouncement bytes.

Dial

Dial a remote peer at a known [Multiaddr].

Fields

addr: Multiaddr

PushFragment

Push a fragment to a remote Pouch peer for storage.

Fields

peer_id: PeerId

chunk_id: String

fragment_id: String

data: Vec<u8>

FetchChunkFragments

Fetch all fragments a remote Pouch holds for a given chunk. The response is sent back through the oneshot channel.

Fields

peer_id: PeerId

chunk_id: String

resp_tx: Sender<FragmentResponse>

Shutdown

Ask the network loop to exit cleanly.

DialRelay

Dial a relay node and create a circuit reservation.

After a successful reservation the node becomes reachable at /p2p-circuit addresses routed through the relay, enabling connectivity even when behind symmetric NAT.

Fields

relay_addr: Multiaddr

Ping

Ping a remote peer for RTT measurement.

The network loop sends a FragmentRequest::Ping, waits for the FragmentResponse::Pong, computes the RTT in milliseconds and forwards it to resp_tx. On timeout or failure the sender is dropped without sending.

Fields

peer_id: PeerId

sent_at_ms: u64

Monotonic timestamp (ms) at send time — used to compute RTT.

resp_tx: Sender<u64>

Receives rtt_ms when the Pong arrives.

ProofOfStorage

Issue a Proof-of-Storage challenge to a remote Pouch.

The network loop sends FragmentRequest::ProofOfStorage, awaits a FragmentResponse::ProofOfStorageOk, and delivers true (proof received) or false (no response / fragment not found) to resp_tx.

Fields

peer_id: PeerId

chunk_id: String

fragment_id: String

nonce: u64

resp_tx: Sender<bool>

Receives true if a proof was returned, false otherwise.

Trait Implementations

impl Debug for NetworkCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.