Merge pull request #3838 from RedisInsight/e2e/feature/RI-6097_Subscript_to_specific_channel_pubsub

add test Verify that PSUBSCRIBE works, that user can specify channel …

Author: mariasergeenko

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

@@ -27,6 +27,7 @@ export class PubSubPage extends InstancePage {
     //INPUTS
     channelNameInput = Selector('[data-testid=field-channel-name]');
     messageInput = Selector('[data-testid=field-message]');
+    channelsSubscribeInput = Selector('[data-testid=channels-input]');
 
     /**
      * Publish message in pubsub

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

@@ -12,19 +12,20 @@ const databaseAPIRequests = new DatabaseAPIRequests();
 
 fixture `PubSub OSS Cluster 7 tests`
     .meta({ type: 'regression' })
-    .page(commonUrl);
+    .page(commonUrl)
 
-test
-    .before(async t => {
+    .beforeEach(async t => {
         await databaseHelper.acceptLicenseTerms();
         await databaseAPIRequests.addNewOSSClusterDatabaseApi(ossClusterConfig);
         await myRedisDatabasePage.reloadPage();
         await myRedisDatabasePage.clickOnDBByName(ossClusterConfig.ossClusterDatabaseName);
         await t.click(myRedisDatabasePage.NavigationPanel.pubSubButton);
     })
-    .after(async() => {
+    .afterEach(async() => {
         await databaseAPIRequests.deleteOSSClusterDatabaseApi(ossClusterConfig);
-    })
+    });
+test
+
     .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 not displayed');
         // Verify that user can see published messages for OSS Cluster 7
@@ -54,3 +55,16 @@ test
         await pubSubPage.Cli.sendCommandInCli('10 spublish channel oss_cluster_message_spublish');
         await verifyMessageDisplayingInPubSub('oss_cluster_message_spublish', false);
     });
+
+test.meta({ rte: rte.ossCluster })('Verify that PSUBSCRIBE works, that user can specify channel name to subscribe', async t => {
+    const channelsName = 'first second third';
+    await t.typeText(pubSubPage.channelsSubscribeInput, channelsName, { replace: true });
+    await t.click(pubSubPage.subscribeButton);
+    await t.expect(pubSubPage.channelsSubscribeInput.hasAttribute('disabled')).ok('the field is not disabled after subscribe');
+    await pubSubPage.publishMessage(channelsName.split(' ')[0], 'published message');
+    await verifyMessageDisplayingInPubSub('published message', true);
+    await pubSubPage.publishMessage(channelsName.split(' ')[1], 'second message');
+    await verifyMessageDisplayingInPubSub('second message', true);
+    await pubSubPage.publishMessage('not exist', 'not exist message');
+    await verifyMessageDisplayingInPubSub('not exist message', false);
+});