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

Fix chain sync examples

Browse source
This commit is contained in:
Santiago Carmuega 2021-11-22 18:05:38 -03:00
parent e2865abcec
commit 6996027741
2 changed files with 4 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

21
pallas-chainsync/examples/blocks.rs
View file

@ -1,36 +1,23 @@
use net2::TcpStreamExt;
use pallas_txsubmission::NaiveProvider;
use std::net::TcpStream;
use std::thread;
use std::time::Duration;
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;
use std::os::unix::net::UnixStream;
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 bearer = UnixStream::connect("/tmp/node.socket").unwrap();
let mut muxer = Multiplexer::try_setup(bearer, &vec![0, 4, 5]).unwrap();
let (rx, tx) = muxer.use_channel(0);
let versions = VersionTable::v1_and_above(MAINNET_MAGIC);
let last = run_agent(Client::initial(versions), rx, &tx).unwrap();
println!("last hanshake state: {:?}", last);
let (ts_rx, ts_tx) = muxer.use_channel(4);
let ts = NaiveProvider::initial(vec![]);
let ts = run_agent(ts, ts_rx, &ts_tx).unwrap();
println!("last tx-submission state: {:?}", ts);
// some random known-point in the chain to use as starting point for the sync
let known_points = vec![Point(
43847831u64,
hex::decode("15b9eeee849dd6386d3770b0745e0450190f7560e5159b1b3ab13b14b2684a45").unwrap(),

1
pallas-chainsync/examples/headers.rs
View file

@ -10,7 +10,6 @@ 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();