massive fmt

iroh-net/bench/src/iroh.rs

@@ -10,9 +10,8 @@ use iroh_net::{
     endpoint::{Connection, ConnectionError, RecvStream, SendStream, TransportConfig},
     Endpoint, NodeAddr,
 };
-use tracing::{trace, warn};
-
 use iroh_relay::{RelayMap, RelayMode, RelayUrl};
+use tracing::{trace, warn};
 
 use crate::{
     client_handler, stats::TransferResult, ClientStats, ConnectionSelector, EndpointSelector, Opt,

iroh-net/src/defaults.rs

@@ -1,8 +1,7 @@
 //! Default values used in [`iroh-net`][`crate`]
 
-use url::Url;
-
 use iroh_relay::{RelayMap, RelayNode};
+use url::Url;
 
 /// The default STUN port used by the Relay server.
 ///

iroh-net/src/disco.rs

@@ -24,12 +24,12 @@ use std::{
 };
 
 use anyhow::{anyhow, bail, ensure, Context, Result};
+use iroh_relay::RelayUrl;
 use serde::{Deserialize, Serialize};
 use url::Url;
 
 use super::key::PublicKey;
 use crate::key;
-use iroh_relay::RelayUrl;
 
 // TODO: custom magicn
 /// The 6 byte header of all discovery messages.

iroh-net/src/discovery.rs

@@ -439,13 +439,13 @@ mod tests {
         time::SystemTime,
     };
 
+    use iroh_relay::RelayMode;
     use parking_lot::Mutex;
     use rand::Rng;
     use tokio_util::task::AbortOnDropHandle;
 
     use super::*;
     use crate::key::SecretKey;
-    use iroh_relay::RelayMode;
 
     #[derive(Debug, Clone, Default)]
     struct TestDiscoveryShared {
@@ -732,6 +732,7 @@ mod test_dns_pkarr {
 
     use anyhow::Result;
     use iroh_base::key::SecretKey;
+    use iroh_relay::{RelayMap, RelayMode};
     use tokio_util::task::AbortOnDropHandle;
 
     use crate::{
@@ -744,7 +745,6 @@ mod test_dns_pkarr {
         },
         AddrInfo, Endpoint, NodeAddr,
     };
-    use iroh_relay::{RelayMap, RelayMode};
 
     const PUBLISH_TIMEOUT: Duration = Duration::from_secs(10);
 

iroh-net/src/discovery/dns.rs

@@ -2,15 +2,14 @@
 
 use anyhow::Result;
 use futures_lite::stream::Boxed as BoxStream;
+use iroh_relay::force_staging_infra;
 
 use crate::{
     discovery::{Discovery, DiscoveryItem},
     dns::ResolverExt,
     Endpoint, NodeId,
 };
 
-use iroh_relay::force_staging_infra;
-
 /// The n0 testing DNS node origin, for production.
 pub const N0_DNS_NODE_ORIGIN_PROD: &str = "dns.iroh.link";
 /// The n0 testing DNS node origin, for testing.

iroh-net/src/discovery/pkarr.rs

@@ -48,6 +48,7 @@ use std::sync::Arc;
 
 use anyhow::{anyhow, bail, Result};
 use futures_util::stream::BoxStream;
+use iroh_relay::force_staging_infra;
 use pkarr::SignedPacket;
 use tokio::{
     task::JoinHandle,
@@ -64,8 +65,6 @@ use crate::{
     AddrInfo, Endpoint, NodeId,
 };
 
-use iroh_relay::force_staging_infra;
-
 #[cfg(feature = "discovery-pkarr-dht")]
 #[cfg_attr(iroh_docsrs, doc(cfg(feature = "discovery-pkarr-dht")))]
 pub mod dht;

iroh-net/src/endpoint.rs

@@ -24,6 +24,7 @@ use std::{
 use anyhow::{anyhow, bail, Context, Result};
 use derive_more::Debug;
 use futures_lite::{Stream, StreamExt};
+use iroh_relay::{force_staging_infra, RelayMode, RelayUrl};
 use pin_project::pin_project;
 use tokio_util::sync::{CancellationToken, WaitForCancellationFuture};
 use tracing::{debug, instrument, trace, warn};
@@ -38,7 +39,6 @@ use crate::{
     magicsock::{self, Handle, QuicMappedAddr},
     tls, NodeId,
 };
-use iroh_relay::{force_staging_infra, RelayMode, RelayUrl};
 
 mod rtt_actor;
 

iroh-net/src/magicsock.rs

@@ -35,6 +35,7 @@ use futures_lite::{FutureExt, Stream, StreamExt};
 use futures_util::stream::BoxStream;
 use iroh_base::key::NodeId;
 use iroh_metrics::{inc, inc_by};
+use iroh_relay::{protos::stun, RelayMap, RelayUrl};
 use netwatch::{interfaces, ip::LocalAddresses, netmon};
 use quinn::AsyncUdpSocket;
 use rand::{seq::SliceRandom, Rng, SeedableRng};
@@ -67,7 +68,6 @@ use crate::{
     key::{PublicKey, SecretKey, SharedSecret},
     netcheck, AddrInfo,
 };
-use iroh_relay::{protos::stun, RelayMap, RelayUrl};
 
 mod metrics;
 mod node_map;
@@ -2778,13 +2778,13 @@ impl NetInfo {
 #[cfg(test)]
 mod tests {
     use anyhow::Context;
+    use iroh_relay::RelayMode;
     use iroh_test::CallOnDrop;
     use rand::RngCore;
     use tokio_util::task::AbortOnDropHandle;
 
     use super::*;
     use crate::{defaults::staging::EU_RELAY_HOSTNAME, tls, Endpoint};
-    use iroh_relay::RelayMode;
 
     const ALPN: &[u8] = b"n0/test/1";
 

iroh-net/src/magicsock/node_map.rs

@@ -10,6 +10,7 @@ use std::{
 use futures_lite::stream::Stream;
 use iroh_base::key::NodeId;
 use iroh_metrics::inc;
+use iroh_relay::RelayUrl;
 use parking_lot::Mutex;
 use serde::{Deserialize, Serialize};
 use stun_rs::TransactionId;
@@ -27,7 +28,6 @@ use crate::{
     key::PublicKey,
     NodeAddr,
 };
-use iroh_relay::RelayUrl;
 
 mod best_addr;
 mod node_state;

iroh-net/src/magicsock/node_map/node_state.rs

@@ -6,6 +6,7 @@ use std::{
 };
 
 use iroh_metrics::inc;
+use iroh_relay::{protos::stun, RelayUrl};
 use netwatch::ip::is_unicast_link_local;
 use serde::{Deserialize, Serialize};
 use tokio::sync::mpsc;
@@ -27,9 +28,6 @@ use crate::{
     NodeAddr, NodeId,
 };
 
-use iroh_relay::protos::stun;
-use iroh_relay::RelayUrl;
-
 /// Number of addresses that are not active that we keep around per node.
 ///
 /// See [`NodeState::prune_direct_addresses`].

iroh-net/src/magicsock/node_map/path_state.rs

@@ -7,14 +7,14 @@ use std::{
 };
 
 use iroh_base::key::NodeId;
+use iroh_relay::protos::stun;
 use tracing::{debug, event, Level};
 
 use super::{
     node_state::{ControlMsg, PongReply, SESSION_ACTIVE_TIMEOUT},
     IpPort, PingRole, Source,
 };
 use crate::{disco::SendAddr, magicsock::HEARTBEAT_INTERVAL};
-use iroh_relay::protos::stun;
 
 /// The minimum time between pings to an endpoint.
 ///

iroh-net/src/magicsock/relay_actor.rs

@@ -10,6 +10,7 @@ use anyhow::Context;
 use backoff::backoff::Backoff;
 use bytes::{Bytes, BytesMut};
 use iroh_metrics::{inc, inc_by};
+use iroh_relay::{self as relay, client::ClientError, ReceivedMessage, RelayUrl, MAX_PACKET_SIZE};
 use tokio::{
     sync::{mpsc, oneshot},
     task::{JoinHandle, JoinSet},
@@ -20,7 +21,6 @@ use tracing::{debug, info, info_span, trace, warn, Instrument};
 
 use super::{ActorMessage, MagicSock, Metrics as MagicsockMetrics, RelayContents};
 use crate::key::{NodeId, PUBLIC_KEY_LENGTH};
-use iroh_relay::{self as relay, client::ClientError, ReceivedMessage, RelayUrl, MAX_PACKET_SIZE};
 
 /// How long a non-home relay connection needs to be idle (last written to) before we close it.
 const RELAY_INACTIVE_CLEANUP_TIME: Duration = Duration::from_secs(60);

iroh-net/src/metrics.rs

@@ -1,7 +1,7 @@
 //! Co-locating all of the iroh-net metrics structs
-pub use portmapper::Metrics as PortmapMetrics;
-
-pub use crate::{magicsock::Metrics as MagicsockMetrics, netcheck::Metrics as NetcheckMetrics};
 #[cfg(feature = "iroh-relay")]
 #[cfg_attr(iroh_docsrs, doc(cfg(feature = "iroh-relay")))]
 pub use iroh_relay::server::Metrics as RelayMetrics;
+pub use portmapper::Metrics as PortmapMetrics;
+
+pub use crate::{magicsock::Metrics as MagicsockMetrics, netcheck::Metrics as NetcheckMetrics};

iroh-net/src/netcheck.rs

@@ -17,6 +17,7 @@ use anyhow::{anyhow, Context as _, Result};
 use bytes::Bytes;
 use hickory_resolver::TokioAsyncResolver as DnsResolver;
 use iroh_metrics::inc;
+use iroh_relay::{protos::stun, RelayMap, RelayUrl};
 use netwatch::{IpFamily, UdpSocket};
 use tokio::{
     sync::{self, mpsc, oneshot},
@@ -25,8 +26,6 @@ use tokio::{
 use tokio_util::{sync::CancellationToken, task::AbortOnDropHandle};
 use tracing::{debug, error, info_span, trace, warn, Instrument};
 
-use iroh_relay::{protos::stun, RelayMap, RelayUrl};
-
 mod metrics;
 mod reportgen;
 
@@ -773,6 +772,7 @@ mod tests {
     use std::net::Ipv4Addr;
 
     use bytes::BytesMut;
+    use iroh_relay::RelayNode;
     use tokio::time;
     use tracing::info;
 
@@ -781,7 +781,6 @@ mod tests {
         defaults::{staging::EU_RELAY_HOSTNAME, DEFAULT_STUN_PORT},
         ping::Pinger,
     };
-    use iroh_relay::RelayNode;
 
     mod stun_utils {
         //! Utils for testing that expose a simple stun server.

iroh-net/src/netcheck/reportgen.rs

@@ -26,6 +26,7 @@ use std::{
 
 use anyhow::{anyhow, bail, Context, Result};
 use iroh_metrics::inc;
+use iroh_relay::{http::RELAY_PROBE_PATH, protos::stun, RelayMap, RelayNode, RelayUrl};
 use netwatch::{interfaces, UdpSocket};
 use rand::seq::IteratorRandom;
 use tokio::{
@@ -46,9 +47,6 @@ use crate::{
     util::MaybeFuture,
 };
 
-use iroh_relay::protos::stun;
-use iroh_relay::{http::RELAY_PROBE_PATH, RelayMap, RelayNode, RelayUrl};
-
 mod hairpin;
 mod probes;
 

iroh-net/src/netcheck/reportgen/hairpin.rs

@@ -15,6 +15,7 @@
 use std::net::{Ipv4Addr, SocketAddr, SocketAddrV4};
 
 use anyhow::{bail, Context, Result};
+use iroh_relay::protos::stun;
 use netwatch::UdpSocket;
 use tokio::{sync::oneshot, time::Instant};
 use tokio_util::task::AbortOnDropHandle;
@@ -25,8 +26,6 @@ use crate::{
     netcheck::{self, reportgen, Inflight},
 };
 
-use iroh_relay::protos::stun;
-
 /// Handle to the hairpin actor.
 ///
 /// Dropping it will abort the actor.

iroh-net/src/netcheck/reportgen/probes.rs

@@ -7,13 +7,12 @@
 use std::{collections::BTreeSet, fmt, sync::Arc};
 
 use anyhow::{ensure, Result};
+use iroh_relay::{RelayMap, RelayNode, RelayUrl};
 use netwatch::interfaces;
 use tokio::time::Duration;
 
 use crate::netcheck::Report;
 
-use iroh_relay::{RelayMap, RelayNode, RelayUrl};
-
 /// The retransmit interval used when netcheck first runs.
 ///
 /// We have no past context to work with, and we want answers relatively quickly, so it's

iroh-net/src/test_utils.rs

@@ -4,14 +4,13 @@ use std::net::Ipv4Addr;
 use anyhow::Result;
 pub use dns_and_pkarr_servers::DnsPkarrServer;
 pub use dns_server::create_dns_resolver;
-use tokio::sync::oneshot;
-
-use crate::defaults::DEFAULT_STUN_PORT;
-
 use iroh_relay::{
     server::{CertConfig, RelayConfig, Server, ServerConfig, StunConfig, TlsConfig},
     RelayMap, RelayNode, RelayUrl,
 };
+use tokio::sync::oneshot;
+
+use crate::defaults::DEFAULT_STUN_PORT;
 
 /// A drop guard to clean up test infrastructure.
 ///

iroh-relay/src/client.rs

@@ -44,11 +44,9 @@ use crate::{
     defaults::timeouts::*,
     http::{Protocol, RELAY_PATH},
     protos::relay::DerpCodec,
-    RelayUrl,
+    util, RelayUrl,
 };
 
-use crate::util;
-
 pub(crate) mod conn;
 pub(crate) mod streams;
 

iroh-relay/src/defaults.rs

@@ -20,9 +20,8 @@ pub const DEFAULT_METRICS_PORT: u16 = 9090;
 pub mod prod {
     use url::Url;
 
-    use crate::{RelayMap, RelayNode};
-
     use super::*;
+    use crate::{RelayMap, RelayNode};
 
     /// Hostname of the default NA relay.
     pub const NA_RELAY_HOSTNAME: &str = "use1-1.relay.iroh.network.";
@@ -89,9 +88,8 @@ pub mod prod {
 pub mod staging {
     use url::Url;
 
-    use crate::{RelayMap, RelayNode};
-
     use super::*;
+    use crate::{RelayMap, RelayNode};
 
     /// Hostname of the default NA relay.
     pub const NA_RELAY_HOSTNAME: &str = "staging-use1-1.relay.iroh.network.";

iroh-relay/src/main.rs

@@ -10,10 +10,10 @@ use std::{
 
 use anyhow::{anyhow, bail, Context as _, Result};
 use clap::Parser;
-use iroh_relay::defaults::{
-    DEFAULT_HTTPS_PORT, DEFAULT_HTTP_PORT, DEFAULT_METRICS_PORT, DEFAULT_STUN_PORT,
+use iroh_relay::{
+    defaults::{DEFAULT_HTTPS_PORT, DEFAULT_HTTP_PORT, DEFAULT_METRICS_PORT, DEFAULT_STUN_PORT},
+    server as relay,
 };
-use iroh_relay::server as relay;
 use serde::{Deserialize, Serialize};
 use tokio_rustls_acme::{caches::DirCache, AcmeConfig};
 use tracing::debug;

iroh-relay/src/protos/relay.rs

@@ -9,13 +9,11 @@ use bytes::{Buf, BufMut, Bytes, BytesMut};
 use futures_lite::{Stream, StreamExt};
 use futures_sink::Sink;
 use futures_util::SinkExt;
-use iroh_base::key::{Signature, PUBLIC_KEY_LENGTH};
+use iroh_base::key::{PublicKey, SecretKey, Signature, PUBLIC_KEY_LENGTH};
 use postcard::experimental::max_size::MaxSize;
 use serde::{Deserialize, Serialize};
 use tokio_util::codec::{Decoder, Encoder};
 
-use iroh_base::key::{PublicKey, SecretKey};
-
 /// The maximum size of a packet sent over relay.
 /// (This only includes the data bytes visible to magicsock, not
 /// including its on-wire framing overhead)