eightball/PluralKit
1
0
Fork 0
mirror of https://github.com/PluralKit/PluralKit.git synced 2026-02-04 04:56:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

chore(gateway): format
Some checks failed
Build and push Rust service Docker images / rust docker build (push) Has been cancelled
Details
rust checks / cargo fmt (push) Has been cancelled
Details

Browse source
This commit is contained in:
asleepyskye 2025-08-27 22:34:19 -04:00
parent 1378379e14
commit 65b40c498b
2 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

6
crates/gateway/src/discord/gateway.rs
View file

@ -6,7 +6,7 @@ use std::sync::Arc;
use tokio::sync::mpsc::Sender; use tokio::sync::mpsc::Sender;
use tracing::{error, info, warn}; use tracing::{error, info, warn};
use twilight_gateway::{ 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::{ use twilight_model::gateway::{
payload::outgoing::update_presence::UpdatePresencePayload, payload::outgoing::update_presence::UpdatePresencePayload,
@ -135,9 +135,7 @@ pub async fn runner(
) )
.increment(1); .increment(1);
if let Err(error) = if let Err(error) = tx_state.try_send((shard.id(), state_event, None, None)) {
tx_state.try_send((shard.id(), state_event, None, None))
{
error!("failed to update shard state for socket closure: {error}"); error!("failed to update shard state for socket closure: {error}");
} }

7
crates/gateway/src/main.rs
View file

@ -109,12 +109,15 @@ async fn main() -> anyhow::Result<()> {
}; };
} }
ShardStateEvent::Closed => { 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}") error!("failed to update shard state for closed: {error}")
}; };
} }
ShardStateEvent::Reconnect => { 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}") error!("failed to update shard state for reconnect: {error}")
}; };
} }