feat: change order of adding error handler and connecting functions i…

…n redis client
paralect · Dec 14, 2023 · 7c7025f · 7c7025f
1 parent cef3ccd
commit 7c7025f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/template/apps/api/src/io-emitter.ts b/template/apps/api/src/io-emitter.ts
@@ -20,10 +20,10 @@ const publish = (roomId: string | string[], eventName: string, data: unknown) =>
 const initClient = async () => {
   const subClient = redisClient.duplicate();
 
-  subClient.on('error', redisErrorHandler);
-
   await subClient.connect();
 
+  subClient.on('error', redisErrorHandler);
+
   emitter = new Emitter(subClient);
 };
 

diff --git a/template/apps/api/src/services/socket/socket.service.ts b/template/apps/api/src/services/socket/socket.service.ts
@@ -16,11 +16,12 @@ export default async (server: http.Server) => {
 
   const subClient = pubClient.duplicate();
 
-  subClient.on('error', redisErrorHandler);
-
   await Promise.all([pubClient.connect(), subClient.connect()]);
+
   logger.info('Socket.io server has been connected.');
 
+  subClient.on('error', redisErrorHandler);
+
   io.adapter(createAdapter(pubClient, subClient));
 
   io.use(async (socket, next) => {