From ce09dc0b233643e646e5302d8efec6014271265c Mon Sep 17 00:00:00 2001 From: Stan Bondi Date: Wed, 16 Oct 2024 15:15:21 +0400 Subject: [PATCH] always dial when using dial-peer cmd --- .../minotari_node/src/commands/command/dial_peer.rs | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/applications/minotari_node/src/commands/command/dial_peer.rs b/applications/minotari_node/src/commands/command/dial_peer.rs index e71c776b25..a0f8f37909 100644 --- a/applications/minotari_node/src/commands/command/dial_peer.rs +++ b/applications/minotari_node/src/commands/command/dial_peer.rs @@ -26,7 +26,12 @@ use anyhow::Error; use async_trait::async_trait; use clap::Parser; use minotari_app_utilities::utilities::UniPeerId; -use tari_network::{identity::PeerId, NetworkingService, ToPeerId}; +use tari_network::{ + identity::PeerId, + swarm::dial_opts::{DialOpts, PeerCondition}, + NetworkingService, + ToPeerId, +}; use tokio::task; use super::{CommandContext, HandleCommand}; @@ -53,7 +58,10 @@ impl CommandContext { let start = Instant::now(); println!("☎️ Dialing peer..."); - match network.dial_peer(dest_peer_id).await { + match network + .dial_peer(DialOpts::peer_id(dest_peer_id).condition(PeerCondition::Always).build()) + .await + { Ok(waiter) => match waiter.await { Ok(_) => { println!("⚡️ Peer connected in {}ms!", start.elapsed().as_millis());