pass connection options

Author: ArtemHoruzhenko

redisinsight/api/src/modules/database/database.service.ts

@@ -23,7 +23,7 @@ import { ExportDatabase } from 'src/modules/database/models/export-database';
 import { deepMerge } from 'src/common/utils';
 import { CaCertificate } from 'src/modules/certificate/models/ca-certificate';
 import { ClientCertificate } from 'src/modules/certificate/models/client-certificate';
-import { RedisClientFactory } from 'src/modules/redis/redis.client.factory';
+import { IRedisConnectionOptions, RedisClientFactory } from 'src/modules/redis/redis.client.factory';
 import { RedisClientStorage } from 'src/modules/redis/redis.client.storage';
 
 @Injectable()
@@ -149,15 +149,25 @@ export class DatabaseService {
    * @param sessionMetadata
    * @param dto
    * @param uniqueCheck
+   * @param options
    */
-  async create(sessionMetadata: SessionMetadata, dto: CreateDatabaseDto, uniqueCheck = false): Promise<Database> {
+  async create(
+    sessionMetadata: SessionMetadata,
+    dto: CreateDatabaseDto,
+    uniqueCheck = false,
+    options: IRedisConnectionOptions = {},
+  ): Promise<Database> {
     try {
       this.logger.log('Creating new database.');
 
       const database = await this.repository.create(
         sessionMetadata,
         {
-          ...await this.databaseFactory.createDatabaseModel(sessionMetadata, classToClass(Database, dto)),
+          ...await this.databaseFactory.createDatabaseModel(
+            sessionMetadata,
+            classToClass(Database, dto),
+            options,
+          ),
           new: true,
         },
         uniqueCheck,

redisinsight/api/src/modules/database/providers/database.factory.ts

@@ -9,7 +9,7 @@ import { DatabaseInfoProvider } from 'src/modules/database/providers/database-in
 import { RedisErrorCodes } from 'src/constants';
 import { CaCertificateService } from 'src/modules/certificate/ca-certificate.service';
 import { ClientCertificateService } from 'src/modules/certificate/client-certificate.service';
-import { RedisClientFactory } from 'src/modules/redis/redis.client.factory';
+import { IRedisConnectionOptions, RedisClientFactory } from 'src/modules/redis/redis.client.factory';
 import {
   discoverClusterNodes, discoverSentinelMasterGroups, isCluster, isSentinel,
 } from 'src/modules/redis/utils';
@@ -28,9 +28,15 @@ export class DatabaseFactory {
 
   /**
    * Create model
+   * @param sessionMetadata
    * @param database
+   * @param options
    */
-  async createDatabaseModel(sessionMetadata: SessionMetadata, database: Database): Promise<Database> {
+  async createDatabaseModel(
+    sessionMetadata: SessionMetadata,
+    database: Database,
+    options: IRedisConnectionOptions = {},
+  ): Promise<Database> {
     let model = await this.createStandaloneDatabaseModel(database);
 
     const client = await this.redisClientFactory.getConnectionStrategy().createStandaloneClient(
@@ -40,7 +46,7 @@ export class DatabaseFactory {
         context: ClientContext.Common,
       },
       database,
-      { useRetry: true },
+      { ...options, useRetry: true },
     );
 
     if (!HostingProvider[model.provider]) {

redisinsight/api/src/modules/redis-sentinel/redis-sentinel.service.ts

@@ -84,6 +84,8 @@ export class RedisSentinelService {
                 password,
               },
             } as Database,
+            undefined,
+            { enableReadyCheck: false },
           );
 
           result.push({