@@ -56,12 +56,12 @@ export class DatabaseAPIRequests {
56
56
requestBody . verifyServerCert = false ;
57
57
requestBody . caCert = {
58
58
name : `ca}-${ uniqueId } ` ,
59
- certificate : databaseParameters . caCert . certificate ,
59
+ certificate : databaseParameters . caCert . certificate
60
60
} ;
61
61
requestBody . clientCert = {
62
62
name : `client}-${ uniqueId } ` ,
63
63
certificate : databaseParameters . clientCert ! . certificate ,
64
- key : databaseParameters . clientCert ! . key ,
64
+ key : databaseParameters . clientCert ! . key
65
65
} ;
66
66
}
67
67
const response = await sendPostRequest (
@@ -85,7 +85,7 @@ export class DatabaseAPIRequests {
85
85
databasesParameters : AddNewDatabaseParameters [ ]
86
86
) : Promise < void > {
87
87
if ( databasesParameters . length ) {
88
- databasesParameters . forEach ( async ( parameter ) => {
88
+ databasesParameters . forEach ( async ( parameter ) => {
89
89
await this . addNewStandaloneDatabaseApi ( parameter ) ;
90
90
} ) ;
91
91
}
@@ -101,7 +101,7 @@ export class DatabaseAPIRequests {
101
101
const requestBody = {
102
102
name : databaseParameters . ossClusterDatabaseName ,
103
103
host : databaseParameters . ossClusterHost ,
104
- port : Number ( databaseParameters . ossClusterPort ) ,
104
+ port : Number ( databaseParameters . ossClusterPort )
105
105
} ;
106
106
const response = await sendPostRequest (
107
107
ResourcePath . Databases ,
@@ -133,7 +133,7 @@ export class DatabaseAPIRequests {
133
133
host : databaseParameters . sentinelHost ,
134
134
port : Number ( databaseParameters . sentinelPort ) ,
135
135
password : databaseParameters . sentinelPassword ,
136
- masters : masters ,
136
+ masters : masters
137
137
} ;
138
138
const resourcePath =
139
139
ResourcePath . RedisSentinel + ResourcePath . Databases ;
@@ -164,7 +164,7 @@ export class DatabaseAPIRequests {
164
164
const allDataBases = await this . getAllDatabases ( ) ;
165
165
const response = await asyncFilter (
166
166
allDataBases ,
167
- async ( item : databaseParameters ) => {
167
+ async ( item : databaseParameters ) => {
168
168
await doAsyncStuff ( ) ;
169
169
return item . name === databaseName ;
170
170
}
@@ -190,12 +190,12 @@ export class DatabaseAPIRequests {
190
190
let response : databaseParameters [ ] = [ ] ;
191
191
response = await asyncFilter (
192
192
allDataBases ,
193
- async ( item : databaseParameters ) => {
193
+ async ( item : databaseParameters ) => {
194
194
await doAsyncStuff ( ) ;
195
195
return item . connectionType === connectionType ;
196
196
}
197
197
) ;
198
- return response [ 0 ] . id ;
198
+ return response ?. [ 0 ] ? .id ;
199
199
}
200
200
201
201
/**
@@ -217,6 +217,7 @@ export class DatabaseAPIRequests {
217
217
) ;
218
218
await t . expect ( await response . status ) . eql ( 200 ) ;
219
219
}
220
+ await this . deleteAllDatabasesByConnectionTypeApi ( 'SENTINEL' ) ;
220
221
}
221
222
}
222
223
@@ -237,7 +238,8 @@ export class DatabaseAPIRequests {
237
238
requestBody
238
239
) ;
239
240
await t . expect ( await response . status ) . eql ( 200 ) ;
240
- } else {
241
+ }
242
+ else {
241
243
throw new Error ( 'Error: Missing databaseId' ) ;
242
244
}
243
245
}
@@ -249,7 +251,7 @@ export class DatabaseAPIRequests {
249
251
async deleteStandaloneDatabasesByNamesApi (
250
252
databaseNames : string [ ]
251
253
) : Promise < void > {
252
- databaseNames . forEach ( async ( databaseName ) => {
254
+ databaseNames . forEach ( async ( databaseName ) => {
253
255
const databaseId = await this . getDatabaseIdByName ( databaseName ) ;
254
256
if ( databaseId ) {
255
257
const requestBody = { ids : [ `${ databaseId } ` ] } ;
@@ -258,7 +260,8 @@ export class DatabaseAPIRequests {
258
260
requestBody
259
261
) ;
260
262
await t . expect ( await response . status ) . eql ( 200 ) ;
261
- } else {
263
+ }
264
+ else {
262
265
throw new Error ( 'Error: Missing databaseId' ) ;
263
266
}
264
267
} ) ;
@@ -311,12 +314,14 @@ export class DatabaseAPIRequests {
311
314
const databaseIds = await this . getDatabaseByConnectionType (
312
315
connectionType
313
316
) ;
314
- const requestBody = { ids : [ `${ databaseIds } ` ] } ;
315
- const response = await sendDeleteRequest (
316
- ResourcePath . Databases ,
317
- requestBody
318
- ) ;
319
- await t . expect ( await response . status ) . eql ( 200 ) ;
317
+ if ( databaseIds ?. length > 0 ) {
318
+ const requestBody = { ids : [ `${ databaseIds } ` ] } ;
319
+ const response = await sendDeleteRequest (
320
+ ResourcePath . Databases ,
321
+ requestBody
322
+ ) ;
323
+ await t . expect ( await response . status ) . eql ( 200 ) ;
324
+ }
320
325
}
321
326
322
327
/**
@@ -327,7 +332,7 @@ export class DatabaseAPIRequests {
327
332
databasesParameters : AddNewDatabaseParameters [ ]
328
333
) : Promise < void > {
329
334
if ( databasesParameters . length ) {
330
- databasesParameters . forEach ( async ( parameter ) => {
335
+ databasesParameters . forEach ( async ( parameter ) => {
331
336
await this . deleteStandaloneDatabaseApi ( parameter ) ;
332
337
} ) ;
333
338
}
@@ -344,7 +349,7 @@ export class DatabaseAPIRequests {
344
349
databaseParameters . ossClusterDatabaseName
345
350
) ;
346
351
const resourcePath =
347
- ResourcePath . Databases + ` /${ databaseId } ` + ResourcePath . ClusterDetails ;
352
+ ` ${ ResourcePath . Databases } /${ databaseId } ${ ResourcePath . ClusterDetails } ` ;
348
353
const response = await sendGetRequest ( resourcePath ) ;
349
354
350
355
await t . expect ( await response . status ) . eql ( 200 ) ;
0 commit comments