Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 14 additions & 2 deletions rust/lit-node/lit-node/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -239,15 +239,27 @@ pub fn main() {
ps_tx.clone(),
peer_checker_tx.clone(),
))
.expect("failed to create PeerState"),
.unwrap_or_else(|e| {
error!(
err = ?e,
"Failed to create PeerState; aborting lit_node startup (supervisor may restart the process)"
);
panic!("failed to create PeerState: {:?}", e);
}),
);

let (tss_state, rx_round_manager, rx_batch_manager) = tss_state::TssState::init(
peer_state,
Arc::new(cfg.clone()),
chain_data_manager.clone(),
)
.expect("Error initializing tss state");
.unwrap_or_else(|e| {
error!(
err = ?e,
"Error initializing TSS state; aborting lit_node startup (supervisor may restart the process)"
);
panic!("Error initializing tss state: {:?}", e);
});

let delegation_usage_db = Arc::new(DelegatedUsageDB::default_with_chain_data_config_manager(
chain_data_manager.clone(),
Expand Down
20 changes: 15 additions & 5 deletions rust/lit-node/lit-node/src/peers/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ use std::collections::BTreeSet;
use std::iter::FromIterator;
use std::sync::{Arc, Weak};
use tonic::transport::Channel;
use tracing::instrument;
use tracing::{error, instrument};
use xor_name::XorName;

#[derive(Debug)]
Expand Down Expand Up @@ -111,11 +111,21 @@ impl PeerState {
.send()
.await
{
let decoded_err = e
.decode_contract_revert::<staking::StakingErrors>()
.expect_or_err("Could not decode staking contract error")?;
// This error currently causes the node to fail startup (and typically be restarted by a supervisor like systemd).
let decoded_revert = e.decode_contract_revert::<staking::StakingErrors>();
error!(
?staker_address,
?attested_node_address,
err = ?e,
decoded_revert = ?decoded_revert,
"Attested wallet registration failed"
);

let err_msg = decoded_revert
.map(|d| format!("{:?}", d))
.unwrap_or_else(|| format!("{:?}", e));
return Err(unexpected_err_code(
format!("{:?}", decoded_err),
err_msg,
EC::NodeBlockchainError,
Some("Could not register attested wallet".to_string()),
));
Expand Down