#RI-3942 - workaround determine only on first shard

Author: AmirAllayarovSofteq

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

@@ -3,6 +3,7 @@ import { IFindRedisClientInstanceByOptions } from 'src/modules/redis/redis.servi
 import { isNull, flatten, uniqBy } from 'lodash';
 import { RecommendationService } from 'src/modules/recommendation/recommendation.service';
 import { catchAclError } from 'src/utils';
+import { RECOMMENDATION_NAMES } from 'src/constants';
 import { DatabaseAnalyzer } from 'src/modules/database-analysis/providers/database-analyzer';
 import { plainToClass } from 'class-transformer';
 import { DatabaseAnalysis, ShortDatabaseAnalysis } from 'src/modules/database-analysis/models';
@@ -58,11 +59,13 @@ export class DatabaseAnalysisService {
 
       const recommendations = DatabaseAnalysisService.getRecommendationsSummary(
         flatten(await Promise.all(
-          scanResults.map(async (nodeResult) => (
+          scanResults.map(async (nodeResult, idx) => (
             await this.recommendationService.getRecommendations({
               client: nodeResult.client,
               keys: nodeResult.keys,
               total: progress.total,
+              // TODO: create generic solution to exclude recommendations
+              exclude: idx !== 0 ? [RECOMMENDATION_NAMES.RTS] : [],
             })
           )),
         )),

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

@@ -2,6 +2,7 @@ import { Injectable } from '@nestjs/common';
 import { Redis } from 'ioredis';
 import { RecommendationProvider } from 'src/modules/recommendation/providers/recommendation.provider';
 import { Recommendation } from 'src/modules/database-analysis/models/recommendation';
+import { RECOMMENDATION_NAMES } from 'src/constants';
 import { RedisString } from 'src/common/constants';
 import { Key } from 'src/modules/database-analysis/models';
 
@@ -10,6 +11,7 @@ interface RecommendationInput {
   keys?: Key[],
   info?: RedisString,
   total?: number,
+  exclude?: string[],
 }
 
 @Injectable()
@@ -31,6 +33,7 @@ export class RecommendationService {
       keys,
       info,
       total,
+      exclude,
     } = dto;
 
     return (
@@ -49,7 +52,8 @@ export class RecommendationService {
         await this.recommendationProvider.determineBigSetsRecommendation(keys),
         await this.recommendationProvider.determineConnectionClientsRecommendation(client),
         await this.recommendationProvider.determineSetPasswordRecommendation(client),
-        await this.recommendationProvider.determineRTSRecommendation(client, keys),
+        // TODO rework, need better solution to do not start determine recommendation
+        exclude.includes(RECOMMENDATION_NAMES.RTS) ? null : await this.recommendationProvider.determineRTSRecommendation(client, keys),
       ]));
   }
 }