From 1c3aa0d4aded532c7474e74663dd0d72a42c5e55 Mon Sep 17 00:00:00 2001
From: Yury-Fridlyand <yury.fridlyand@improving.com>
Date: Thu, 19 Sep 2024 01:38:07 -0700
Subject: [PATCH] Node: fix pubsub IT by making sure cluster mode tests run
 only with cluster mode enabled flag  (#2317)

* Signed-off-by: Yury-Fridlyand <yury.fridlyand@improving.com>

* Signed-off-by: Yury-Fridlyand <yury.fridlyand@improving.com>
---
 node/tests/PubSub.test.ts | 20 ++++++++------------
 1 file changed, 8 insertions(+), 12 deletions(-)

diff --git a/node/tests/PubSub.test.ts b/node/tests/PubSub.test.ts
index 82aec7f826..5e8d40207a 100644
--- a/node/tests/PubSub.test.ts
+++ b/node/tests/PubSub.test.ts
@@ -4018,7 +4018,7 @@ describe("PubSub", () => {
      *
      * @param clusterMode - Indicates if the test should be run in cluster mode.
      */
-    it.each([true, false])(
+    it.each([true])(
         "test pubsub numsub and shardnumsub separation_%p",
         async (clusterMode) => {
             //const clusterMode = false;
@@ -4070,17 +4070,13 @@ describe("PubSub", () => {
                 });
 
                 // Test pubsubShardnumsub
-                if (clusterMode) {
-                    const shardSubscribers = await (
-                        client2 as GlideClusterClient
-                    ).pubsubShardNumSub([regularChannel, shardChannel]);
-                    expect(
-                        convertGlideRecordToRecord(shardSubscribers),
-                    ).toEqual({
-                        [regularChannel]: 0,
-                        [shardChannel]: 2,
-                    });
-                }
+                const shardSubscribers = await (
+                    client2 as GlideClusterClient
+                ).pubsubShardNumSub([regularChannel, shardChannel]);
+                expect(convertGlideRecordToRecord(shardSubscribers)).toEqual({
+                    [regularChannel]: 0,
+                    [shardChannel]: 2,
+                });
             } finally {
                 if (client1) {
                     await clientCleanup(client1, pubSub!);