diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts index cf99b7d..7799b9c 100644 --- a/src/wsConnectionManager.ts +++ b/src/wsConnectionManager.ts @@ -164,11 +164,6 @@ async function main() { .subscribe(redisChannel) .then(() => { subscribedChannels.add(redisChannel); - ws.send( - JSON.stringify({ - message: `Subscribe received for channel: ${parsedMessage.channel}, market: ${parsedMessage.market}, marketType: ${parsedMessage.marketType}`, - }) - ); }) .catch(() => { ws.send( @@ -186,6 +181,11 @@ async function main() { } channelSubscribers.get(redisChannel).add(ws); + ws.send( + JSON.stringify({ + message: `Subscribe received for channel: ${parsedMessage.channel}, market: ${parsedMessage.market}, marketType: ${parsedMessage.marketType}`, + }) + ); // Fetch and send last message if (redisChannel.includes('orderbook')) { const lastUpdateChannel = `last_update_${redisChannel}`;