From a75e4eabfc4b34aba7620c82ba77558a32d9e10a Mon Sep 17 00:00:00 2001
From: Paul Makles <me@insrt.uk>
Date: Mon, 16 Feb 2026 19:37:04 +0000
Subject: [PATCH] fix: add separate config option for redis events replica url
 (#590)

---
 crates/bonfire/src/websocket.rs | 8 +++++++-
 crates/core/config/src/lib.rs   | 1 +
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/crates/bonfire/src/websocket.rs b/crates/bonfire/src/websocket.rs
index bdada514..c92da23b 100644
--- a/crates/bonfire/src/websocket.rs
+++ b/crates/bonfire/src/websocket.rs
@@ -218,7 +218,13 @@ async fn listener(
     kill_signal_r: async_channel::Receiver<()>,
     write: &Mutex<WsWriter>,
 ) {
-    let redis_config = RedisConfig::from_url(&REDIS_URI).unwrap();
+    let stoat_config = revolt_config::config().await;
+    let url = stoat_config
+        .database
+        .redis_pubsub
+        .unwrap_or(REDIS_URI.to_string());
+
+    let redis_config = RedisConfig::from_url(&url).unwrap();
     let subscriber = match report_internal_error!(
         fred::types::Builder::from_config(redis_config).build_subscriber_client()
     ) {
diff --git a/crates/core/config/src/lib.rs b/crates/core/config/src/lib.rs
index 35c93b5a..8b68ad4f 100644
--- a/crates/core/config/src/lib.rs
+++ b/crates/core/config/src/lib.rs
@@ -117,6 +117,7 @@ static CONFIG_BUILDER: Lazy<RwLock<Config>> = Lazy::new(|| {
 pub struct Database {
     pub mongodb: String,
     pub redis: String,
+    pub redis_pubsub: Option<String>,
 }
 
 #[derive(Deserialize, Debug, Clone)]