use std::time::{Duration, Instant};
use std::io::{BufRead, BufReader};
-use bitcoin::network::address::Address;
+use bitcoin::network::address::{Address, AddrV2Message};
use rand::thread_rng;
use rand::seq::{SliceRandom, IteratorRandom};
}
}));
}
+ pub fn add_fresh_nodes_v2(&self, addresses: &Vec<AddrV2Message>) {
+ self.add_fresh_addrs(addresses.iter().filter_map(|addr| {
+ match addr.socket_addr() {
+ Ok(socketaddr) => Some(socketaddr),
+ Err(_) => None, // TODO: Handle onions
+ }
+ }));
+ }
pub fn set_node_state(&self, sockaddr: SocketAddr, state: AddressState, services: u64) -> AddressState {
let addr: SockAddr = sockaddr.into();