From 05b99e21dce911b761151b12b104a5611beed426 Mon Sep 17 00:00:00 2001
From: Apher <apher@spilum.net>
Date: Mon, 29 Jun 2026 01:09:14 +0000
Subject: [PATCH] Fix typo

---
 src/models/index.js | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/models/index.js b/src/models/index.js
index 2bb0369..65e3ca8 100644
--- a/src/models/index.js
+++ b/src/models/index.js
@@ -59,7 +59,7 @@ redis.initializeStreams = async () => {
 
         // Create transcriptions streams consumer group
         try {
-            await client.xGroupCreate("communication", "mtf-devices", '0', {MKSTREAM: true});
+            await redis.client.xGroupCreate("communication", "mtf-devices", '0', {MKSTREAM: true});
 
             console.log("Created consumer group: mtf-devices (communication)");
         } catch (err) {
@@ -75,7 +75,7 @@ redis.initializeStreams = async () => {
         for (const deviceId of deviceIds) {
             const groupName = `${deviceId}_group`;
             try {
-                await client.xGroupCreate('communication', groupName, '0', {MKSTREAM: true});
+                await redis.client.xGroupCreate('communication', groupName, '0', {MKSTREAM: true});
                 console.log(`Created consumer group: ${groupName} (communication)`);
             } catch (err) {
                 if (err.message.includes('BUSYGROUP')) {
@@ -87,7 +87,7 @@ redis.initializeStreams = async () => {
         }
 
         console.log("Streams initialized successfully");
-        await client.quit();
+        await redis.client.quit();
     } catch (err) {
         console.error("Error initializing streams:", err.message);
     }