1
1
import { createClient } from 'redis' ;
2
2
import { t } from 'testcafe' ;
3
3
import { Chance } from 'chance' ;
4
- import { COMMANDS_TO_CREATE_KEY } from '../helpers/constants ' ;
5
- import { BrowserPage , CliPage } from '../pageObjects' ;
4
+ import { random } from 'lodash ' ;
5
+ import { BrowserPage } from '../pageObjects' ;
6
6
import { KeyData , AddKeyArguments } from '../pageObjects/browser-page' ;
7
- import { KeyTypesTexts } from './constants' ;
7
+ import { COMMANDS_TO_CREATE_KEY , KeyTypesTexts } from './constants' ;
8
8
import { Common } from './common' ;
9
- import { random } from 'lodash' ;
10
9
11
10
const common = new Common ( ) ;
12
- const cliPage = new CliPage ( ) ;
13
11
const browserPage = new BrowserPage ( ) ;
14
12
15
13
export function getRandomKeyName ( keyNameLength : number ) : string {
@@ -49,17 +47,17 @@ export const keyTypes = [
49
47
* @param keyField The key field value
50
48
*/
51
49
export async function addKeysViaCli ( keyData : KeyData , keyValue ?: string , keyField ?: string ) : Promise < void > {
52
- await t . click ( cliPage . cliExpandButton ) ;
50
+ await t . click ( browserPage . Cli . cliExpandButton ) ;
53
51
for ( const { textType, keyName } of keyData ) {
54
52
if ( textType in COMMANDS_TO_CREATE_KEY ) {
55
53
textType === 'Hash' || textType === 'Stream'
56
- ? await t . typeText ( cliPage . cliCommandInput , COMMANDS_TO_CREATE_KEY [ textType ] ( keyName , keyValue , keyField ) , { paste : true } )
57
- : await t . typeText ( cliPage . cliCommandInput , COMMANDS_TO_CREATE_KEY [ textType ] ( keyName , keyValue ) , { paste : true } ) ;
54
+ ? await t . typeText ( browserPage . Cli . cliCommandInput , COMMANDS_TO_CREATE_KEY [ textType ] ( keyName , keyValue , keyField ) , { paste : true } )
55
+ : await t . typeText ( browserPage . Cli . cliCommandInput , COMMANDS_TO_CREATE_KEY [ textType ] ( keyName , keyValue ) , { paste : true } ) ;
58
56
await t . pressKey ( 'enter' ) ;
59
57
}
60
58
}
61
59
await t
62
- . click ( cliPage . cliCollapseButton )
60
+ . click ( browserPage . Cli . cliCollapseButton )
63
61
. click ( browserPage . refreshKeysButton ) ;
64
62
}
65
63
@@ -72,7 +70,7 @@ export async function deleteKeysViaCli(keyData: KeyData): Promise<void> {
72
70
for ( const { keyName } of keyData ) {
73
71
keys . push ( keyName ) ;
74
72
}
75
- await cliPage . sendCommandInCli ( `DEL ${ keys . join ( ' ' ) } ` ) ;
73
+ await browserPage . Cli . sendCommandInCli ( `DEL ${ keys . join ( ' ' ) } ` ) ;
76
74
}
77
75
78
76
/**
@@ -85,14 +83,14 @@ export async function populateDBWithHashes(host: string, port: string, keyArgume
85
83
const dbConf = { port : Number . parseInt ( port ) , host, username : 'default' } ;
86
84
const client = createClient ( dbConf ) ;
87
85
88
- await client . on ( 'error' , async function ( error : string ) {
86
+ await client . on ( 'error' , async function ( error : string ) {
89
87
throw new Error ( error ) ;
90
88
} ) ;
91
- await client . on ( 'connect' , async function ( ) {
92
- if ( keyArguments . keysCount != undefined ) {
89
+ await client . on ( 'connect' , async function ( ) {
90
+ if ( keyArguments . keysCount ) {
93
91
for ( let i = 0 ; i < keyArguments . keysCount ; i ++ ) {
94
92
const keyName = `${ keyArguments . keyNameStartWith } ${ common . generateWord ( 20 ) } ` ;
95
- await client . hset ( [ keyName , 'field1' , 'Hello' ] , async ( error : string ) => {
93
+ await client . hset ( [ keyName , 'field1' , 'Hello' ] , async ( error : string ) => {
96
94
if ( error ) {
97
95
throw error ;
98
96
}
@@ -114,18 +112,18 @@ export async function populateHashWithFields(host: string, port: string, keyArgu
114
112
const client = createClient ( dbConf ) ;
115
113
const fields : string [ ] = [ ] ;
116
114
117
- await client . on ( 'error' , async function ( error : string ) {
115
+ await client . on ( 'error' , async function ( error : string ) {
118
116
throw new Error ( error ) ;
119
117
} ) ;
120
- await client . on ( 'connect' , async function ( ) {
121
- if ( keyArguments . fieldsCount != undefined ) {
118
+ await client . on ( 'connect' , async function ( ) {
119
+ if ( keyArguments . fieldsCount ) {
122
120
for ( let i = 0 ; i < keyArguments . fieldsCount ; i ++ ) {
123
121
const field = `${ keyArguments . fieldStartWith } ${ common . generateWord ( 10 ) } ` ;
124
122
const fieldValue = `${ keyArguments . fieldValueStartWith } ${ common . generateWord ( 10 ) } ` ;
125
123
fields . push ( field , fieldValue ) ;
126
124
}
127
125
}
128
- await client . hset ( keyArguments . keyName , fields , async ( error : string ) => {
126
+ await client . hset ( keyArguments . keyName , fields , async ( error : string ) => {
129
127
if ( error ) {
130
128
throw error ;
131
129
}
@@ -145,17 +143,17 @@ export async function populateListWithElements(host: string, port: string, keyAr
145
143
const client = createClient ( dbConf ) ;
146
144
const elements : string [ ] = [ ] ;
147
145
148
- await client . on ( 'error' , async function ( error : string ) {
146
+ await client . on ( 'error' , async function ( error : string ) {
149
147
throw new Error ( error ) ;
150
148
} ) ;
151
- await client . on ( 'connect' , async function ( ) {
152
- if ( keyArguments . elementsCount != undefined ) {
149
+ await client . on ( 'connect' , async function ( ) {
150
+ if ( keyArguments . elementsCount ) {
153
151
for ( let i = 0 ; i < keyArguments . elementsCount ; i ++ ) {
154
152
const element = `${ keyArguments . elementStartWith } ${ common . generateWord ( 10 ) } ` ;
155
153
elements . push ( element ) ;
156
154
}
157
155
}
158
- await client . lpush ( keyArguments . keyName , elements , async ( error : string ) => {
156
+ await client . lpush ( keyArguments . keyName , elements , async ( error : string ) => {
159
157
if ( error ) {
160
158
throw error ;
161
159
}
@@ -175,17 +173,17 @@ export async function populateSetWithMembers(host: string, port: string, keyArgu
175
173
const client = createClient ( dbConf ) ;
176
174
const members : string [ ] = [ ] ;
177
175
178
- await client . on ( 'error' , async function ( error : string ) {
176
+ await client . on ( 'error' , async function ( error : string ) {
179
177
throw new Error ( error ) ;
180
178
} ) ;
181
- await client . on ( 'connect' , async function ( ) {
182
- if ( keyArguments . membersCount != undefined ) {
179
+ await client . on ( 'connect' , async function ( ) {
180
+ if ( keyArguments . membersCount ) {
183
181
for ( let i = 0 ; i < keyArguments . membersCount ; i ++ ) {
184
182
const member = `${ keyArguments . memberStartWith } ${ common . generateWord ( 10 ) } ` ;
185
183
members . push ( member ) ;
186
184
}
187
185
}
188
- await client . sadd ( keyArguments . keyName , members , async ( error : string ) => {
186
+ await client . sadd ( keyArguments . keyName , members , async ( error : string ) => {
189
187
if ( error ) {
190
188
throw error ;
191
189
}
@@ -200,7 +198,7 @@ export async function populateSetWithMembers(host: string, port: string, keyArgu
200
198
* @param port The port of database
201
199
* @param keyArguments The arguments of key and its members
202
200
*/
203
- export async function populateZSetWithMembers ( host : string , port : string , keyArguments : AddKeyArguments ) : Promise < void > {
201
+ export async function populateZSetWithMembers ( host : string , port : string , keyArguments : AddKeyArguments ) : Promise < void > {
204
202
const dbConf = { port : Number . parseInt ( port ) , host, username : 'default' } ;
205
203
let minScoreValue : - 10 ;
206
204
let maxScoreValue : 10 ;
@@ -211,7 +209,7 @@ export async function populateSetWithMembers(host: string, port: string, keyArgu
211
209
throw new Error ( error ) ;
212
210
} ) ;
213
211
await client . on ( 'connect' , async function ( ) {
214
- if ( keyArguments . membersCount != undefined ) {
212
+ if ( keyArguments . membersCount ) {
215
213
for ( let i = 0 ; i < keyArguments . membersCount ; i ++ ) {
216
214
const memberName = `${ keyArguments . memberStartWith } ${ common . generateWord ( 10 ) } ` ;
217
215
const scoreValue = random ( minScoreValue , maxScoreValue ) . toString ( 2 ) ;
@@ -236,10 +234,10 @@ export async function deleteAllKeysFromDB(host: string, port: string): Promise<v
236
234
const dbConf = { port : Number . parseInt ( port ) , host, username : 'default' } ;
237
235
const client = createClient ( dbConf ) ;
238
236
239
- await client . on ( 'error' , async function ( error : string ) {
237
+ await client . on ( 'error' , async function ( error : string ) {
240
238
throw new Error ( error ) ;
241
239
} ) ;
242
- await client . on ( 'connect' , async function ( ) {
240
+ await client . on ( 'connect' , async function ( ) {
243
241
await client . flushall ( ( error : string ) => {
244
242
if ( error ) {
245
243
throw error ;
0 commit comments