[E2E] pub/sub oss cluster tests added

tests/e2e/pageObjects/pub-sub-page.ts

@@ -16,6 +16,7 @@ export class PubSubPage {
     pubSubPageContainer = Selector('[data-testid=pub-sub-page]');
     clientBadge = Selector('[data-testid=affected-clients-badge]');
     clearButtonTooltip = Selector('.euiToolTipPopover');
+    ossClusterEmptyMessage = Selector('[data-testid=empty-messages-list-cluster]');
     //BUTTONS
     subscribeButton = Selector('[data-testid=subscribe-btn]').withText('Subscribe');
     unsubscribeButton = Selector('[data-testid=subscribe-btn]').withText('Unsubscribe');

tests/e2e/pageObjects/user-agreement-page.ts

@@ -15,7 +15,7 @@ export class UserAgreementPage {
     switchOptionEncryption = Selector('[data-testid=switch-option-encryption]');
     pluginSectionWithText = Selector('[data-testid=plugin-section]');
     recommendedSwitcher = Selector('[data-testid=switch-option-recommended]');
-
+    
     //Accept RedisInsight License Terms
     async acceptLicenseTerms(): Promise<void> {
         if (await this.switchOptionEula.exists) {
@@ -24,7 +24,7 @@ export class UserAgreementPage {
             await t.click(this.submitButton);
         }
     }
-
+    
     /**
      * Get state of Recommended switcher
      */

tests/e2e/tests/regression/pub-sub/pub-sub-oss-cluster-7.ts

@@ -0,0 +1,60 @@
+import {
+    acceptLicenseTerms
+} from '../../../helpers/database';
+import { MyRedisDatabasePage, PubSubPage, CliPage } from '../../../pageObjects';
+import { commonUrl, ossStandaloneConfig, ossClusterConfig } from '../../../helpers/conf';
+import { rte, env } from '../../../helpers/constants';
+import { verifyMessageDisplayingInPubSub } from '../../../helpers/pub-sub';
+import {
+    addNewOSSClusterDatabaseApi, addNewStandaloneDatabaseApi,
+    deleteOSSClusterDatabaseApi, deleteStandaloneDatabaseApi
+} from '../../../helpers/api/api-database';
+
+const myRedisDatabasePage = new MyRedisDatabasePage();
+const pubSubPage = new PubSubPage();
+const cliPage = new CliPage();
+
+fixture `PubSub OSS Cluster 7 tests`
+    .meta({ env: env.web, type: 'regression' })
+    .page(commonUrl);
+
+test
+    .before(async t => {
+        await acceptLicenseTerms();
+        await addNewOSSClusterDatabaseApi(ossClusterConfig);
+        await t.eval(() => location.reload());
+        await myRedisDatabasePage.clickOnDBByName(ossClusterConfig.ossClusterDatabaseName);
+        await t.click(myRedisDatabasePage.pubSubButton);
+    })
+    .after(async() => {
+        await deleteOSSClusterDatabaseApi(ossClusterConfig);
+    })
+    .meta({ rte: rte.ossCluster })('Verify that SPUBLISH message is displayed for OSS Cluster 7 database', async t => {
+        await t.expect(pubSubPage.ossClusterEmptyMessage.exists).ok('SPUBLISH message');
+        // Verify that user can see published messages for OSS Cluster 7
+        await t.click(pubSubPage.subscribeButton);
+        //Publish different messages
+        await cliPage.sendCommandInCli('50 publish channel oss_cluster_message');
+        await verifyMessageDisplayingInPubSub('oss_cluster_message', true);
+        // Verify that SPUBLISHED messages are not displayed for OSS Cluster 7
+        await cliPage.sendCommandInCli('10 spublish channel oss_cluster_message_spublish');
+        await verifyMessageDisplayingInPubSub('oss_cluster_message_spublish', false);
+    });
+test
+    .before(async t => {
+        await acceptLicenseTerms();
+        await addNewStandaloneDatabaseApi(ossStandaloneConfig);
+        await t.eval(() => location.reload());
+        await myRedisDatabasePage.clickOnDBByName(ossStandaloneConfig.databaseName);
+        await t.click(myRedisDatabasePage.pubSubButton);
+    })
+    .after(async() => {
+        await deleteStandaloneDatabaseApi(ossStandaloneConfig);
+    })
+    .meta({ rte: rte.standalone })('Verify that SPUBLISH message is not displayed for other databases expect OSS Cluster 7', async t => {
+        await t.expect(pubSubPage.ossClusterEmptyMessage.exists).notOk('No SPUBLISH message');
+        // Verify that user can't see published messages for Standalone DB
+        await t.click(pubSubPage.subscribeButton);
+        await cliPage.sendCommandInCli('10 spublish channel oss_cluster_message_spublish');
+        await verifyMessageDisplayingInPubSub('oss_cluster_message_spublish', false);
+    });