Spilum.Net/mtf-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix typo

Browse Source
This commit is contained in:
Apher 2026-06-29 01:09:14 +00:00
parent 5fdb74866e
commit 05b99e21dc
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/models/index.js
View File

@ -59,7 +59,7 @@ redis.initializeStreams = async () => {
// Create transcriptions streams consumer group // Create transcriptions streams consumer group
try { 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)"); console.log("Created consumer group: mtf-devices (communication)");
} catch (err) { } catch (err) {
@ -75,7 +75,7 @@ redis.initializeStreams = async () => {
for (const deviceId of deviceIds) { for (const deviceId of deviceIds) {
const groupName = `${deviceId}_group`; const groupName = `${deviceId}_group`;
try { 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)`); console.log(`Created consumer group: ${groupName} (communication)`);
} catch (err) { } catch (err) {
if (err.message.includes('BUSYGROUP')) { if (err.message.includes('BUSYGROUP')) {
@ -87,7 +87,7 @@ redis.initializeStreams = async () => {
} }
console.log("Streams initialized successfully"); console.log("Streams initialized successfully");
await client.quit(); await redis.client.quit();
} catch (err) { } catch (err) {
console.error("Error initializing streams:", err.message); console.error("Error initializing streams:", err.message);
} }