add sendTranscriptEvent

index.js

@@ -31,6 +31,19 @@ redis.ensureGroup = async (stream, group) => {
     }
 }
 
+redis.sendTranscriptEvent = async (streamKey, device_id, text) => {
+    try {
+        await redis.client.xAdd(streamKey, "*", {
+            text,
+            device_id: device_id,
+        });
+
+        console.log("Transcript added to stream");
+    } catch (err) {
+        console.error(err);
+    }
+}
+
 module.exports = {
     redis
 }