Module peer 

Node connection and message handling

Examples

Send and receive a message to a node syncronously:

use bch::messages::{Message, Ping, Version, NODE_BITCOIN_CASH, PROTOCOL_VERSION};
use bch::network::Network;
use bch::peer::Peer;
use bch::util::rx::Observable;
use bch::util::secs_since;
use std::time::UNIX_EPOCH;

let (ip, port) = Network::Mainnet.seed_iter().next().unwrap();
let version = Version {
    version: PROTOCOL_VERSION,
    services: NODE_BITCOIN_CASH,
    timestamp: secs_since(UNIX_EPOCH) as i64,
    user_agent: "rust-bch".to_string(),
    ..Default::default()
};

let peer = Peer::connect(ip, port, Network::Mainnet, version, |_| true);
peer.connected_event().poll();

let ping = Message::Ping(Ping { nonce: 0 });
peer.send(&ping).unwrap();

let response = peer.messages().poll();

Handle node events asynronously:

use bch::messages::{Version, NODE_BITCOIN_CASH, PROTOCOL_VERSION};
use bch::network::Network;
use bch::peer::{Peer, PeerConnected, PeerDisconnected, PeerMessage};
use bch::util::rx::{Observable, Observer};
use bch::util::secs_since;
use std::sync::Arc;
use std::time::UNIX_EPOCH;

let (ip, port) = Network::Mainnet.seed_iter().next().unwrap();
let version = Version {
    version: PROTOCOL_VERSION,
    services: NODE_BITCOIN_CASH,
    timestamp: secs_since(UNIX_EPOCH) as i64,
    user_agent: "rust-bch".to_string(),
    ..Default::default()
};

let peer = Peer::connect(ip, port, Network::Mainnet, version, |_| true);

struct EventHandler {}

impl Observer<PeerConnected> for EventHandler {
    fn next(&self, event: &PeerConnected) {
        // Handle node connected
    }
}

impl Observer<PeerDisconnected> for EventHandler {
    fn next(&self, event: &PeerDisconnected) {
        // Handle node disconnected
    }
}

impl Observer<PeerMessage> for EventHandler {
    fn next(&self, event: &PeerMessage) {
        // Handle message from node
    }
}

let event_handler = Arc::new(EventHandler {});

peer.connected_event().subscribe(&event_handler);
peer.disconnected_event().subscribe(&event_handler);
peer.messages().subscribe(&event_handler);

Structs

Peer

Node on the network to send and receive messages

PeerConnected

Event emitted when a connection is established with the peer

PeerDisconnected

Event emitted when the connection with the peer is terminated

PeerMessage

Event emitted when the peer receives a network message