kylefang/stacks-puppet-node
1
0
Fork 0
mirror of https://github.com/alexgo-io/stacks-puppet-node.git synced 2026-05-28 06:25:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add info logging to event observer endpoint config

Browse Source
This commit is contained in:
Matthew Little
2020-04-10 19:35:53 +02:00
parent 00d3c506b2
commit a27582732a
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/testnet/helium/event_dispatcher.rs
View File

@@ -26,6 +26,8 @@ impl EventObserver {
pub fn send(&mut self, filtered_events: Vec<&(Txid, &StacksTransactionEvent)>, chain_tip: &StacksBlock, chain_tip_info: &StacksHeaderInfo, receipts: &Vec<StacksTransactionReceipt>) {
// Initiate a tcp socket, first using std::net TCP connect for smart DNS resolution
let std_stream = std::net::TcpStream::connect(&self.endpoint).unwrap();
info!("Connected to event observer at: {}", std_stream.peer_addr().unwrap());
// Then wrap as mio TCP stream
let stream = TcpStream::from_stream(std_stream).unwrap();
// Serialize events to JSON
@@ -178,6 +180,7 @@ impl EventDispatcher {
pub fn register_observer(&mut self, conf: &EventObserverConfig) {
// let event_observer = EventObserver::new(&conf.address, conf.port);
info!("Registering event observer at: {}", conf.endpoint);
let event_observer = EventObserver { endpoint: conf.endpoint.clone() };
let observer_index = self.registered_observers.len() as u16;