Fix websocket msg serialisation

Signed-off-by: Brian Evans <ebrian101@gmail.com>
mrbrianevans · Oct 5, 2023 · 37618df · 37618df
1 parent 6599d49
commit 37618df
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/redis/streamFromRedis.ts b/server/src/redis/streamFromRedis.ts
@@ -182,7 +182,7 @@ const eventStream = listenRedisStream({ streamKeys: [...streamPaths].map(stream
 for await(const event of eventStream) {
   const streamPath = event.stream.split(":")[1]
   let parsedEvent = JSON.parse(event.data.event)
-  app.server?.publish(streamPath, { streamPath, ...parsedEvent })
+  app.server?.publish(streamPath, JSON.stringify({ streamPath, ...parsedEvent }))
   if (streamPath === "companies")
     await saveCompanyNumber(counterClient, parsedEvent, streamPath)
       .catch(e => logger.error(e, "Error saving company number"))