reformat

Author: randomairborne

pyng/src/tokio/bedrock.rs

@@ -13,9 +13,9 @@ use tokio::{
 };
 
 use crate::{
-    bedrock::{Packet, DEFAULT_PORT, OFFLINE_MESSAGE_DATA_ID},
-    tokio::AsyncPingable,
     Bedrock, BedrockResponse, Error,
+    bedrock::{DEFAULT_PORT, OFFLINE_MESSAGE_DATA_ID, Packet},
+    tokio::AsyncPingable,
 };
 
 impl AsyncPingable for Bedrock {
@@ -129,7 +129,7 @@ impl Connection {
                 return Err(io::Error::new(
                     io::ErrorKind::Other,
                     "Invalid C -> S Packet",
-                ))
+                ));
             }
         }
 

pyng/src/tokio/java.rs

@@ -12,7 +12,7 @@ use tokio::{
     net::TcpStream,
 };
 
-use crate::{java::Packet, tokio::AsyncPingable, Error, Java, JavaResponse};
+use crate::{Error, Java, JavaResponse, java::Packet, tokio::AsyncPingable};
 
 impl AsyncPingable for Java {
     type Response = JavaResponse;

pyng/src/tokio/mod.rs

@@ -4,8 +4,8 @@ mod java;
 use std::sync::OnceLock;
 
 use hickory_resolver::{
-    config::{ResolverConfig, ResolverOpts},
     TokioAsyncResolver,
+    config::{ResolverConfig, ResolverOpts},
 };
 
 use crate::Error;
@@ -17,7 +17,7 @@ pub trait AsyncPingable {
 
     /// Ping the entity, gathering the latency and response.
     fn ping(self)
-        -> impl std::future::Future<Output = Result<(u64, Self::Response), Error>> + Send;
+    -> impl std::future::Future<Output = Result<(u64, Self::Response), Error>> + Send;
 }
 
 /// Retrieve the status of a given Minecraft server using a `AsyncPingable` configuration.

src/executor.rs

@@ -4,8 +4,8 @@ use futures_util::future::Either;
 use pyng::{Bedrock, Java};
 
 use crate::{
-    structures::{ChatStatus, MCPingResponse, PlayerSample, Players, Version},
     Failure,
+    structures::{ChatStatus, MCPingResponse, PlayerSample, Players, Version},
 };
 
 pub async fn ping_java(address: String) -> Result<MCPingResponse, Failure> {

src/main.rs

@@ -14,33 +14,33 @@ use std::{
 
 use arc_swap::ArcSwap;
 use axum::{
+    Extension, Router,
     body::Body,
     extract::{FromRequestParts, Path, Query, Request, State},
     handler::Handler,
     http::{
+        HeaderName, HeaderValue, StatusCode,
         header::{ACCEPT, CACHE_CONTROL, CONTENT_TYPE},
         request::Parts,
-        HeaderName, HeaderValue, StatusCode,
     },
     middleware::Next,
     response::{Html, IntoResponse, Redirect, Response},
     routing::get,
-    Extension, Router,
 };
 use axum_extra::routing::RouterExt;
-use base64::{prelude::BASE64_STANDARD, Engine};
+use base64::{Engine, prelude::BASE64_STANDARD};
 use bustdir::BustDir;
-use reqwest::{header::HeaderMap, redirect::Policy, Client};
+use reqwest::{Client, header::HeaderMap, redirect::Policy};
 use rinja::Template;
 use serde::{Deserialize, Serialize};
 use tokio::net::TcpListener;
 use tokio_util::sync::CancellationToken;
 use tower::ServiceBuilder;
 use tower_http::{services::ServeDir, set_header::SetResponseHeaderLayer};
 use tower_sombrero::{
+    Sombrero,
     csp::CspNonce,
     headers::{ContentSecurityPolicy, CspSchemeSource, CspSource},
-    Sombrero,
 };
 use tracing::Level;
 

src/services.rs

@@ -8,11 +8,11 @@ use tokio::join;
 use tokio_util::sync::CancellationToken;
 
 use crate::{
+    AppState, Json,
     structures::{
         MinecraftApiStatusEntry, MojangApiStatus, MojangSessionServerStatus, ServicesResponse,
         Status, XblStatusName, XblStatusResponse,
     },
-    AppState, Json,
 };
 
 const MOJANG_SESSIONSERVER_URL: &str =