Skip to content

Commit c0600e1

Browse files
committed
clean up
1 parent 6112f01 commit c0600e1

File tree

4 files changed

+25
-22
lines changed

4 files changed

+25
-22
lines changed

src/jormungandr/jormungandr/src/fragment/logs.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use crate::{fragment::FragmentId, network::bootstrap::local_addr_lookup};
1+
use crate::{fragment::FragmentId, network::retrieve_local_ip};
22
use jormungandr_lib::{
33
crypto::hash::Hash,
44
interfaces::{BlockDate, FragmentLog, FragmentOrigin, FragmentStatus},
@@ -79,7 +79,7 @@ impl Logs {
7979
let mut entry = FragmentLog::new(
8080
fragment_id.into_hash(),
8181
FragmentOrigin::Network {
82-
addr: local_addr_lookup(),
82+
addr: retrieve_local_ip(),
8383
},
8484
);
8585
entry.modify(status);

src/jormungandr/jormungandr/src/network/bootstrap.rs

Lines changed: 2 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,8 @@ use crate::{
88
use chain_core::property::ReadError;
99
use chain_network::{data as net_data, error::Error as NetworkError};
1010
use futures::prelude::*;
11-
use local_ip_address::local_ip;
12-
use std::{
13-
fmt::Debug,
14-
net::{IpAddr, Ipv4Addr},
15-
};
11+
12+
use std::fmt::Debug;
1613
use tokio_util::sync::CancellationToken;
1714

1815
#[derive(thiserror::Error, Debug)]
@@ -130,16 +127,3 @@ pub async fn bootstrap_from_peer(
130127
.map_err(Box::new)?;
131128
}
132129
}
133-
134-
pub fn local_addr_lookup() -> IpAddr {
135-
match local_ip() {
136-
Ok(ip) => ip,
137-
Err(err) => {
138-
tracing::error!(
139-
reason = %err,
140-
"unable to lookup local addr"
141-
);
142-
std::net::IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1))
143-
}
144-
}
145-
}

src/jormungandr/jormungandr/src/network/mod.rs

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,11 @@ mod subscription;
1515

1616
use self::convert::Encode;
1717
use futures::{future, prelude::*};
18+
use local_ip_address::local_ip;
19+
use std::{
20+
fmt::Debug,
21+
net::{IpAddr, Ipv4Addr},
22+
};
1823
use thiserror::Error;
1924
use tokio_util::sync::CancellationToken;
2025

@@ -781,3 +786,17 @@ pub enum FetchBlockError {
781786
#[error("could not download block hash {block}")]
782787
CouldNotDownloadBlock { block: HeaderHash },
783788
}
789+
790+
/// Infallible util function to obtain local IP addr
791+
pub fn retrieve_local_ip() -> IpAddr {
792+
match local_ip() {
793+
Ok(ip) => ip,
794+
Err(err) => {
795+
tracing::error!(
796+
reason = %err,
797+
"unable to lookup local addr"
798+
);
799+
std::net::IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1))
800+
}
801+
}
802+
}

src/jormungandr/jormungandr/src/network/subscription.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ use super::{buffer_sizes, convert::Decode, GlobalStateR};
22
use crate::{
33
blockcfg::Fragment,
44
intercom::{self, BlockMsg, TopologyMsg, TransactionMsg},
5-
network::bootstrap::local_addr_lookup,
5+
network::retrieve_local_ip,
66
settings::start::network::Configuration,
77
topology::{Gossip, NodeId},
88
utils::async_msg::{self, MessageBox},
@@ -380,7 +380,7 @@ impl FragmentProcessor {
380380
None => {
381381
tracing::error!("node addr not present in config, reverting to local lookup");
382382
FragmentOrigin::Network {
383-
addr: local_addr_lookup(),
383+
addr: retrieve_local_ip(),
384384
}
385385
}
386386
};

0 commit comments

Comments
 (0)