Skip to content

Commit f0b87d9

Browse files
Merge pull request #3859 from RedisInsight/e2e/feature/RI-6122-improvements-to-filter-pub-sub-channels
add pup/sub message test
2 parents e00346f + 6b704d1 commit f0b87d9

File tree

3 files changed

+12
-3
lines changed

3 files changed

+12
-3
lines changed

redisinsight/ui/src/pages/pub-sub/components/subscription-panel/components/patternsInfo/PatternsInfo.tsx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ const PatternsInfo = ({ channels }: PatternsInfoProps) => {
1717

1818
return (
1919
<div className={styles.patternsContainer}>
20-
<EuiText color="subdued" size="s" data-testid="messages-count">Patterns:&nbsp;{getChannelsCount()} </EuiText>
20+
<EuiText color="subdued" size="s" data-testid="patterns-count">Patterns:&nbsp;{getChannelsCount()} </EuiText>
2121
<AppendInfo title={<>{channels?.trim().split(' ').map((ch) => <p>{ch}</p>)}</>} />
2222
</div>
2323
)

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,9 @@ export class PubSubPage extends InstancePage {
2929
messageInput = Selector('[data-testid=field-message]');
3030
channelsSubscribeInput = Selector('[data-testid=channels-input]');
3131

32+
patternsCount = Selector('[data-testid=patterns-count]');
33+
messageCount = Selector('[data-testid=messages-count]');
34+
3235
/**
3336
* Publish message in pubsub
3437
* @param channel The name of channel

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

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,13 +58,19 @@ test
5858

5959
test.meta({ rte: rte.ossCluster })('Verify that PSUBSCRIBE works, that user can specify channel name to subscribe', async t => {
6060
const channelsName = 'first second third';
61+
const namesList = channelsName.split(' ');
62+
63+
await t.expect(pubSubPage.channelsSubscribeInput.value).eql('*', 'the default value is not set');
6164
await t.typeText(pubSubPage.channelsSubscribeInput, channelsName, { replace: true });
6265
await t.click(pubSubPage.subscribeButton);
6366
await t.expect(pubSubPage.channelsSubscribeInput.hasAttribute('disabled')).ok('the field is not disabled after subscribe');
64-
await pubSubPage.publishMessage(channelsName.split(' ')[0], 'published message');
67+
await pubSubPage.publishMessage(namesList[0], 'published message');
6568
await verifyMessageDisplayingInPubSub('published message', true);
66-
await pubSubPage.publishMessage(channelsName.split(' ')[1], 'second message');
69+
await pubSubPage.publishMessage(namesList[1], 'second message');
6770
await verifyMessageDisplayingInPubSub('second message', true);
6871
await pubSubPage.publishMessage('not exist', 'not exist message');
6972
await verifyMessageDisplayingInPubSub('not exist message', false);
73+
74+
await t.expect(pubSubPage.patternsCount.textContent).contains(namesList.length.toString(), 'patterns count is not calculated correctly');
75+
await t.expect(pubSubPage.messageCount.textContent).contains('2', 'message count is not calculated correctly');
7076
});

0 commit comments

Comments
 (0)