diff --git a/index.js b/index.js index 187cda7..78a31b5 100644 --- a/index.js +++ b/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 } \ No newline at end of file