Merge branch 'master' into 'development'

reactive sentinel en develop

See merge request !22

src/health/redis.healthIndicator.ts

@@ -7,7 +7,12 @@ export class RedisHealthIndicator extends HealthIndicator {
 
   async checkRedisConnection(redisConf: { sentinelHost: string, sentinelPort: number, groupName: string; }): Promise<HealthIndicatorResult> {
 
-    const client = new IORedis({ host: redisConf.sentinelHost, port: redisConf.sentinelPort});
+    const client = new IORedis({
+      sentinels: [
+        { host: redisConf.sentinelHost, port: redisConf.sentinelPort },
+      ],
+      name: redisConf.groupName,
+    });
 
     await new Promise((resolve, reject) => {
       client.on('ready', resolve);
@@ -28,4 +33,4 @@ export class RedisHealthIndicator extends HealthIndicator {
 
     return this.getStatus('Redis', true);
   }
-}
+}
\ No newline at end of file

src/helpers/redis.helper.ts

@@ -13,7 +13,16 @@ export class Redis {
     Logger.log(`Entering function`, `Redis.connect`);
     let cfg:any={
         host: this.redisConfig.sentinelHost, port: this.redisConfig.sentinelPort ,
+        name: this.redisConfig.groupName,
     };
+    if(this.redisConfig.sentinel){
+      cfg={
+          sentinels: [
+            { host: this.redisConfig.sentinelHost, port: this.redisConfig.sentinelPort },
+          ],
+          name: this.redisConfig.groupName,
+      };
+    }
 
     const client = new IORedis(cfg);
 
@@ -94,4 +103,4 @@ export class Redis {
       handleError(error, new InternalServerErrorException('Couldn\'t remove key/value in redis.'));
     }
   }
-}
+}
\ No newline at end of file