jmug/stoatchat
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

fix(bonfire): ignore all Redis errors but Canceled

Browse Source
This commit is contained in:
Paul Makles
2024-06-20 22:12:00 +01:00
parent 090d8cba71
commit 93e05e9f18
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
crates/bonfire/src/websocket.rs
View File

@@ -3,6 +3,7 @@ use std::{collections::HashSet, net::SocketAddr, sync::Arc};
use async_tungstenite::WebSocketStream; use async_tungstenite::WebSocketStream;
use authifier::AuthifierEvent; use authifier::AuthifierEvent;
use fred::{ use fred::{
error::{RedisError, RedisErrorKind},
interfaces::{ClientLike, EventInterface, PubsubInterface}, interfaces::{ClientLike, EventInterface, PubsubInterface},
types::RedisConfig, types::RedisConfig,
}; };
@@ -229,11 +230,14 @@ async fn listener(
// Handle Redis connection dropping // Handle Redis connection dropping
let (clean_up_s, clean_up_r) = async_channel::bounded(1); let (clean_up_s, clean_up_r) = async_channel::bounded(1);
let clean_up_s = Arc::new(Mutex::new(clean_up_s)); let clean_up_s = Arc::new(Mutex::new(clean_up_s));
subscriber.on_error(move |_| { subscriber.on_error(move |err| {
let clean_up_s = clean_up_s.clone(); if let RedisErrorKind::Canceled = err.kind() {
spawn(async move { let clean_up_s = clean_up_s.clone();
clean_up_s.lock().await.send(()).await.ok(); spawn(async move {
}); clean_up_s.lock().await.send(()).await.ok();
});
}
Ok(()) Ok(())
}); });