From 6e6b961816691461a918f5e2c3dc4ea850d46e40 Mon Sep 17 00:00:00 2001 From: Apher Date: Fri, 3 Jul 2026 06:00:47 +0000 Subject: [PATCH] Fix typo, wrong variable and remove redis connection control in method --- src/server.js | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/src/server.js b/src/server.js index 0ef4f80..3314c9a 100644 --- a/src/server.js +++ b/src/server.js @@ -10,9 +10,7 @@ const config = require("./config"); // Send Speech to Text to Redis Stream const sendTranscriptEvent = async (streamKey, type, text) => { - await redis.client.connect().catch(console.error); - - await redis.xAdd( + await redis.client.xAdd( streamKey, '*', { @@ -21,8 +19,6 @@ const sendTranscriptEvent = async (streamKey, type, text) => { } ) - await redis.client.quit(); - console.log("Transcript added to stream"); } @@ -30,7 +26,7 @@ const sendTranscriptEvent = async (streamKey, type, text) => { const processor = async (group, consumer, streamKey) => { await redis.client.connect().catch(console.error); - sendTranscriptEvent(streamKey, "TEST", "TEST"); + sendTranscriptEvent("speech:events", "TEST", "TEST"); while (true) { const res = await redis.client.xReadGroup(