diff --git a/crates/gateway/src/discord/gateway.rs b/crates/gateway/src/discord/gateway.rs index 2f657138..8210e06e 100644 --- a/crates/gateway/src/discord/gateway.rs +++ b/crates/gateway/src/discord/gateway.rs @@ -6,7 +6,7 @@ use std::sync::Arc; use tokio::sync::mpsc::Sender; use tracing::{error, info, warn}; use twilight_gateway::{ - create_iterator, ConfigBuilder, Event, EventTypeFlags, Message, Shard, ShardId, CloseFrame + create_iterator, CloseFrame, ConfigBuilder, Event, EventTypeFlags, Message, Shard, ShardId, }; use twilight_model::gateway::{ payload::outgoing::update_presence::UpdatePresencePayload, @@ -135,9 +135,7 @@ pub async fn runner( ) .increment(1); - if let Err(error) = - tx_state.try_send((shard.id(), state_event, None, None)) - { + if let Err(error) = tx_state.try_send((shard.id(), state_event, None, None)) { error!("failed to update shard state for socket closure: {error}"); } diff --git a/crates/gateway/src/main.rs b/crates/gateway/src/main.rs index a4bf7d2a..12db76b5 100644 --- a/crates/gateway/src/main.rs +++ b/crates/gateway/src/main.rs @@ -109,12 +109,15 @@ async fn main() -> anyhow::Result<()> { }; } ShardStateEvent::Closed => { - if let Err(error) = shard_state.socket_closed(shard_id.number(), false).await { + if let Err(error) = + shard_state.socket_closed(shard_id.number(), false).await + { error!("failed to update shard state for closed: {error}") }; } ShardStateEvent::Reconnect => { - if let Err(error) = shard_state.socket_closed(shard_id.number(), true).await { + if let Err(error) = shard_state.socket_closed(shard_id.number(), true).await + { error!("failed to update shard state for reconnect: {error}") }; }