From 308193377d08454fac3381513957ff011ae586a3 Mon Sep 17 00:00:00 2001
From: Bob Bobs <bobthebobs@protonmail.com>
Date: Fri, 2 Feb 2024 10:31:11 -0700
Subject: [PATCH] fix(bonfire): use REDIS_URI env var

---
 crates/bonfire/src/websocket.rs | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/crates/bonfire/src/websocket.rs b/crates/bonfire/src/websocket.rs
index b7d363b1..6fd5aa08 100644
--- a/crates/bonfire/src/websocket.rs
+++ b/crates/bonfire/src/websocket.rs
@@ -1,7 +1,10 @@
 use std::net::SocketAddr;
 
 use async_tungstenite::WebSocketStream;
-use fred::interfaces::{ClientLike, EventInterface, PubsubInterface};
+use fred::{
+    interfaces::{ClientLike, EventInterface, PubsubInterface},
+    types::RedisConfig,
+};
 use futures::{
     channel::oneshot,
     pin_mut, select,
@@ -16,7 +19,7 @@ use revolt_quark::{
         state::{State, SubscriptionStateChange},
     },
     models::{user::UserHint, User},
-    redis_kiss::{PayloadType, REDIS_PAYLOAD_TYPE},
+    redis_kiss::{PayloadType, REDIS_PAYLOAD_TYPE, REDIS_URI},
     Database,
 };
 
@@ -142,7 +145,8 @@ async fn listener(
     config: &ProtocolConfiguration,
     write: &Mutex<WsWriter>,
 ) {
-    let Ok(subscriber) = fred::prelude::Builder::default_centralized().build_subscriber_client()
+    let redis_config = RedisConfig::from_url(&REDIS_URI).unwrap();
+    let Ok(subscriber) = fred::types::Builder::from_config(redis_config).build_subscriber_client()
     else {
         return;
     };