Compare commits
9 Commits
address_fe
...
cb2e89b1e9
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
cb2e89b1e9 | ||
|
|
524eaec76d | ||
|
|
34a9db047d | ||
|
|
fe04c8ed27 | ||
|
|
1f41ba5261 | ||
|
|
7eb1ab119d | ||
|
|
0799841cf2 | ||
|
|
424c11c5aa | ||
|
|
271fdbbb4c |
@@ -4,8 +4,9 @@ use client_network::{
|
||||
};
|
||||
use crossbeam_channel::{Receiver, Sender};
|
||||
use egui::{
|
||||
Align, Align2, Button, CentralPanel, CollapsingHeader, Context, Id, LayerId, Layout, Order,
|
||||
Popup, ScrollArea, SidePanel, TextStyle, TopBottomPanel, Ui, ViewportCommand,
|
||||
Align, Align2, Button, CentralPanel, CollapsingHeader, Color32, Context, CornerRadius, Frame,
|
||||
Id, LayerId, Layout, Order, Popup, Response, ScrollArea, SidePanel, Stroke, TextStyle,
|
||||
TopBottomPanel, Ui, ViewportCommand,
|
||||
};
|
||||
use std::{collections::HashMap, fmt::format};
|
||||
|
||||
@@ -43,6 +44,7 @@ pub struct P2PClientApp {
|
||||
show_network_popup: bool, // gérer selon besoin
|
||||
|
||||
error_message: Option<String>, // Some(message) -> afficher, None -> rien
|
||||
success_message: Option<String>, // Some(message) -> afficher, None -> rien
|
||||
//
|
||||
active_server: String,
|
||||
}
|
||||
@@ -62,7 +64,7 @@ impl P2PClientApp {
|
||||
network_cmd_tx: cmd_tx,
|
||||
network_event_rx: event_rx,
|
||||
status_message: "Client Initialized. Awaiting network status...".to_string(),
|
||||
known_peers: vec![("bob".to_string(), true)],
|
||||
known_peers: Vec::new(),
|
||||
connect_address_input: "https://jch.irif.fr:8443".to_string(),
|
||||
connected_address: "".to_string(),
|
||||
loaded_fs,
|
||||
@@ -70,6 +72,7 @@ impl P2PClientApp {
|
||||
server_status: ServerStatus::NotConnected,
|
||||
show_network_popup: false,
|
||||
error_message: None,
|
||||
success_message: None,
|
||||
connect_name_input: "bob".to_string(),
|
||||
active_server: "".to_string(),
|
||||
}
|
||||
@@ -77,9 +80,15 @@ impl P2PClientApp {
|
||||
pub fn show_error(&mut self, msg: impl Into<String>) {
|
||||
self.error_message = Some(msg.into());
|
||||
}
|
||||
pub fn show_success(&mut self, msg: impl Into<String>) {
|
||||
self.success_message = Some(msg.into());
|
||||
}
|
||||
pub fn clear_error(&mut self) {
|
||||
self.error_message = None;
|
||||
}
|
||||
pub fn clear_success(&mut self) {
|
||||
self.success_message = None;
|
||||
}
|
||||
}
|
||||
|
||||
// --- eframe::App Trait Implementation ---
|
||||
@@ -175,6 +184,9 @@ impl eframe::App for P2PClientApp {
|
||||
NetworkEvent::Error(err) => {
|
||||
self.show_error(err);
|
||||
}
|
||||
NetworkEvent::Success(msg) => {
|
||||
self.show_success(msg);
|
||||
}
|
||||
NetworkEvent::DataReceived(_, merkle_node) => todo!(),
|
||||
NetworkEvent::HandshakeFailed() => {}
|
||||
NetworkEvent::ServerHandshakeFailed(err) => {
|
||||
@@ -360,13 +372,24 @@ impl eframe::App for P2PClientApp {
|
||||
let is_active =
|
||||
self.active_peer.as_ref().map_or(false, |id| id == &peer.0); // if peer.id == self.active_peer_id
|
||||
|
||||
let selectable;
|
||||
let selectable: Response;
|
||||
if &self.active_server == &peer.0 {
|
||||
selectable =
|
||||
ui.selectable_label(is_active, format!("{} 📡 🌀", peer.0))
|
||||
// Create a frame with green background and render the selectable inside it.
|
||||
// Adjust rounding, padding and stroke as desired.
|
||||
let frame = Frame {
|
||||
fill: Color32::DARK_BLUE,
|
||||
stroke: Stroke::default(),
|
||||
corner_radius: CornerRadius::from(0.5),
|
||||
..Default::default()
|
||||
};
|
||||
let internal = frame.show(ui, |ui| {
|
||||
ui.selectable_label(is_active, format!("{}", peer.0))
|
||||
});
|
||||
selectable = internal.response;
|
||||
} else {
|
||||
selectable = ui.selectable_label(is_active, format!("{}", peer.0));
|
||||
}
|
||||
|
||||
if selectable.clicked() {
|
||||
// switch to displaying this peer's tree
|
||||
self.active_peer = Some(peer.0.clone());
|
||||
@@ -476,6 +499,20 @@ impl eframe::App for P2PClientApp {
|
||||
});
|
||||
ctx.request_repaint();
|
||||
}
|
||||
if let Some(msg) = &self.success_message {
|
||||
let msg = msg.clone();
|
||||
egui::Window::new("Success")
|
||||
.collapsible(false)
|
||||
.resizable(false)
|
||||
.anchor(egui::Align2::CENTER_CENTER, [0.0, 0.0])
|
||||
.show(ctx, |ui| {
|
||||
ui.label(&msg);
|
||||
if ui.button("OK").clicked() {
|
||||
self.clear_success();
|
||||
}
|
||||
});
|
||||
ctx.request_repaint();
|
||||
}
|
||||
|
||||
ctx.request_repaint_after(std::time::Duration::from_millis(10));
|
||||
}
|
||||
|
||||
26
client-network/src/fetchsocketaddresserror.rs
Normal file
26
client-network/src/fetchsocketaddresserror.rs
Normal file
@@ -0,0 +1,26 @@
|
||||
use std::fmt;
|
||||
|
||||
#[derive(Debug)]
|
||||
pub enum FetchSocketAddressError {
|
||||
NoIPV4Address,
|
||||
NoRegisteredAddresses,
|
||||
NoResponseFromUser,
|
||||
ClientError(String),
|
||||
}
|
||||
|
||||
impl fmt::Display for FetchSocketAddressError {
|
||||
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
||||
match self {
|
||||
FetchSocketAddressError::NoIPV4Address => write!(f, "No IPv4 Address registered."),
|
||||
FetchSocketAddressError::NoRegisteredAddresses => {
|
||||
write!(f, "No Registered Addresses found.")
|
||||
}
|
||||
FetchSocketAddressError::NoResponseFromUser => {
|
||||
write!(f, "No Response from user after contact.")
|
||||
}
|
||||
FetchSocketAddressError::ClientError(error) => {
|
||||
write!(f, "Client error : {}", error)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -2,6 +2,7 @@ mod cryptographic_signature;
|
||||
mod data;
|
||||
mod datum_generation;
|
||||
mod datum_parsing;
|
||||
mod fetchsocketaddresserror;
|
||||
mod message_handling;
|
||||
mod messages_channels;
|
||||
mod messages_structure;
|
||||
@@ -9,22 +10,22 @@ mod peers_refresh;
|
||||
mod registration;
|
||||
mod server_communication;
|
||||
mod threads_handling;
|
||||
mod timestamp;
|
||||
|
||||
use crate::fetchsocketaddresserror::FetchSocketAddressError;
|
||||
use crate::peers_refresh::*;
|
||||
use crate::timestamp::Timestamp;
|
||||
use crate::{
|
||||
cryptographic_signature::CryptographicSignature,
|
||||
message_handling::EventType,
|
||||
messages_channels::{MultipleSenders, start_receving_thread, start_retry_thread},
|
||||
messages_structure::{
|
||||
NATTRAVERSALREQUEST, NATTRAVERSALREQUEST2, PING, ROOTREQUEST, construct_message,
|
||||
},
|
||||
messages_structure::{NATTRAVERSALREQUEST, PING, ROOTREQUEST, construct_message},
|
||||
peers_refresh::HandshakeHistory,
|
||||
registration::{parse_addresses, perform_handshake, register_with_the_server},
|
||||
server_communication::{generate_id, get_peer_list},
|
||||
threads_handling::Worker,
|
||||
};
|
||||
use std::{
|
||||
clone,
|
||||
io::Error,
|
||||
net::{IpAddr, Ipv4Addr, UdpSocket},
|
||||
time::Duration,
|
||||
@@ -38,15 +39,17 @@ pub struct P2PSharedData {
|
||||
shared_socket: Arc<UdpSocket>,
|
||||
shared_cryptopair: Arc<CryptographicSignature>,
|
||||
shared_messageslist: Arc<Mutex<HashMap<i32, EventType>>>,
|
||||
shared_messagesreceived: Arc<Mutex<HashMap<String, (EventType, Timestamp)>>>,
|
||||
shared_senders: Arc<MultipleSenders>,
|
||||
server_name: Arc<Mutex<String>>,
|
||||
server_address: Arc<Mutex<String>>,
|
||||
handshake_peers: Arc<HandshakeHistory>,
|
||||
threads: Vec<Worker>,
|
||||
}
|
||||
|
||||
use bytes::Bytes;
|
||||
use p256::pkcs8::der::pem::Base64Encoder;
|
||||
use reqwest::Client;
|
||||
use tokio::time::sleep;
|
||||
|
||||
impl P2PSharedData {
|
||||
pub fn new(
|
||||
@@ -54,26 +57,31 @@ impl P2PSharedData {
|
||||
cmd_tx: crossbeam_channel::Sender<NetworkEvent>,
|
||||
) -> Result<P2PSharedData, Error> {
|
||||
let messages_list = HashMap::<i32, EventType>::new();
|
||||
let messagesrecv_list = HashMap::<String, (EventType, Timestamp)>::new();
|
||||
let username = String::from(username);
|
||||
let crypto_pair = CryptographicSignature::new(username);
|
||||
let socket = UdpSocket::bind("0.0.0.0:0")?;
|
||||
let shared_socket = Arc::new(socket);
|
||||
let shared_cryptopair = Arc::new(crypto_pair);
|
||||
let shared_messageslist = Arc::new(Mutex::new(messages_list));
|
||||
let shared_messagesreceived = Arc::new(Mutex::new(messagesrecv_list));
|
||||
|
||||
let mut threads = Vec::new();
|
||||
|
||||
let senders = MultipleSenders::new(1, &shared_socket, cmd_tx, &mut threads);
|
||||
let shared_senders = Arc::new(senders);
|
||||
let server_name = Arc::new(Mutex::new("".to_string()));
|
||||
let server_address = Arc::new(Mutex::new("".to_string()));
|
||||
let handhsake_peers = Arc::new(HandshakeHistory::new());
|
||||
|
||||
Ok(P2PSharedData {
|
||||
shared_socket: shared_socket,
|
||||
shared_cryptopair: shared_cryptopair,
|
||||
shared_messageslist: shared_messageslist,
|
||||
shared_messagesreceived: shared_messagesreceived,
|
||||
shared_senders: shared_senders,
|
||||
server_name: server_name,
|
||||
server_address: server_address,
|
||||
handshake_peers: handhsake_peers,
|
||||
threads,
|
||||
})
|
||||
@@ -88,14 +96,31 @@ impl P2PSharedData {
|
||||
pub fn messages_list(&self) -> Arc<Mutex<HashMap<i32, EventType>>> {
|
||||
self.shared_messageslist.clone()
|
||||
}
|
||||
pub fn messages_received(&self) -> Arc<Mutex<HashMap<String, (EventType, Timestamp)>>> {
|
||||
self.shared_messagesreceived.clone()
|
||||
}
|
||||
pub fn servername(&self) -> String {
|
||||
let guard = self.server_name.lock().unwrap();
|
||||
let guard = {
|
||||
let maybe_sn = self.server_name.lock().unwrap();
|
||||
maybe_sn.clone()
|
||||
};
|
||||
guard.to_string()
|
||||
}
|
||||
pub fn serveraddress(&self) -> String {
|
||||
let guard = {
|
||||
let maybe_sn = self.server_address.lock().unwrap();
|
||||
maybe_sn.clone()
|
||||
};
|
||||
guard.to_string()
|
||||
}
|
||||
pub fn set_servername(&self, new: String) {
|
||||
let mut guard = self.server_name.lock().unwrap();
|
||||
*guard = new
|
||||
}
|
||||
pub fn set_serveraddress(&self, new: String) {
|
||||
let mut guard = self.server_address.lock().unwrap();
|
||||
*guard = new
|
||||
}
|
||||
pub fn senders(&self) -> Arc<MultipleSenders> {
|
||||
self.shared_senders.clone()
|
||||
}
|
||||
@@ -113,6 +138,10 @@ impl P2PSharedData {
|
||||
&*self.shared_messageslist
|
||||
}
|
||||
|
||||
pub fn messages_received_ref(&self) -> &Mutex<HashMap<String, (EventType, Timestamp)>> {
|
||||
&*self.shared_messagesreceived
|
||||
}
|
||||
|
||||
pub fn senders_ref(&self) -> &MultipleSenders {
|
||||
&*self.shared_senders
|
||||
}
|
||||
@@ -157,6 +186,7 @@ pub enum NetworkEvent {
|
||||
ConnectedHandshake(),
|
||||
Disconnected(),
|
||||
Error(String),
|
||||
Success(String),
|
||||
PeerConnected(String),
|
||||
PeerListUpdated(Vec<(String, bool)>),
|
||||
FileTreeReceived([u8; 32], MerkleNode), // peer_id, content
|
||||
@@ -218,7 +248,7 @@ pub fn start_p2p_executor(
|
||||
sd.senders(),
|
||||
sd.cryptopair(),
|
||||
sd.messages_list(),
|
||||
sd.handshake_peers.username_k_peerinfo_v.clone(),
|
||||
sd.handshake_peers.get_username_peerinfo_map(),
|
||||
);
|
||||
|
||||
let res =
|
||||
@@ -338,6 +368,7 @@ pub fn start_p2p_executor(
|
||||
}*/
|
||||
}
|
||||
NetworkCommand::FetchPeerList(ip) => {
|
||||
println!("[Network] FetchPeerList() called");
|
||||
if ip == "" {
|
||||
let res = event_tx.send(NetworkEvent::Error(
|
||||
"Not registered to any server".to_string(),
|
||||
@@ -367,48 +398,65 @@ pub fn start_p2p_executor(
|
||||
Err(e) => println!("error"),
|
||||
}
|
||||
}
|
||||
println!("[Network] FetchPeerList() called");
|
||||
}
|
||||
NetworkCommand::RegisterAsPeer(_) => {
|
||||
println!("[Network] RegisterAsPeer() called");
|
||||
}
|
||||
NetworkCommand::Ping(str, ip) => {
|
||||
println!("[Network] Ping({}) called", str);
|
||||
if let Some(sd) = shared_data.as_ref() {
|
||||
let id = generate_id();
|
||||
sd.add_message(id, EventType::Ping);
|
||||
let pingrequest =
|
||||
construct_message(PING, Vec::new(), id, sd.cryptopair_ref());
|
||||
let peer_address = get_socket_address(str, ip).await;
|
||||
let peer_address =
|
||||
get_socket_address(str, ip, shared_data.as_ref()).await;
|
||||
match peer_address {
|
||||
Some(addr) => {
|
||||
if let Some(ping) = pingrequest {
|
||||
sd.senders_ref().add_message_to_retry_queue(
|
||||
ping.clone(),
|
||||
addr.to_string(),
|
||||
false,
|
||||
);
|
||||
sd.senders_ref().send_dispatch(
|
||||
ping,
|
||||
addr.to_string(),
|
||||
false,
|
||||
sd.messages_list(),
|
||||
);
|
||||
}
|
||||
Ok(addr) => {
|
||||
//if let Some(ping) = pingrequest {
|
||||
// sd.senders_ref().add_message_to_retry_queue(
|
||||
// ping.clone(),
|
||||
// addr.to_string(),
|
||||
// false,
|
||||
// );
|
||||
// sd.senders_ref().send_dispatch(
|
||||
// ping,
|
||||
// addr.to_string(),
|
||||
// false,
|
||||
// sd.messages_list(),
|
||||
// );
|
||||
//}
|
||||
match event_tx.send(NetworkEvent::Success(format!(
|
||||
"Successfully sent ping message to {}.",
|
||||
addr.to_string()
|
||||
))) {
|
||||
Ok(_) => {}
|
||||
Err(e) => {
|
||||
eprintln!("NetworkEvent error : {}", e);
|
||||
}
|
||||
};
|
||||
}
|
||||
None => {
|
||||
let err_msg =
|
||||
format!("failed to retreive socket address:").to_string();
|
||||
let res = event_tx.send(NetworkEvent::Error(err_msg));
|
||||
Err(err_msg) => {
|
||||
match event_tx.send(NetworkEvent::Error(err_msg.to_string())) {
|
||||
Ok(_) => {}
|
||||
Err(e) => {
|
||||
eprintln!("NetworkEvent error : {}", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
println!("[Network] Ping() called");
|
||||
}
|
||||
NetworkCommand::Disconnect() => {
|
||||
if let Some(sd) = shared_data.as_ref() {
|
||||
println!("Disconnecting: {}", &sd.cryptopair().username);
|
||||
shared_data = None;
|
||||
let res = event_tx.send(NetworkEvent::Disconnected());
|
||||
match event_tx.send(NetworkEvent::Disconnected()) {
|
||||
Ok(_) => {}
|
||||
Err(e) => {
|
||||
eprintln!("NetworkEvent error : {}", e);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
println!("no p2p data");
|
||||
}
|
||||
@@ -424,45 +472,44 @@ pub fn start_p2p_executor(
|
||||
if let Some(sd) = shared_data.as_ref() {
|
||||
println!("username:{}, ip:{}", username, ip);
|
||||
// user server to send nattraversal request
|
||||
let server_addr_query =
|
||||
get_socket_address(sd.servername().clone(), ip.clone());
|
||||
let peer_addr_query = get_socket_address(username.clone(), ip.clone());
|
||||
let server_addr = sd.serveraddress();
|
||||
let peer_addr_query = get_socket_address(
|
||||
username.clone(),
|
||||
ip.clone(),
|
||||
shared_data.as_ref(),
|
||||
);
|
||||
|
||||
match server_addr_query.await {
|
||||
Some(server_addr) => match peer_addr_query.await {
|
||||
Some(peer_addr) => {
|
||||
let payload = socket_addr_to_vec(server_addr);
|
||||
match peer_addr_query.await {
|
||||
Ok(peer_addr) => {
|
||||
let payload = socket_addr_to_vec(peer_addr);
|
||||
|
||||
print!("{:?}", payload.clone());
|
||||
print!("{:?}", payload.clone());
|
||||
|
||||
let id = generate_id();
|
||||
let natreq = construct_message(
|
||||
NATTRAVERSALREQUEST,
|
||||
payload.clone(),
|
||||
id.clone(),
|
||||
&sd.cryptopair(),
|
||||
);
|
||||
let id = generate_id();
|
||||
let natreq = construct_message(
|
||||
NATTRAVERSALREQUEST,
|
||||
payload.clone(),
|
||||
id.clone(),
|
||||
&sd.cryptopair(),
|
||||
);
|
||||
|
||||
sd.add_message(id, EventType::NatTraversal);
|
||||
sd.senders_ref().send_dispatch(
|
||||
natreq.expect(
|
||||
"couldnt construct message nattraversalrequest2",
|
||||
),
|
||||
server_addr.to_string(),
|
||||
false,
|
||||
sd.messages_list(),
|
||||
);
|
||||
sd.add_message(id, EventType::NatTraversal);
|
||||
sd.senders_ref().send_dispatch(
|
||||
natreq.expect(
|
||||
"couldnt construct message nattraversalrequest2",
|
||||
),
|
||||
server_addr.to_string(),
|
||||
false,
|
||||
sd.messages_list(),
|
||||
);
|
||||
}
|
||||
Err(err_msg) => {
|
||||
match event_tx.send(NetworkEvent::Error(err_msg.to_string())) {
|
||||
Ok(_) => {}
|
||||
Err(e) => {
|
||||
eprintln!("NetworkEvent error : {}", e);
|
||||
}
|
||||
}
|
||||
None => {
|
||||
let err_msg = format!("failed to retreive socket address")
|
||||
.to_string();
|
||||
let res = event_tx.send(NetworkEvent::Error(err_msg));
|
||||
}
|
||||
},
|
||||
None => {
|
||||
let err_msg =
|
||||
format!("failed to retreive socket address").to_string();
|
||||
let res = event_tx.send(NetworkEvent::Error(err_msg));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -476,7 +523,7 @@ pub fn start_p2p_executor(
|
||||
// event_tx.send(NetworkEvent::PeerConnected("NewPeerID".to_string())).unwrap();
|
||||
|
||||
// Avoid spinning too fast
|
||||
tokio::time::sleep(std::time::Duration::from_millis(50)).await;
|
||||
sleep(std::time::Duration::from_millis(50)).await;
|
||||
}
|
||||
})
|
||||
}
|
||||
@@ -506,11 +553,126 @@ fn parse_pack(s: &str) -> Option<[u8; 6]> {
|
||||
])
|
||||
}
|
||||
|
||||
async fn quick_ping(addr: &SocketAddr, timeout_ms: u64, sd: &P2PSharedData) -> bool {
|
||||
let id = generate_id();
|
||||
let pingreq = construct_message(PING, Vec::new(), id, &sd.shared_cryptopair);
|
||||
|
||||
if let Some(ping) = pingreq {
|
||||
sd.add_message(id, EventType::Ping);
|
||||
sd.senders_ref()
|
||||
.send_dispatch(ping, addr.to_string(), false, sd.messages_list());
|
||||
}
|
||||
|
||||
sleep(Duration::from_millis(timeout_ms)).await;
|
||||
|
||||
let msg_list = sd.messages_list_ref().lock().expect("yooo");
|
||||
let res = !msg_list.contains_key(&id);
|
||||
|
||||
for (id, evt) in msg_list.iter() {
|
||||
println!("id : {}, evt : {}", id, evt.to_string());
|
||||
}
|
||||
println!("message list doesnt contain key? {}", res);
|
||||
|
||||
res
|
||||
}
|
||||
|
||||
///
|
||||
/// sends a get request to the server to get the socket address of the given peer
|
||||
///
|
||||
|
||||
pub async fn get_socket_address(username: String, ip: String) -> Option<SocketAddr> {
|
||||
pub async fn get_socket_address(
|
||||
username: String,
|
||||
ip: String,
|
||||
shared_data: Option<&P2PSharedData>,
|
||||
) -> Result<SocketAddr, FetchSocketAddressError> {
|
||||
let sd = shared_data.expect("No shared data");
|
||||
|
||||
let client = match Client::builder().timeout(Duration::from_secs(5)).build() {
|
||||
Ok(c) => c,
|
||||
Err(e) => {
|
||||
return Err(FetchSocketAddressError::ClientError(e.to_string()));
|
||||
}
|
||||
};
|
||||
|
||||
let uri = format!("{}/peers/{}/addresses", ip, username);
|
||||
let res = match client.get(&uri).send().await {
|
||||
Ok(r) => r,
|
||||
Err(e) => return Err(FetchSocketAddressError::ClientError(e.to_string())),
|
||||
};
|
||||
|
||||
if res.status().is_success() {
|
||||
println!("Successfully retrieved the addresses. {}", res.status());
|
||||
} else {
|
||||
eprintln!(
|
||||
"Failed to get the peers addresses from the server. Status: {}",
|
||||
res.status()
|
||||
);
|
||||
}
|
||||
|
||||
let body = match res.bytes().await {
|
||||
Ok(b) => b,
|
||||
Err(e) => {
|
||||
return Err(FetchSocketAddressError::ClientError(e.to_string()));
|
||||
}
|
||||
};
|
||||
|
||||
let s = match String::from_utf8(body.to_vec()) {
|
||||
Ok(st) => st,
|
||||
Err(e) => {
|
||||
return Err(FetchSocketAddressError::ClientError(e.to_string()));
|
||||
}
|
||||
};
|
||||
|
||||
let addresses = parse_addresses(&s); // assumes parse_addresses: &str -> Vec<SocketAddr>
|
||||
if addresses.is_empty() {
|
||||
return Err(FetchSocketAddressError::NoRegisteredAddresses);
|
||||
} else if !addresses.iter().any(|a| matches!(a, SocketAddr::V4(_))) {
|
||||
return Err(FetchSocketAddressError::NoIPV4Address);
|
||||
}
|
||||
|
||||
for addr in addresses {
|
||||
println!("trying address : {}", addr);
|
||||
if quick_ping(&addr, 5000, sd).await {
|
||||
return Ok(addr);
|
||||
}
|
||||
|
||||
let payload = socket_addr_to_vec(addr);
|
||||
let id = generate_id();
|
||||
|
||||
let natreq = construct_message(NATTRAVERSALREQUEST, payload.clone(), id, &sd.cryptopair());
|
||||
|
||||
sd.add_message(id, EventType::NatTraversal);
|
||||
sd.senders_ref().send_dispatch(
|
||||
natreq.expect("couldnt construct message nattraversalrequest2"),
|
||||
sd.serveraddress().to_string(),
|
||||
false,
|
||||
sd.messages_list(),
|
||||
);
|
||||
|
||||
sleep(Duration::from_millis(5000)).await;
|
||||
|
||||
let maybe_entry = {
|
||||
let guard = sd.messages_received_ref().lock().unwrap();
|
||||
guard.clone()
|
||||
}; // guard dropped
|
||||
|
||||
for (id, (evt, time)) in maybe_entry.iter() {
|
||||
println!("{} : {} at {}", id, evt.to_string(), time.to_string());
|
||||
if id.eq(&addr.to_string()) && Timestamp::now().diff(time) < 10 {
|
||||
println!("received message from address, returning said address..");
|
||||
return Ok(addr);
|
||||
}
|
||||
}
|
||||
|
||||
if quick_ping(&addr, 15000, sd).await {
|
||||
return Ok(addr);
|
||||
}
|
||||
}
|
||||
|
||||
Err(FetchSocketAddressError::NoResponseFromUser)
|
||||
}
|
||||
|
||||
pub async fn get_server_address(username: String, ip: String) -> Option<SocketAddr> {
|
||||
let client = Client::builder()
|
||||
.timeout(Duration::from_secs(5))
|
||||
.build()
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
use tokio::sync::oneshot;
|
||||
|
||||
use crate::{
|
||||
NetworkEvent, NodeHash,
|
||||
NetworkEvent, NodeHash, P2PSharedData,
|
||||
cryptographic_signature::{
|
||||
CryptographicSignature, get_peer_key, sign_message, verify_signature,
|
||||
},
|
||||
@@ -9,9 +11,11 @@ use crate::{
|
||||
peers_refresh::HandshakeHistory,
|
||||
registration,
|
||||
server_communication::generate_id,
|
||||
timestamp::Timestamp,
|
||||
};
|
||||
use std::{
|
||||
collections::HashMap,
|
||||
default,
|
||||
net::{Ipv4Addr, SocketAddr},
|
||||
};
|
||||
use std::{
|
||||
@@ -20,7 +24,7 @@ use std::{
|
||||
};
|
||||
|
||||
// Types of messages that await for a response
|
||||
#[derive(Debug)]
|
||||
#[derive(Debug, Clone)]
|
||||
pub enum EventType {
|
||||
HelloThenRootRequest,
|
||||
Hello,
|
||||
@@ -28,6 +32,32 @@ pub enum EventType {
|
||||
Ping,
|
||||
NatTraversal,
|
||||
DatumRequest,
|
||||
Unknown,
|
||||
}
|
||||
|
||||
impl EventType {
|
||||
pub fn to_string(&self) -> String {
|
||||
match self {
|
||||
EventType::HelloThenRootRequest => "HelloThenRootRequest".to_owned(),
|
||||
EventType::Hello => "Hello".to_owned(),
|
||||
EventType::RootRequest => "RootRequest".to_owned(),
|
||||
EventType::Ping => "Ping".to_owned(),
|
||||
EventType::NatTraversal => "NatTraversal".to_owned(),
|
||||
EventType::DatumRequest => "DatumRequest".to_owned(),
|
||||
EventType::Unknown => "Unknown".to_owned(),
|
||||
}
|
||||
}
|
||||
|
||||
pub fn from_msgtype(msgtype: u8) -> EventType {
|
||||
match msgtype {
|
||||
PING => EventType::Ping,
|
||||
HELLO => EventType::Hello,
|
||||
ROOTREQUEST => EventType::RootRequest,
|
||||
NATTRAVERSALREQUEST => EventType::NatTraversal,
|
||||
DATUMREQUEST => EventType::DatumRequest,
|
||||
_ => EventType::Unknown,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
const ID: usize = 4;
|
||||
@@ -51,6 +81,7 @@ const NATTRAVERSALREQUEST2: u8 = 5;
|
||||
|
||||
pub fn handle_recevied_message(
|
||||
messages_list: &Arc<Mutex<HashMap<i32, EventType>>>,
|
||||
messages_received: &Arc<Mutex<HashMap<String, (EventType, Timestamp)>>>,
|
||||
recevied_message: &Vec<u8>,
|
||||
crypto_pair: &CryptographicSignature,
|
||||
//socket_addr: &SocketAddr,
|
||||
@@ -89,6 +120,7 @@ pub fn handle_recevied_message(
|
||||
cmd_tx,
|
||||
ip,
|
||||
messages_list,
|
||||
messages_received,
|
||||
handhsake_history,
|
||||
senders,
|
||||
);
|
||||
@@ -114,6 +146,7 @@ pub fn parse_message(
|
||||
cmd_tx: crossbeam_channel::Sender<NetworkEvent>,
|
||||
ip: SocketAddr,
|
||||
messages_list: &Arc<Mutex<HashMap<i32, EventType>>>,
|
||||
messages_received: &Arc<Mutex<HashMap<String, (EventType, Timestamp)>>>,
|
||||
handhsake_history: Arc<HandshakeHistory>,
|
||||
senders: &MultipleSenders,
|
||||
) -> Option<Vec<u8>> {
|
||||
@@ -125,6 +158,14 @@ pub fn parse_message(
|
||||
|
||||
let msgtype = received_message[ID];
|
||||
|
||||
messages_received
|
||||
.lock()
|
||||
.expect("couldnt lock received map")
|
||||
.insert(
|
||||
ip.to_string(),
|
||||
(EventType::from_msgtype(msgtype), Timestamp::now()),
|
||||
);
|
||||
|
||||
let length_bytes: [u8; 2] = received_message[TYPE..LENGTH]
|
||||
.try_into()
|
||||
.expect("Taille incorrecte");
|
||||
@@ -134,6 +175,7 @@ pub fn parse_message(
|
||||
match msgtype {
|
||||
HELLO | HELLOREPLY => {
|
||||
let ilength = u16::from_be_bytes(length_bytes);
|
||||
println!("hello");
|
||||
println!("name received length: {}", ilength);
|
||||
let received_name = &received_message[LENGTH + EXTENSIONS..LENGTH + ilength as usize];
|
||||
let received_username = String::from_utf8(received_name.to_vec());
|
||||
@@ -147,12 +189,14 @@ pub fn parse_message(
|
||||
.block_on(get_peer_key(&username))
|
||||
.expect("failed to retrieve public key"),
|
||||
};
|
||||
println!("handshake JULIUS added");
|
||||
handhsake_history.add_new_handshake(peer_pubkey, "".to_string(), ip);
|
||||
let signature: [u8; SIGNATURE] = received_message
|
||||
[LENGTH + msg_length..LENGTH + msg_length + SIGNATURE]
|
||||
.try_into()
|
||||
.expect("Taille incorrecte");
|
||||
match msgtype {
|
||||
HELLOREPLY => {
|
||||
handhsake_history.add_new_handshake(peer_pubkey, "".to_string(), ip);
|
||||
}
|
||||
_ => {
|
||||
println!("no handshake added");
|
||||
}
|
||||
}
|
||||
if !verify_signature(peer_pubkey, &received_message) {
|
||||
println!(
|
||||
"incorrect signature from given peer: {}, ignoring message of type {} with id {}",
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
use crossbeam_channel::Receiver;
|
||||
use tokio::sync::oneshot;
|
||||
use tokio::time::sleep;
|
||||
|
||||
use crate::P2PSharedData;
|
||||
use crate::cryptographic_signature::CryptographicSignature;
|
||||
use crate::message_handling::EventType;
|
||||
use crate::message_handling::handle_recevied_message;
|
||||
use crate::peers_refresh::HandshakeHistory;
|
||||
@@ -193,6 +193,7 @@ pub fn start_retry_thread(
|
||||
// on verifie si le message a recu une reponse
|
||||
let message_id: [u8; 4] = front.msg.payload[0..4].try_into().expect("size error");
|
||||
let id = i32::from_be_bytes(message_id);
|
||||
|
||||
let message_type = front.msg.payload[4];
|
||||
let guard = messages_list.lock().unwrap();
|
||||
|
||||
@@ -268,6 +269,7 @@ pub fn start_receving_thread(
|
||||
let cryptopair_clone = shared_data.cryptopair();
|
||||
let senders_clone = shared_data.senders();
|
||||
let messages_clone = shared_data.messages_list();
|
||||
let messages_received_clone = shared_data.messages_received();
|
||||
let servername_clone = shared_data.servername();
|
||||
let thread = thread::spawn(move || {
|
||||
let mut buf = [0u8; 1024];
|
||||
@@ -279,6 +281,7 @@ pub fn start_receving_thread(
|
||||
println!("Reçu {} octets de {}: {:?}", amt, src, received_data);
|
||||
handle_recevied_message(
|
||||
&messages_clone,
|
||||
&messages_received_clone,
|
||||
&received_data,
|
||||
&cryptopair_clone,
|
||||
&senders_clone,
|
||||
|
||||
@@ -90,6 +90,10 @@ impl HandshakeHistory {
|
||||
}
|
||||
}
|
||||
|
||||
pub fn get_username_peerinfo_map(&self) -> Arc<Mutex<HashMap<String, PeerInfo>>> {
|
||||
self.username_k_peerinfo_v.clone()
|
||||
}
|
||||
|
||||
pub fn add_new_handshake(&self, hash: VerifyingKey, username: String, ip: SocketAddr) {
|
||||
let peerinfo = PeerInfo {
|
||||
username: username.clone(),
|
||||
@@ -112,14 +116,11 @@ pub fn update_handshake(
|
||||
let map_for_thread = username_k_peerinfo_v.clone();
|
||||
let handle = thread::spawn(move || {
|
||||
loop {
|
||||
println!("loop boucle");
|
||||
let guard = map_for_thread.lock().unwrap();
|
||||
println!("len:{}", guard.len());
|
||||
for (peer, peerinfo) in guard.iter() {
|
||||
let id = generate_id();
|
||||
let mut map = messages_list.lock().unwrap();
|
||||
map.insert(id, EventType::Ping);
|
||||
drop(map);
|
||||
let pingrequest = construct_message(PING, Vec::new(), id, &crypto_pair);
|
||||
if let Some(ping) = pingrequest {
|
||||
senders.add_message_to_retry_queue(
|
||||
@@ -133,10 +134,10 @@ pub fn update_handshake(
|
||||
false,
|
||||
messages_list.clone(),
|
||||
);
|
||||
println!("ping envoye a {}", peer);
|
||||
}
|
||||
}
|
||||
thread::sleep(Duration::from_secs(2));
|
||||
drop(guard);
|
||||
thread::sleep(Duration::from_secs(240));
|
||||
}
|
||||
});
|
||||
Worker::spawn(handle, crate::threads_handling::WorkerType::PING)
|
||||
|
||||
@@ -1,19 +1,14 @@
|
||||
use bytes::Bytes;
|
||||
|
||||
use crate::NetworkEvent;
|
||||
use crate::P2PSharedData;
|
||||
use crate::cryptographic_signature::{CryptographicSignature, formatPubKey, sign_message};
|
||||
use crate::get_socket_address;
|
||||
use crate::cryptographic_signature::CryptographicSignature;
|
||||
use crate::get_server_address;
|
||||
use crate::message_handling::EventType;
|
||||
use crate::messages_channels::MultipleSenders;
|
||||
use crate::messages_structure::construct_message;
|
||||
use crate::server_communication::generate_id;
|
||||
use crossbeam_channel::{Receiver, Sender};
|
||||
use std::collections::HashMap;
|
||||
use crossbeam_channel::Sender;
|
||||
use std::net::SocketAddr;
|
||||
use std::net::UdpSocket;
|
||||
use std::str::FromStr;
|
||||
use std::sync::{Arc, Mutex};
|
||||
use std::sync::Arc;
|
||||
|
||||
///
|
||||
/// sends the cryptographic signature to the server using a PUT request over the HTTP API.
|
||||
@@ -29,8 +24,13 @@ pub async fn register_with_the_server(
|
||||
let pubkey_bytes_minus = pubkey_bytes[1..].to_vec();
|
||||
let res = client.put(uri).body(pubkey_bytes_minus).send().await?;
|
||||
let res = res.error_for_status()?;
|
||||
println!("register ip adresses");
|
||||
Ok(())
|
||||
match res.error_for_status() {
|
||||
Ok(_) => {
|
||||
println!("register ip adresses");
|
||||
Ok(())
|
||||
}
|
||||
Err(e) => Err(e),
|
||||
}
|
||||
}
|
||||
|
||||
pub fn parse_addresses(input: &String) -> Vec<SocketAddr> {
|
||||
@@ -62,10 +62,11 @@ pub async fn perform_handshake(
|
||||
let senders = sd.senders_ref();
|
||||
|
||||
let id = generate_id();
|
||||
let server_addr_query = get_socket_address(username.clone(), ip.clone());
|
||||
let server_addr_query = get_server_address(username.clone(), ip.clone());
|
||||
match server_addr_query.await {
|
||||
Some(sockaddr_bytes) => {
|
||||
sd.set_servername(username);
|
||||
sd.set_serveraddress(sockaddr_bytes.to_string());
|
||||
// first: &SocketAddr
|
||||
let mut payload = Vec::new();
|
||||
payload.extend_from_slice(&0u32.to_be_bytes());
|
||||
@@ -115,8 +116,6 @@ pub async fn perform_handshake(
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
// Note this useful idiom: importing names from outer (for mod tests) scope.
|
||||
use super::*;
|
||||
|
||||
/*///
|
||||
/// does the procedure to register with the server
|
||||
|
||||
46
client-network/src/timestamp.rs
Normal file
46
client-network/src/timestamp.rs
Normal file
@@ -0,0 +1,46 @@
|
||||
use std::time::{SystemTime, UNIX_EPOCH};
|
||||
|
||||
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||
pub struct Timestamp {
|
||||
secs: u64, // seconds since UNIX epoch
|
||||
}
|
||||
|
||||
unsafe impl Send for Timestamp {}
|
||||
|
||||
impl Timestamp {
|
||||
// Create a Timestamp from current system time
|
||||
pub fn now() -> Self {
|
||||
let dur = SystemTime::now()
|
||||
.duration_since(UNIX_EPOCH)
|
||||
.expect("system time before UNIX_EPOCH");
|
||||
Self {
|
||||
secs: dur.as_secs(),
|
||||
}
|
||||
}
|
||||
|
||||
// Create from explicit fields (optional helper)
|
||||
pub fn from_secs(secs: u64) -> Self {
|
||||
Self { secs }
|
||||
}
|
||||
|
||||
// Return underlying seconds
|
||||
pub fn as_secs(&self) -> u64 {
|
||||
self.secs
|
||||
}
|
||||
|
||||
// Return elapsed seconds between `self` and `other`.
|
||||
// Panics if `other` is in the future relative to `self`.
|
||||
// If you call `Timestamp::now().diff(past)`, it returns seconds since `past`.
|
||||
pub fn diff(&self, earlier: &Timestamp) -> u64 {
|
||||
assert!(earlier.secs <= self.secs, "given time is in the future");
|
||||
self.secs - earlier.secs
|
||||
}
|
||||
|
||||
pub fn to_string(&self) -> String {
|
||||
let secs_of_day = self.secs % 86_400;
|
||||
let hh = secs_of_day / 3600;
|
||||
let mm = (secs_of_day % 3600) / 60;
|
||||
let ss = secs_of_day % 60;
|
||||
format!("{:02}:{:02}:{:02}", hh, mm, ss)
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user