From acdeef1b9f7afb979021c7bc645980170768bd21 Mon Sep 17 00:00:00 2001
From: Nour Alharithi <nour.alharithi@gmail.com>
Date: Fri, 19 Jan 2024 14:34:09 -0800
Subject: [PATCH] ack-bug-fix

---
 src/wsConnectionManager.ts | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

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}`;