attach ts and send ack on subscribe

2024-01-19 12:37:49 -08:00
parent 207521e95c
commit fe19c821af
3 changed files with 15 additions and 5 deletions
--- a/src/wsConnectionManager.ts
+++ b/src/wsConnectionManager.ts
@@ -164,12 +164,16 @@ 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(
 									JSON.stringify({
-										redisChannel,
-										error: `Error subscribing to channel: ${redisChannel}`,
+										error: `Error subscribing to channel: ${parsedMessage}`,
 									})
 								);
 								return;
@@ -198,6 +202,7 @@ async function main() {
 							);
 						}
 					}
+
 					break;
 				}
 				case 'unsubscribe': {