From a24757f3740986a58de3d7ee6d44033c64a8a852 Mon Sep 17 00:00:00 2001 From: Luke Steyn Date: Wed, 22 Nov 2023 15:49:51 +0100 Subject: [PATCH] Added handling for last_update messages --- src/wsConnectionManager.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts index 226cb89..cb383aa 100644 --- a/src/wsConnectionManager.ts +++ b/src/wsConnectionManager.ts @@ -166,12 +166,17 @@ async function main() { // Fetch and send last message if (redisChannel.includes('orderbook')) { + const lastUpdateChannel = `last_update_${redisChannel}`; const lastMessage = await lastMessageRetriever.client.get( - `last_update_${redisChannel}` + lastUpdateChannel ); + if (lastMessage !== null) { ws.send( - JSON.stringify({ channel: redisChannel, data: lastMessage }) + JSON.stringify({ + channel: lastUpdateChannel, + data: lastMessage, + }) ); } }