From cc8fe46ad2ac54b691aeb0fa73fbb419bfe5a46c Mon Sep 17 00:00:00 2001
From: Nour Alharithi <nour.alharithi@gmail.com>
Date: Fri, 27 Oct 2023 17:09:19 -0700
Subject: [PATCH] ws manager uses password

---
 package.json               |  2 +-
 src/wsConnectionManager.ts | 13 ++++++++++++-
 2 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/package.json b/package.json
index 535cd2f..2458e73 100644
--- a/package.json
+++ b/package.json
@@ -50,7 +50,7 @@
     "start": "node lib/index.js",
     "dev": "ts-node src/index.ts",
     "ws-publish": "ts-node src/wsPublish.ts",
-    "manager": "ts-node src/wsConnectionManager.ts",
+    "ws-manager": "ts-node src/wsConnectionManager.ts",
     "dev:inspect": "yarn build && node --inspect ./lib/index.js",
     "dev:debug": "yarn build && node --inspect-brk --inspect=2230 ./lib/index.js",
     "example": "ts-node example/client.ts",
diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts
index 1faf185..efa8afa 100644
--- a/src/wsConnectionManager.ts
+++ b/src/wsConnectionManager.ts
@@ -16,9 +16,10 @@ const io = new Server(server);
 
 const REDIS_HOST = process.env.REDIS_HOST || 'localhost';
 const REDIS_PORT = process.env.REDIS_PORT || '6379';
+const REDIS_PASSWORD = process.env.REDIS_PASSWORD;
 
 async function main() {
-	const redisClient = new RedisClient(REDIS_HOST, REDIS_PORT);
+	const redisClient = new RedisClient(REDIS_HOST, REDIS_PORT, REDIS_PASSWORD);
 	await redisClient.connect();
 
 	io.on('connection', (socket) => {
@@ -31,6 +32,16 @@ async function main() {
 				}
 			});
 		});
+
+		socket.on('unsubscribe', (channel) => {
+			console.log('Unsubscribing from channel', channel);
+			redisClient.client.unsubscribe(channel);
+		});
+
+		socket.on('disconnect', () => {
+			console.log('Client disconnected');
+		});
+
 	});
 
 	server.listen('3000', () => {