feat: add support for redis sentinel

package.json

@@ -43,6 +43,7 @@
     "@semantic-release/release-notes-generator": "^9.0.1",
     "@types/bull": "^3.15.0",
     "@types/express": "^4.17.8",
+    "@types/ioredis": "^4.22.1",
     "@types/jest": "^26.0.15",
     "@types/node": "^14.14.6",
     "@typescript-eslint/eslint-plugin": "^4.6.1",

src/app.module.ts

@@ -1,6 +1,7 @@
 import { BullModule } from '@nestjs/bull';
 import { Module } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
+import IORedis from 'ioredis';
 import configuration, { QueueConfig } from './common/config/configuration';
 import { validation } from './common/config/validation';
 import { ScheamaModule } from './schema/schema.module';
@@ -19,12 +20,28 @@ import { ScheamaModule } from './schema/schema.module';
       useFactory: (configService: ConfigService) => {
         const queueConfig = configService.get<QueueConfig>('queue');
 
-        return {
-          redis: {
+        let redisConfig: IORedis.RedisOptions;
+
+        if (queueConfig.isSentinel) {
+          redisConfig = {
+            sentinels: [
+              {
+                host: queueConfig.host,
+                port: queueConfig.port,
+              },
+            ],
+            name: queueConfig.set,
+          };
+        } else {
+          redisConfig = {
             host: queueConfig.host,
             port: queueConfig.port,
             password: queueConfig.password,
-          },
+          };
+        }
+
+        return {
+          redis: redisConfig,
           prefix: 'bull',
         };
       },

src/common/config/configuration.ts

@@ -9,18 +9,22 @@ export interface Services {
 }
 
 export interface QueueConfig {
+  isSentinel: boolean;
   host: string;
   port: number;
-  password: string;
+  password?: string;
+  set?: string;
 }
 
 export default (): Config => {
   return {
     steamApiKey: process.env.STEAM_API_KEY,
     queue: {
+      isSentinel: process.env.QUEUE_IS_SENTINEL === 'true',
       host: process.env.QUEUE_HOST,
       port: parseInt(process.env.QUEUE_PORT, 10),
       password: process.env.QUEUE_PASSWORD,
+      set: process.env.QUEUE_SET,
     },
     services: {
       schema: process.env.SCHEMA_SERVICE_URL,

src/common/config/validation.ts

@@ -3,9 +3,11 @@ import * as Joi from 'joi';
 const validation = Joi.object({
   NODE_ENV: Joi.string().valid('development', 'production', 'test').required(),
   STEAM_API_KEY: Joi.string().required(),
+  QUEUE_IS_SENTINEL: Joi.boolean().optional(),
   QUEUE_HOST: Joi.string().required(),
   QUEUE_PORT: Joi.number().required(),
-  QUEUE_PASSWORD: Joi.string().required(),
+  QUEUE_PASSWORD: Joi.string().optional(),
+  QUEUE_SET: Joi.string().optional(),
   SCHEMA_SERVICE_URL: Joi.string().required(),
 });