Skip to content

Commit b02beea

Browse files
author
Artem
committed
rollback CircleCI configs + fix PR comments + fix bug when unable to descover sentinel databases with existing certs
1 parent 6f8868f commit b02beea

File tree

4 files changed

+16
-17
lines changed

4 files changed

+16
-17
lines changed

.circleci/config.yml

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -896,11 +896,10 @@ workflows:
896896
matrix:
897897
alias: itest-code
898898
parameters:
899-
# rte: *iTestsNamesShort
900-
rte: *iTestsNames
899+
rte: *iTestsNamesShort
901900
name: ITest - << matrix.rte >> (code)
902-
# requires:
903-
# - UTest - API
901+
requires:
902+
- UTest - API
904903
# E2E tests for "e2e/feature" or "e2e/bugfix" branches only
905904
e2e-tests:
906905
jobs:

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

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,6 @@ export class DatabaseImportService {
9090
fail: [],
9191
};
9292

93-
console.log('___ items', items);
94-
9593
// it is very important to insert databases on-by-one to avoid db constraint errors
9694
await items.reduce((prev, item, index) => prev.finally(() => this.createDatabase(item, index)
9795
.then((result) => {
@@ -260,16 +258,9 @@ export class DatabaseImportService {
260258
*/
261259
static determineConnectionType(data: any = {}): ConnectionType {
262260
if (data?.connectionType) {
263-
switch (data.connectionType) {
264-
case ConnectionType.CLUSTER:
265-
return ConnectionType.CLUSTER;
266-
case ConnectionType.SENTINEL:
267-
return ConnectionType.SENTINEL;
268-
case ConnectionType.STANDALONE:
269-
return ConnectionType.STANDALONE;
270-
default:
271-
return ConnectionType.NOT_CONNECTED;
272-
}
261+
return (data.connectionType in ConnectionType)
262+
? ConnectionType[data.connectionType]
263+
: ConnectionType.NOT_CONNECTED;
273264
}
274265

275266
if (data?.type) {

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ import { BadRequestException } from '@nestjs/common';
33
import ERROR_MESSAGES from 'src/constants/error-messages';
44
import { RedisService } from 'src/modules/redis/redis.service';
55
import {
6+
mockDatabaseFactory,
67
mockDatabaseInfoProvider,
78
mockDatabaseService,
89
mockIORedisClient,
@@ -15,6 +16,7 @@ import { RedisSentinelService } from 'src/modules/redis-sentinel/redis-sentinel.
1516
import { RedisSentinelAnalytics } from 'src/modules/redis-sentinel/redis-sentinel.analytics';
1617
import { DatabaseService } from 'src/modules/database/database.service';
1718
import { DatabaseInfoProvider } from 'src/modules/database/providers/database-info.provider';
19+
import { DatabaseFactory } from 'src/modules/database/providers/database.factory';
1820

1921
describe('RedisSentinelService', () => {
2022
let service: RedisSentinelService;
@@ -38,6 +40,10 @@ describe('RedisSentinelService', () => {
3840
provide: DatabaseService,
3941
useFactory: mockDatabaseService,
4042
},
43+
{
44+
provide: DatabaseFactory,
45+
useFactory: mockDatabaseFactory,
46+
},
4147
{
4248
provide: DatabaseInfoProvider,
4349
useFactory: mockDatabaseInfoProvider,

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ import { getRedisConnectionException } from 'src/utils';
1212
import { SentinelMaster } from 'src/modules/redis-sentinel/models/sentinel-master';
1313
import { RedisSentinelAnalytics } from 'src/modules/redis-sentinel/redis-sentinel.analytics';
1414
import { DatabaseInfoProvider } from 'src/modules/database/providers/database-info.provider';
15+
import { DatabaseFactory } from 'src/modules/database/providers/database.factory';
1516

1617
@Injectable()
1718
export class RedisSentinelService {
@@ -20,6 +21,7 @@ export class RedisSentinelService {
2021
constructor(
2122
private readonly redisService: RedisService,
2223
private readonly databaseService: DatabaseService,
24+
private readonly databaseFactory: DatabaseFactory,
2325
private readonly databaseInfoProvider: DatabaseInfoProvider,
2426
private readonly redisSentinelAnalytics: RedisSentinelAnalytics,
2527
) {}
@@ -113,7 +115,8 @@ export class RedisSentinelService {
113115
this.logger.log('Connection and getting sentinel masters.');
114116
let result: SentinelMaster[];
115117
try {
116-
const client = await this.redisService.createStandaloneClient(dto, AppTool.Common, false);
118+
const database = await this.databaseFactory.createStandaloneDatabaseModel(dto);
119+
const client = await this.redisService.createStandaloneClient(database, AppTool.Common, false);
117120
result = await this.databaseInfoProvider.determineSentinelMasterGroups(client);
118121
this.redisSentinelAnalytics.sendGetSentinelMastersSucceedEvent(result);
119122

0 commit comments

Comments
 (0)