Fix formatting

Author: PredaaA

src/cache.rs

@@ -45,7 +45,7 @@ pub enum Event {
 pub struct Guilds(Arc<InMemoryCache>, u32);
 
 impl Guilds {
-    pub fn new(cache: Arc<InMemoryCache>, shard_id: u32) -> Self {
+    pub const fn new(cache: Arc<InMemoryCache>, shard_id: u32) -> Self {
         Self(cache, shard_id)
     }
 

src/discord_log.rs

@@ -15,12 +15,12 @@ pub fn discord_log(
     let message: String = message.into();
 
     tokio::spawn(async move {
-        let binding = "".to_string();
+        let binding = String::new();
         let webhook_url = CONFIG.webhook_url.as_ref().unwrap_or(&binding);
         if webhook_url.is_empty() {
             return;
         }
-        let Ok((webhook_id, webhook_token)) = webhook_link::parse(&webhook_url) else {
+        let Ok((webhook_id, webhook_token)) = webhook_link::parse(webhook_url) else {
             warn!("Invalid webhook URL");
             return;
         };

src/dispatch.rs

@@ -1,8 +1,8 @@
+use futures_util::StreamExt;
 use itoa::Buffer;
 #[cfg(feature = "simd-json")]
 use simd_json::Mutable;
 use tokio::{sync::broadcast, time::Instant};
-use futures_util::StreamExt;
 use tracing::{info, trace};
 use twilight_gateway::{parse, Event, EventType, EventTypeFlags, Message, Shard};
 use twilight_model::gateway::event::GatewayEvent as TwilightGatewayEvent;
@@ -32,7 +32,7 @@ pub async fn events(
     shard_count: u32,
     broadcast_tx: broadcast::Sender<BroadcastMessage>,
     client: Arc<twilight_http::Client>,
-){
+) {
     // This method only wants to relay events while the shard is in a READY state
     // Therefore, we only put events in the queue while we are connected and READY
     let mut is_ready = false;
@@ -168,7 +168,7 @@ pub fn update_shard_statistics(
 ) {
     // We don't want to depend on a specific twilight type name here. Use the
     // Debug representation to determine a rough numeric status mapping.
-    let status_str = format!("{:?}", connection_status);
+    let status_str = format!("{connection_status:?}");
     let connection_status = if status_str.contains("Connected") {
         4.0
     } else if status_str.contains("Identifying") {

src/main.rs

@@ -21,7 +21,7 @@ use tracing_subscriber::{
     filter::LevelFilter, layer::SubscriberExt, reload, util::SubscriberInitExt,
 };
 use twilight_cache_inmemory::InMemoryCache;
-use twilight_gateway::{CloseFrame, Config, ConfigBuilder, Shard, ShardId};
+use twilight_gateway::{CloseFrame, ConfigBuilder, Shard, ShardId};
 use twilight_gateway_queue::InMemoryQueue;
 use twilight_http::Client;
 use twilight_model::gateway::{

src/server.rs

@@ -53,7 +53,7 @@ fn compress_full(compressor: &mut Compress, output: &mut Vec<u8>, input: &[u8])
             .compress_vec(&input[offset..], output, FlushCompress::None)
             .unwrap()
         {
-            Status::Ok => continue,
+            Status::Ok => (),
             Status::BufError => output.reserve(4096),
             Status::StreamEnd => break,
         }
@@ -65,7 +65,7 @@ fn compress_full(compressor: &mut Compress, output: &mut Vec<u8>, input: &[u8])
             .compress_vec(&[], output, FlushCompress::Sync)
             .unwrap()
         {
-            Status::Ok | Status::BufError => continue,
+            Status::Ok | Status::BufError => (),
             Status::StreamEnd => break,
         }
     }
@@ -144,7 +144,7 @@ async fn forward_shard(
         if let Ok(serialized) = to_string(&ready_payload) {
             debug!("[Shard {shard_id}] Sending newly created READY");
             let _res = stream_writer.send(Message::Text(serialized));
-        };
+        }
 
         // Send GUILD_CREATE/GUILD_DELETEs based on guild availability
         for payload in shard_status.guilds.get_guild_payloads(&mut seq) {
@@ -153,7 +153,7 @@ async fn forward_shard(
                     "[Shard {shard_id}] Sending newly created GUILD_CREATE/GUILD_DELETE payload",
                 );
                 let _res = stream_writer.send(Message::Text(serialized));
-            };
+            }
         }
     } else {
         let _res = stream_writer.send(Message::Text(RESUMED.to_string()));