Sulkta-OSS/pallas
3
0
Fork 0
Code Issues 1 Pull requests 4 Projects Releases Packages Wiki Activity Actions

Add first-pass chain-sync implementation

Browse source
This commit is contained in:
Santiago Carmuega 2021-11-21 12:05:33 -03:00
parent 4cdddd331b
commit d6848b4e72
6 changed files with 418 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

37
pallas-chainsync/examples/blocks.rs Normal file
View file

@ -0,0 +1,37 @@
use net2::TcpStreamExt;
use std::net::TcpStream;
use pallas_chainsync::{Consumer, Point};
use pallas_handshake::n2c::{Client, VersionTable};
use pallas_handshake::MAINNET_MAGIC;
use pallas_machines::run_agent;
use pallas_multiplexer::Multiplexer;
fn main() {
env_logger::init();
//let bearer = TcpStream::connect("localhost:6000").unwrap();
let bearer = TcpStream::connect("relays-new.cardano-mainnet.iohk.io:3001").unwrap();
bearer.set_nodelay(true).unwrap();
bearer.set_keepalive_ms(Some(30_000u32)).unwrap();
let mut handles = Multiplexer::new(bearer, &vec![0, 5]).unwrap();
let (_, rx, tx) = handles.remove(0);
let versions = VersionTable::v1_and_above(MAINNET_MAGIC);
let last = run_agent(Client::initial(versions), rx, &tx).unwrap();
println!("{:?}", last);
let known_points = vec![Point(
43847831u64,
hex::decode("15b9eeee849dd6386d3770b0745e0450190f7560e5159b1b3ab13b14b2684a45").unwrap(),
)];
let (_, cs_rx, cs_tx) = handles.remove(0);
let cs = Consumer::initial(known_points);
let cs = run_agent(cs, cs_rx, &cs_tx).unwrap();
println!("{:?}", cs);
}

37
pallas-chainsync/examples/headers.rs Normal file
View file

@ -0,0 +1,37 @@
use net2::TcpStreamExt;
use std::net::TcpStream;
use pallas_chainsync::{Consumer, Point};
use pallas_handshake::n2n::{Client, VersionTable};
use pallas_handshake::MAINNET_MAGIC;
use pallas_machines::run_agent;
use pallas_multiplexer::Multiplexer;
fn main() {
env_logger::init();
//let bearer = TcpStream::connect("localhost:6000").unwrap();
let bearer = TcpStream::connect("relays-new.cardano-mainnet.iohk.io:3001").unwrap();
bearer.set_nodelay(true).unwrap();
bearer.set_keepalive_ms(Some(30_000u32)).unwrap();
let mut handles = Multiplexer::new(bearer, &vec![0, 2]).unwrap();
let (_, rx, tx) = handles.remove(0);
let versions = VersionTable::v4_and_above(MAINNET_MAGIC);
let last = run_agent(Client::initial(versions), rx, &tx).unwrap();
println!("{:?}", last);
let known_points = vec![Point(
43847831u64,
hex::decode("15b9eeee849dd6386d3770b0745e0450190f7560e5159b1b3ab13b14b2684a45").unwrap(),
)];
let (_, cs_rx, cs_tx) = handles.remove(0);
let cs = Consumer::initial(known_points);
let cs = run_agent(cs, cs_rx, &cs_tx).unwrap();
println!("{:?}", cs);
}