e2e - Show consumer group tests

tests/e2e/pageObjects/browser-page.ts

@@ -74,6 +74,7 @@ export class BrowserPage {
     saveGroupsButton = Selector('[data-testid=save-groups-btn]');
     //CONTAINERS
     streamGroupsContainer = Selector('[data-testid=stream-groups-container]');
+    streamConsumersContainer = Selector('[data-testid=stream-consumers-container]');
     breadcrumbsContainer = Selector('[data-testid=breadcrumbs-container]');
     virtualTableContainer = Selector('[data-testid=virtual-table-container]');
     streamEntriesContainer = Selector('[data-testid=stream-entries-container]');
@@ -94,6 +95,7 @@ export class BrowserPage {
     filterOptionTypeSelected = Selector('[data-testid^=filter-option-type-selected]');
     //TABS
     streamTabGroups = Selector('[data-testid=stream-tab-Groups]');
+    streamTabs = Selector('[data-test-subj=stream-tabs]');
     //TEXT INPUTS (also referred to as 'Text fields')
     addKeyNameInput = Selector('[data-testid=key]');
     keyNameInput = Selector('[data-testid=edit-key-input]');
@@ -189,6 +191,9 @@ export class BrowserPage {
     streamRangeRightTimestamp = Selector('[data-testid=range-right-timestamp]');
     streamGroupId = Selector('.streamItemId[data-testid^=stream-group-id]');
     streamGroupName = Selector('[data-testid^=stream-group-name]');
+    streamMessage = Selector('[data-testid^=stream-message]');
+    streamConsumerName = Selector('[data-testid^=stream-consumer-]');
+    consumerGroup = Selector('[data-testid^=stream-group-]');
     entryIdInfoIcon = Selector('[data-testid=entry-id-info-icon]');
     errorMessage = Selector('[data-test-subj=toast-error]');
     entryIdError = Selector('[data-testid=id-error]');

tests/e2e/tests/critical-path/browser/consumer-group.e2e.ts

@@ -1,13 +1,14 @@
 import { Chance } from 'chance';
 import { rte } from '../../../helpers/constants';
 import { acceptLicenseTermsAndAddDatabase, deleteDatabase } from '../../../helpers/database';
-import { BrowserPage } from '../../../pageObjects';
+import { BrowserPage, CliPage } from '../../../pageObjects';
 import {
     commonUrl,
     ossStandaloneConfig
 } from '../../../helpers/conf';
 
 const browserPage = new BrowserPage();
+const cliPage = new CliPage();
 const chance = new Chance();
 
 let keyName = chance.word({ length: 20 });
@@ -23,7 +24,7 @@ fixture `Consumer group`
     })
     .afterEach(async t => {
         //Clear and delete database
-        if (t.expect(browserPage.closeKeyButton.visible).ok){
+        if (await t.expect(browserPage.closeKeyButton.visible).ok()){
             await t.click(browserPage.closeKeyButton);
         }
         await browserPage.deleteKeyByName(keyName);
@@ -92,3 +93,61 @@ test('Verify that user can see the Consumer group columns (Group Name, Consumers
         await t.expect(browserPage.scoreButton.nth(i).textContent).eql(groupColumns[i], `The ${i} Consumer group column name`);
     }
 });
+test('Verify that user can see the message when there are no Consumers in the Consumer Group', async t => {
+    keyName = chance.word({ length: 20 });
+    consumerGroupName = chance.word({ length: 20 });
+    const message = 'Your Consumer Group has no Consumers available.';
+    // Add New Stream Key
+    await browserPage.addStreamKey(keyName, keyField, keyValue);
+    // Open Stream consumer group and check message
+    await t.click(browserPage.streamTabGroups);
+    await browserPage.createConsumerGroup(consumerGroupName);
+    await t.click(browserPage.consumerGroup);
+    await t.expect(browserPage.streamConsumersContainer.textContent).contains(message, 'The message for empty Consumer Group');
+});
+test('Verify that user can see the Consumer information columns (Consumer Name, Pendings, Idle Time,ms)', async t => {
+    keyName = chance.word({ length: 20 });
+    consumerGroupName = chance.word({ length: 20 });
+    const cliCommands = [
+        `XGROUP CREATE ${keyName} ${consumerGroupName} $ MKSTREAM`,
+        `XADD ${keyName} * message apple`,
+        `XREADGROUP GROUP ${consumerGroupName} Alice COUNT 1 STREAMS ${keyName} >`
+    ];
+    const consumerColumns = [
+        'Consumer Name',
+        'Pending',
+        'Idle Time, ms'
+    ];
+    // Add New Stream Key with groups and consumers
+    for(const command of cliCommands){
+        await cliPage.sendCommandInCli(command);
+    }
+    // Open Stream consumer info view
+    await browserPage.openKeyDetails(keyName);
+    await t.click(browserPage.streamTabGroups);
+    await t.click(browserPage.consumerGroup);
+    for(let i = 0; i < consumerColumns.length; i++){
+        await t.expect(browserPage.scoreButton.nth(i).textContent).eql(consumerColumns[i], `The ${i} Consumers info column name`);
+    }
+});
+test('Verify that user can navigate to Consumer Groups screen using the link in the breadcrumbs', async t => {
+    keyName = chance.word({ length: 20 });
+    consumerGroupName = chance.word({ length: 20 });
+    const cliCommands = [
+        `XGROUP CREATE ${keyName} ${consumerGroupName} $ MKSTREAM`,
+        `XADD ${keyName} * message apple`,
+        `XREADGROUP GROUP ${consumerGroupName} Alice COUNT 1 STREAMS ${keyName} >`
+    ];
+    // Add New Stream Key with groups and consumers
+    for(const command of cliCommands){
+        await cliPage.sendCommandInCli(command);
+    }
+    // Open Stream consumer info view
+    await browserPage.openKeyDetails(keyName);
+    await t.click(browserPage.streamTabGroups);
+    await t.click(browserPage.consumerGroup);
+    // Check navigation
+    await t.expect(browserPage.streamTabs.visible).ok('Stream navigation tabs visibility');
+    await t.click(browserPage.streamTabGroups);
+    await t.expect(browserPage.streamTabGroups.withAttribute('aria-selected', 'true').exists).ok('The Consumer Groups screen is opened');
+});

tests/e2e/tests/regression/browser/consumer-group.e2e.ts

@@ -1,13 +1,14 @@
 import { Chance } from 'chance';
 import { rte } from '../../../helpers/constants';
 import { acceptLicenseTermsAndAddDatabase, deleteDatabase } from '../../../helpers/database';
-import { BrowserPage } from '../../../pageObjects';
+import { BrowserPage, CliPage } from '../../../pageObjects';
 import {
     commonUrl,
     ossStandaloneConfig
 } from '../../../helpers/conf';
 
 const browserPage = new BrowserPage();
+const cliPage = new CliPage();
 const chance = new Chance();
 
 let keyName = chance.word({ length: 20 });
@@ -23,7 +24,7 @@ fixture `Consumer group`
     })
     .afterEach(async t => {
         //Clear and delete database
-        if (t.expect(browserPage.closeKeyButton.visible).ok){
+        if (await t.expect(browserPage.closeKeyButton.visible).ok()){
             await t.click(browserPage.closeKeyButton);
         }
         await browserPage.deleteKeyByName(keyName);
@@ -98,3 +99,31 @@ test('Verify that user can sort Consumer Group column: A>Z / Z>A(A>Z is default
         await t.expect(browserPage.streamGroupName.nth(i).textContent).contains(consumerGroupNames[groupsCount - 1 - i], 'The Consumer Groups Z>A sorting');
     }
 });
+test('Verify that A>Z is default table sorting in Consumer column', async t => {
+    keyName = chance.word({ length: 20 });
+    consumerGroupName = chance.word({ length: 20 });
+    const consumerNames = [
+        'Alice',
+        'Zalice'
+    ];
+    const cliCommands = [
+        `XGROUP CREATE ${keyName} ${consumerGroupName} $ MKSTREAM`,
+        `XADD ${keyName} * message apple`,
+        `XADD ${keyName} * message orange`,
+        `XREADGROUP GROUP ${consumerGroupName} ${consumerNames[0]} COUNT 1 STREAMS ${keyName} >`,
+        `XREADGROUP GROUP ${consumerGroupName} ${consumerNames[1]} COUNT 1 STREAMS ${keyName} >`
+    ];
+    //Add New Stream Key with groups and consumers
+    for(const command of cliCommands){
+        await cliPage.sendCommandInCli(command);
+    }
+    //Open Stream consumer info view
+    await browserPage.openKeyDetails(keyName);
+    await t.click(browserPage.streamTabGroups);
+    await t.click(browserPage.consumerGroup);
+    //Verify default sorting
+    const consumerCount = await browserPage.streamConsumerName.count;
+    for(let i = 0; i < consumerCount; i++){
+        await t.expect(browserPage.streamConsumerName.nth(i).textContent).contains(consumerNames[i], 'The Consumers default sorting');
+    }
+});

tests/e2e/tests/regression/shortcuts/shortcuts.e2e.ts

@@ -2,10 +2,12 @@ import { rte, env } from '../../../helpers/constants';
 import { acceptLicenseTerms } from '../../../helpers/database';
 import { MyRedisDatabasePage, HelpCenterPage, ShortcutsPage } from '../../../pageObjects';
 import { commonUrl } from '../../../helpers/conf';
+import { ClientFunction } from 'testcafe';
 
 const myRedisDatabasePage = new MyRedisDatabasePage();
 const helpCenterPage = new HelpCenterPage();
 const shortcutsPage = new ShortcutsPage();
+const getPageUrl = ClientFunction(() => window.location.href);
 
 fixture `Shortcuts`
     .meta({ type: 'regression' })
@@ -80,3 +82,13 @@ test
             await t.expect(shortcutsPage.shortcutsPanel.textContent).contains(element, 'The user can see description of the “Shift+Space” shortcut');
         }
     })
+test
+    .meta({ env: env.web, rte: rte.none })
+    ('Verify redirected link opening Release Notes in Help Center', async t => {
+        const link = 'https://github.com/RedisInsight/RedisInsight/releases';
+        //Click on the Release Notes in Help Center
+        await t.click(myRedisDatabasePage.helpCenterButton);
+        await t.click(helpCenterPage.helpCenterReleaseNotesButton);
+        //Verify the opened link
+        await t.expect(getPageUrl()).eql(link, 'The Release Notes link');
+    })