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 committed by Nicolas Cantu
parent f23314d925
commit 90f83efd3d
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 message::{broadcast_message, process_message, BroadcastType, MessageCache, MESSAGECACHE};
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,
hex::{DisplayHex, FromHex},
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() {
Ok(lists) => (lists.peers_list.clone(), lists.processes_list.clone()),
Err(e) => {
log::error!("{}", e);
panic!();
}
};
let init_msg = InitMessage::new(
let init_msg = HandshakeMessage::new(
our_sp_address.to_string(),
peers_list,
processes_list,
members,
processes,
);
if let Err(e) = broadcast_message(