feat: add improvements for handling redis errors

paralect · Dec 13, 2023 · cef3ccd · cef3ccd
1 parent 4a65e8e
commit cef3ccd
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 19 deletions.
diff --git a/template/apps/api/src/app.ts b/template/apps/api/src/app.ts
@@ -21,6 +21,8 @@ import { socketService } from 'services';
 import config from 'config';
 import logger from 'logger';
 import routes from 'routes';
+
+import { redisErrorHandler } from 'redis-client';
 import ioEmitter from 'io-emitter';
 
 const initKoa = () => {
@@ -49,10 +51,16 @@ const app = initKoa();
 (async () => {
  const server = http.createServer(app.callback());
 
- await Promise.all([
- ioEmitter.initClient(),
- socketService(server),
- ]);
+ if (config.REDIS_URI) {
+ try {
+ await Promise.all([
+ ioEmitter.initClient(),
+ socketService(server),
+ ]);
+ } catch (e) {
+ if (e instanceof Error) redisErrorHandler(e);
+ }
+ }
 
  server.listen(config.PORT, () => {
  logger.info(`API server is listening on ${config.PORT}, in ${config.APP_ENV} environment`);

diff --git a/template/apps/api/src/io-emitter.ts b/template/apps/api/src/io-emitter.ts
@@ -1,20 +1,15 @@
 import { Emitter } from '@socket.io/redis-emitter';
 
-import redisClient from 'redis-client';
+import redisClient, { redisErrorHandler } from 'redis-client';
 import logger from 'logger';
 
-import config from './config';
-
 let emitter: Emitter | null = null;
 
 const publish = (roomId: string | string[], eventName: string, data: unknown) => {
  if (emitter === null) {
- if (config.REDIS_ERRORS_POLICY === 'throw') {
- throw new Error('ioEmitter is not initialized.');
- } else {
- logger.debug('ioEmitter is not initialized.');
- return;
- }
+ redisErrorHandler(new Error('ioEmitter is not initialized.'));
+
+ return;
  }
 
  logger.debug(`published io event [${eventName}] to ${roomId}, the data is: ${JSON.stringify(data)}`);
@@ -24,6 +19,9 @@ const publish = (roomId: string | string[], eventName: string, data: unknown) =>
 
 const initClient = async () => {
  const subClient = redisClient.duplicate();
+
+ subClient.on('error', redisErrorHandler);
+
  await subClient.connect();
 
  emitter = new Emitter(subClient);

diff --git a/template/apps/api/src/redis-client.ts b/template/apps/api/src/redis-client.ts
@@ -10,21 +10,23 @@ const client = createClient({
  connectTimeout: 30_000,
  reconnectStrategy: (retries) => {
  const maxDelay = 5_000;
- const baseDelay = 50;
+ const baseDelay = 1_000;
 
  return Math.min(baseDelay * Math.pow(2, retries), maxDelay);
  },
  },
 });
 
-client.on('error', err => {
- const errorMessage = `redisClient => Redis error: ${err.stack || err}`;
+export const redisErrorHandler = (error: Error) => {
+ const errorMessage = `[Redis Client] ${error.stack || error}`;
 
  if (config.REDIS_ERRORS_POLICY === 'throw') {
- throw Error(errorMessage);
+ throw new Error(errorMessage);
  } else {
  logger.error(errorMessage);
  }
-});
+};
+
+client.on('error', redisErrorHandler);
 
 export default client;
diff --git a/template/apps/api/src/services/socket/socket.service.ts b/template/apps/api/src/services/socket/socket.service.ts
@@ -6,7 +6,7 @@ import { COOKIES } from 'app-constants';
 
 import { tokenService } from 'resources/token';
 
-import pubClient from 'redis-client';
+import pubClient, { redisErrorHandler } from 'redis-client';
 import logger from 'logger';
 
 import socketHelper from './socket.helper';
@@ -16,6 +16,8 @@ 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.');