Jedrzej Stuczynski
34 lines
989 B
Rust
34 lines
989 B
Rust
use curve25519_dalek::digest::Digest;
|
|
use nym_client::utils::addressing;
|
|
use std::convert::TryInto;
|
|
use std::error::Error;
|
|
use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr};
|
|
use tokio::prelude::*;
|
|
|
|
#[derive(Debug)]
|
|
pub struct MixPeer {
|
|
connection: SocketAddr,
|
|
}
|
|
|
|
impl MixPeer {
|
|
// note that very soon `next_hop_address` will be changed to `next_hop_metadata`
|
|
pub fn new(next_hop_address: [u8; 32]) -> MixPeer {
|
|
let next_hop_socket_address =
|
|
addressing::socket_address_from_encoded_bytes(next_hop_address);
|
|
MixPeer {
|
|
connection: next_hop_socket_address,
|
|
}
|
|
}
|
|
|
|
pub async fn send(&self, bytes: Vec<u8>) -> Result<(), Box<dyn Error>> {
|
|
let next_hop_address = self.connection.clone();
|
|
let mut stream = tokio::net::TcpStream::connect(next_hop_address).await?;
|
|
stream.write_all(&bytes).await?;
|
|
Ok(())
|
|
}
|
|
|
|
pub fn to_string(&self) -> String {
|
|
self.connection.to_string()
|
|
}
|
|
}
|