4nk/sdk_relay
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update to HandshakeMessage

Browse Source
This commit is contained in:
NicolasCantu 2025-01-09 17:30:39 +01:00
parent 9db6b9f957
commit a55159449a
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/main.rs
View File

@ -16,7 +16,7 @@ use futures_util::{future, pin_mut, stream::TryStreamExt, FutureExt, StreamExt};
use log::{debug, error, warn}; use log::{debug, error, warn};
use message::{broadcast_message, process_message, BroadcastType, MessageCache, MESSAGECACHE}; use message::{broadcast_message, process_message, BroadcastType, MessageCache, MESSAGECACHE};
use scan::{check_transaction_alone, compute_partial_tweak_to_transaction}; use scan::{check_transaction_alone, compute_partial_tweak_to_transaction};
use sdk_common::{network::InitMessage, pcd::Member, process::{Process, CACHEDPROCESSES}, sp_client::{bitcoin::{ use sdk_common::{network::HandshakeMessage, pcd::Member, process::{lock_processes, Process, CACHEDPROCESSES}, sp_client::{bitcoin::{
consensus::deserialize, consensus::deserialize,
hex::{DisplayHex, FromHex}, hex::{DisplayHex, FromHex},
Amount, Network, Transaction, Amount, Network, Transaction,
@ -199,20 +199,13 @@ async fn handle_connection(raw_stream: TcpStream, addr: SocketAddr, our_sp_addre
} }
}; };
let public_lists = LISTS.get().expect("Public Lists are not initialized"); let processes = lock_processes().unwrap().clone();
let members = lock_members().unwrap().clone();
let (peers_list, processes_list) = match public_lists.lock_anyhow() { let init_msg = HandshakeMessage::new(
Ok(lists) => (lists.peers_list.clone(), lists.processes_list.clone()),
Err(e) => {
log::error!("{}", e);
panic!();
}
};
let init_msg = InitMessage::new(
our_sp_address.to_string(), our_sp_address.to_string(),
peers_list, members,
processes_list, processes,
); );
if let Err(e) = broadcast_message( if let Err(e) = broadcast_message(