updated and add tests

Author: mariasergeenko

tests/e2e/package.json

@@ -25,7 +25,8 @@
   "author": "",
   "dependencies": {
     "axios": "^1.6.0",
-    "cli-argument-parser": "0.4.5"
+    "cli-argument-parser": "0.4.5",
+    "js-yaml": "^4.1.0"
   },
   "resolutions": {
     "@types/lodash": "4.14.192",

tests/e2e/pageObjects/components/monaco-editor.ts

@@ -20,6 +20,7 @@ export class MonacoEditor {
      * @param clean if  field should be cleaned
      */
     async sendTextToMonaco(input: Selector, command: string, clean = true): Promise<void> {
+
         await t.click(input);
         if(clean) {
             await t
@@ -30,6 +31,28 @@ export class MonacoEditor {
         await t.typeText(input, command);
     }
 
+    /**
+     * Send lines in monacoEditor without additional space that typeText can add
+     * @param input The input locator
+     * @param lines lines
+     * @param depth level of depth of the object
+     */
+    async insertTextByLines(input: Selector, lines: string[], depth: number): Promise<void> {
+        for(let i = 0; i < lines.length; i++) {
+            const line = lines[i];
+
+            for(let j = 0; j < depth; j++) {
+                await t.pressKey('shift+tab');
+            }
+
+            if (line) {
+                await t.typeText(input, line, { paste: true });
+            }
+            await t.pressKey('esc');
+            await t.pressKey('enter');
+        }
+    }
+
     /**
      * Get text from monacoEditor
      */

tests/e2e/pageObjects/components/rdi/pipeline-management-panel.ts

@@ -11,7 +11,7 @@ export class PipelineManagementPanel {
 
     jobNameInput = Selector('[data-testid=inline-item-editor]');
     jobItem = Selector('[data-testid*=rdi-nav-job-actions]');
-    confirmBtn  = Selector('[data-testid=confirm-btn]');
+    confirmBtn  = Selector('[data-testid=delete-confirm-btn]');
     jobsPipelineTitle = Selector('[class*=rdi__title]');
 
     /**
@@ -28,7 +28,7 @@ export class PipelineManagementPanel {
      * @param name job name
      */
     async openJobByName(name: string): Promise<void> {
-        const jobBtnSelector = Selector(`[data-testid=rdi-nav-job-${name}]`);
+        const jobBtnSelector = await this.getJobByName(name);
         await t.click(jobBtnSelector);
     }
 
@@ -52,4 +52,12 @@ export class PipelineManagementPanel {
             .typeText(this.jobNameInput, newName, { replace: true })
             .click(this.EditorButton.applyBtn);
     }
+
+    /**
+     * Get Job by name
+     * @param name job name
+     */
+    async getJobByName(name: string): Promise<Selector> {
+        return Selector(`[data-testid=rdi-nav-job-${name}]`);
+    }
 }

tests/e2e/pageObjects/components/rdi/rdi-header.ts

@@ -11,10 +11,11 @@ export class RdiHeader {
     deployConfirmBtn = Selector('[data-testid=deploy-confirm-btn]');
 
     uploadPipelineButton = Selector('[data-testid=upload-pipeline-btn]');
+    uploadConfirmPipelineButton = Selector('[data-testid=upload-confirm-btn]');
     uploadFromFileButton = Selector('[data-testid=upload-file-btn]');
     downloadPipelineButton = Selector('[data-testid=download-pipeline-btn]');
     importInput = Selector('[data-testid=import-file-modal-filepicker]');
-    confirmUploadingPipelineBatton = Selector('[data-testid=upload-confirm-btn]');
+    confirmUploadingPipelineBatton = Selector('[data-testid=submit-btn]');
 
     cloudSignInButton = Selector('[data-testid=cloud-sign-in-btn]');
 

tests/e2e/pageObjects/components/rdi/test-connection-panel.ts

@@ -9,6 +9,7 @@ export class TestConnectionPanel {
     failedSection = Selector('[data-testid^=failed-connections-]');
     endpointRow = Selector(this.endpointRowString);
     closeSection = Selector('[data-testid=close-test-connections-btn]');
+    targetName = Selector('[data-testid=table-target-target]');
 
     /**
      * Open/Close  section
@@ -34,16 +35,6 @@ export class TestConnectionPanel {
         return sectionSelector.find('span[data-testid="number-of-connections"]').textContent;
     }
 
-    /**
-     * get row count in the section
-     * @param section Name of section
-     */
-    async getNumberOfSectionRow(section: TextConnectionSection): Promise<string> {
-        const sectionSelector = Selector(`[data-testid^=${section}-connections-]`);
-        const rows =  await sectionSelector.find('[data-testid^=table-endpoint]').count;
-        return rows.toString();
-    }
-
     /**
      * get row endpoint text by index
      * @param section Name of section

tests/e2e/pageObjects/rdi-instance-page.ts

@@ -15,7 +15,7 @@ export class RdiInstancePage extends BaseOverviewPage {
     RdiHeader = new RdiHeader();
     MonacoEditor = new MonacoEditor();
 
-    dryRunButton = Selector('[data-testid=rdi-jobs-dry-run]');
+    dryRunButton = Selector('[data-testid=rdi-job-dry-run]');
     dryRunSubmitBtn = Selector('[data-testid=dry-run-btn]');
     closeDryRunPanelBtn = Selector('[data-testid=close-dry-run-btn]');
     dryRunPanel = Selector('[data-testid=dry-run-panel]');
@@ -28,6 +28,8 @@ export class RdiInstancePage extends BaseOverviewPage {
     okUploadPipelineBtn = Selector('[data-testid=ok-btn]');
     closeImportModelBtn = Selector('[data-testid=import-file-modal] button');
 
+    loadingIndicator = Selector('[class*=rdi__loading]');
+
     configurationInput = Selector('[data-testid=wrapper-rdi-monaco-config]');
     configurationLink = Selector('[data-testid=rdi-pipeline-config-link]');
 
@@ -38,7 +40,6 @@ export class RdiInstancePage extends BaseOverviewPage {
     jmesPathOption = Selector('[id=jmespath]');
     sqlEditorButton = Selector('[data-testid=open-dedicated-editor-btn]');
 
-    successDeployNotification = Selector('[data-testid=success-deploy-pipeline-notification]');
     errorDeployNotification = Selector('[data-test-subj=toast-error-deploy]');
     failedUploadingPipelineNotification = Selector('[data-testid=result-failed]');
     closeNotification =  Selector('[class*=euiModal__closeIcon]');

tests/e2e/test-data/rdi/RDI_pipelineConfig.zip

@@ -15,13 +15,13 @@ const databaseHelper = new DatabaseHelper();
 
 const rdiInstance: AddNewRdiParameters = {
     name: 'testInstance',
-    url: 'http://localhost:4000',
+    url: 'https://54.175.165.214',
     username: 'username',
-    password: 'password'
+    password: 'v3rY$tronGPa33w0Rd3ECDb'
 };
 
 //skip the tests until rdi integration is added
-fixture.skip `Add job`
+fixture `Add job`
     .meta({ type: 'critical_path', feature: 'rdi' })
     .page(commonUrl)
     .beforeEach(async() => {
@@ -85,6 +85,7 @@ test('Verify that user insert template for jobs', async() => {
     // should be empty config
     await rdiInstancePage.PipelineManagementPanel.addJob(jobName);
 
+    await rdiInstancePage.PipelineManagementPanel.openJobByName(jobName);
     await t.expect(rdiInstancePage.templateApplyButton.visible).ok('the template popover is not expanded');
     const buttonClass = rdiInstancePage.templateApplyButton.getAttribute('class');
     await t.expect(buttonClass).notContains(disabledAttribute, 'Apply button is disabled');
@@ -94,7 +95,7 @@ test('Verify that user insert template for jobs', async() => {
     await t.click(rdiInstancePage.templateButton);
     await t.expect(rdiInstancePage.templateApplyButton.visible).ok('the template popover is not expanded');
     await t.expect(rdiInstancePage.pipelineDropdown.textContent).eql(defaultValue, 'the default value is set incorrectly');
-    await rdiInstancePage.setTemplateDropdownValue(RdiTemplatePipelineType.WriteBehind);
+    await rdiInstancePage.setTemplateDropdownValue(RdiTemplatePipelineType.Ingest);
 
     //verify uniq templates words - should be undated when templates are added
     const enteredText = await rdiInstancePage.MonacoEditor.getTextFromMonaco();
@@ -120,9 +121,9 @@ test('Verify that user can open an additional editor to work with SQL and JMESPa
     const jobName = 'testJob';
     const sqlText = 'SELECT test FROM test1';
     const SQLiteText = 's';
-    const SQLiteAutoCompleteText = 'STRFTIME(format, time_value)';
+    const SQLiteAutoCompleteText = 'SIGN(X)';
     const JMESPathText = 'r';
-    const JMESPathAutoCompleteText = 'regex_replace';
+    const JMESPathAutoCompleteText = 'REGEX_REPLACE';
 
     await rdiInstancePage.PipelineManagementPanel.addJob(jobName);
     await rdiInstancePage.PipelineManagementPanel.openJobByName(jobName);
@@ -136,7 +137,7 @@ test('Verify that user can open an additional editor to work with SQL and JMESPa
     await t.expect(rdiInstancePage.draggableArea.exists).ok('SQL/JMESPath editor is not displayed');
 
     // Verify that user can see SQL(set by default) and JMESPath editor options
-    await t.expect(rdiInstancePage.dedicatedLanguageSelect.textContent).eql('SQL', 'SQL is not set by default');
+    await t.expect(rdiInstancePage.dedicatedLanguageSelect.textContent).eql('SQLite functions', 'SQL is not set by default');
 
     // Verify that user can close the additional editor
     await rdiInstancePage.MonacoEditor.sendTextToMonaco(rdiInstancePage.draggableArea, sqlText, false);
@@ -158,7 +159,7 @@ test('Verify that user can open an additional editor to work with SQL and JMESPa
     // Start type characters and select command
     await rdiInstancePage.MonacoEditor.sendTextToMonaco(rdiInstancePage.draggableArea, JMESPathText);
     // Verify that the list with auto-suggestions is displayed
-    await t.expect(rdiInstancePage.MonacoEditor.monacoSuggestion.count).eql(3, 'Auto-suggestions are not displayed');
+    await t.expect(rdiInstancePage.MonacoEditor.monacoSuggestion.count).gt(1, 'Auto-suggestions are not displayed');
     await t.pressKey('tab');
     await t.click(rdiInstancePage.EditorButton.applyBtn);
     await t.expect(await rdiInstancePage.MonacoEditor.getTextFromMonaco()).contains(JMESPathAutoCompleteText, 'Text from JMESPath editor not applied');
@@ -168,7 +169,7 @@ test('Verify that user can open an additional editor to work with SQL and JMESPa
     // Start type characters and select command
     await rdiInstancePage.MonacoEditor.sendTextToMonaco(rdiInstancePage.draggableArea, SQLiteText);
     // Verify that the list with auto-suggestions is displayed
-    await t.expect(rdiInstancePage.MonacoEditor.monacoSuggestion.count).eql(3, 'Auto-suggestions are not displayed');
+    await t.expect(rdiInstancePage.MonacoEditor.monacoSuggestion.count).gt(1, 'Auto-suggestions are not displayed');
     await t.pressKey('tab');
     await t.click(rdiInstancePage.EditorButton.applyBtn);
     await t.expect(await rdiInstancePage.MonacoEditor.getTextFromMonaco()).contains(SQLiteAutoCompleteText, 'Text from SQLite editor not applied');

tests/e2e/test-data/rdi/RDI_pipelineJobValid.zip

@@ -7,8 +7,9 @@ import { RdiInstancePage } from '../../../../pageObjects/rdi-instance-page';
 import { commonUrl } from '../../../../helpers/conf';
 import { RdiPopoverOptions, RedisOverviewPage } from '../../../../helpers/constants';
 import { MyRedisDatabasePage } from '../../../../pageObjects';
-import { DatabaseHelper } from '../../../../helpers';
+import { Common, DatabaseHelper } from '../../../../helpers';
 import { RdiApiRequests } from '../../../../helpers/api/api-rdi';
+import { goBackHistory } from '../../../../helpers/utils';
 
 const rdiInstancesListPage = new RdiInstancesListPage();
 const browserActions = new BrowserActions();
@@ -19,29 +20,29 @@ const rdiApiRequests = new RdiApiRequests();
 
 const rdiInstance: RdiInstance = {
     alias: 'Alias',
-    url: 'http://localhost:4000',
+    url: 'https://54.175.165.214',
     username: 'username',
-    password: 'passwordPassword',
+    password: 'v3rY$tronGPa33w0Rd3ECDb',
     version: '1.2'
 };
 const rdiInstance2: RdiInstance = {
     alias: 'test',
-    url: 'http://localhost:4000',
+    url: 'https://54.175.165.214',
     username: 'name',
-    password: 'pass2024',
+    password: 'v3rY$tronGPa33w0Rd3ECDb',
     version: '1.2'
 };
 
 const rdiInstance3: RdiInstance = {
     alias: 'first',
-    url: 'http://localhost:4000',
+    url: 'https://54.175.165.214',
     username: 'name',
-    password: 'passPassword2024',
+    password: 'v3rY$tronGPa33w0Rd3ECDb',
     version: '1.2'
 };
 //skip the tests until rdi integration is added
 
-fixture.skip `Rdi instance`
+fixture `Rdi instance`
     .meta({ type: 'critical_path', feature: 'rdi' })
     .page(commonUrl)
     .beforeEach(async() => {
@@ -77,7 +78,6 @@ test('Verify that user can add and remove RDI', async() => {
 });
 test
     .after(async() => {
-        await t.typeText(rdiInstancesListPage.searchInput, '', { replace: true });
         await rdiInstancesListPage.deleteAllInstance();
     })('Verify that user can search by RDI', async() => {
         await rdiInstancesListPage.addRdi(rdiInstance);
@@ -90,20 +90,19 @@ test
     });
 test('Verify that sorting on the list of rdi saved when rdi opened', async t => {
     // Sort by Connection Type
-
     await rdiInstancesListPage.addRdi(rdiInstance);
     await rdiInstancesListPage.addRdi(rdiInstance3);
     await rdiInstancesListPage.addRdi(rdiInstance2);
 
-    const sortedByUrl = [rdiInstance3.alias, rdiInstance2.alias, rdiInstance.alias];
-    await rdiInstancesListPage.sortByColumn('URL');
+    const sortedByAlias = [rdiInstance.alias, rdiInstance3.alias, rdiInstance2.alias];
+    await rdiInstancesListPage.sortByColumn('RDI Alias');
     let actualDatabaseList = await rdiInstancesListPage.getAllRdiNames();
-    await rdiInstancesListPage.compareInstances(actualDatabaseList, sortedByUrl);
+    await rdiInstancesListPage.compareInstances(actualDatabaseList, sortedByAlias);
     await rdiInstancesListPage.clickRdiByName(rdiInstance.alias);
     await rdiInstancePage.selectStartPipelineOption(RdiPopoverOptions.Pipeline);
     await t.click(rdiInstancePage.RdiHeader.breadcrumbsLink);
     actualDatabaseList = await rdiInstancesListPage.getAllRdiNames();
-    await rdiInstancesListPage.compareInstances(actualDatabaseList, sortedByUrl);
+    await rdiInstancesListPage.compareInstances(actualDatabaseList, sortedByAlias);
 });
 test('Verify that user has the same sorting if db name is changed', async t => {
     const newAliasName  = 'New alias';
@@ -151,16 +150,15 @@ test('Verify that button is displayed if user does not enter all mandatory infor
 });
 test('Verify that user can see the Redis Data Integration message on the empty RDI list', async t => {
     const noInstancesMessage = 'Redis Data Integration (RDI) synchronizes data from your existing database into Redis in near-real-time. We\'ve done the heavy lifting so you can turn slow data into fast data without coding.';
-    // const externalPageLink = 'https://docs.redis.com/rdi-preview/rdi/quickstart/'
+    const externalPageLink = 'https://redis.io/docs/latest/integrate/redis-data-integration/ingest/quick-start-guide/?utm_source=redisinsight&utm_medium=rdi&utm_campaign=rdi_list'
 
     await t.expect(rdiInstancesListPage.emptyRdiList.withText(noInstancesMessage).exists).ok('Empty RDI page message not displayed');
 
     await t.click(rdiInstancesListPage.addRdiFromEmptyListBtn);
     await t.expect(rdiInstancesListPage.AddRdiInstance.connectToRdiForm.exists).ok('Add rdi form not opened');
     await t.click(rdiInstancesListPage.AddRdiInstance.cancelInstanceBtn);
 
-    // Unskip after updating testcafe with opening links support https://redislabs.atlassian.net/browse/RI-5565
-    // await t.click(rdiInstancesListPage.quickstartBtn);
-    // await Common.checkURL(externalPageLink);
-    // await goBackHistory();
+    await t.click(rdiInstancesListPage.quickstartBtn);
+    await Common.checkURL(externalPageLink);
+    await goBackHistory();
 });