skip Consumer Groups ITests for CRDT database because xadd-id-uniqueness-mode is strict

Author: Artem

redisinsight/api/test/api/stream/POST-instance-id-streams-consumer_groups-consumers-pending_messages-ack.test.ts

@@ -58,7 +58,12 @@ const mainCheckFn = async (testCase) => {
 };
 
 describe('POST /instance/:instanceId/streams/consumer-groups/consumers/pending-messages/ack', () => {
-  beforeEach(async () => await rte.data.generateKeys(true));
+  requirements('!rte.crdt');
+
+  beforeEach(async () => {
+    await rte.data.generateStrings(true);
+    await rte.data.generateStreamsWithoutStrictMode();
+  });
 
   describe('Validation', () => {
     generateInvalidDataTestCases(dataSchema, validInputData).map(

redisinsight/api/test/api/stream/POST-instance-id-streams-consumer_groups-consumers-pending_messages-claim.test.ts

@@ -67,7 +67,12 @@ const mainCheckFn = async (testCase) => {
 };
 
 describe('POST /instance/:instanceId/streams/consumer-groups/consumers/pending-messages/claim', () => {
-  beforeEach(async () => await rte.data.generateKeys(true));
+  requirements('!rte.crdt');
+
+  beforeEach(async () => {
+    await rte.data.generateStrings(true);
+    await rte.data.generateStreamsWithoutStrictMode();
+  });
 
   describe('Validation', () => {
     generateInvalidDataTestCases(dataSchema, validInputData).map(

redisinsight/api/test/api/stream/POST-instance-id-streams-consumer_groups-consumers-pending_messages-get.test.ts

@@ -64,7 +64,12 @@ const mainCheckFn = async (testCase) => {
 };
 
 describe('POST /instance/:instanceId/streams/consumer-groups/consumers/pending-messages/get', () => {
-  beforeEach(async () => await rte.data.generateKeys(true));
+  requirements('!rte.crdt');
+
+  beforeEach(async () => {
+    await rte.data.generateStrings(true);
+    await rte.data.generateStreamsWithoutStrictMode();
+  });
 
   describe('Validation', () => {
     generateInvalidDataTestCases(dataSchema, validInputData).map(

redisinsight/api/test/helpers/constants.ts

@@ -55,6 +55,7 @@ export const constants = {
   TEST_RTE_ON_PREMISE: process.env.TEST_RTE_ON_PREMISE ? process.env.TEST_RTE_ON_PREMISE === 'true' : true,
   TEST_RTE_SHARED_DATA: process.env.TEST_RTE_SHARED_DATA ? process.env.TEST_RTE_SHARED_DATA === 'true' : false,
   TEST_RTE_BIG_DATA: process.env.TEST_RTE_BIG_DATA ? process.env.TEST_RTE_BIG_DATA === 'true' : false,
+  TEST_RTE_CRDT: process.env.TEST_RTE_CRDT ? process.env.TEST_RTE_CRDT === 'true' : false,
   TEST_RTE_TYPE: process.env.TEST_RTE_DISCOVERY_TYPE || 'STANDALONE',
   TEST_RTE_HOST: process.env.TEST_RTE_DISCOVERY_HOST,
   TEST_RTE_PORT: process.env.TEST_RTE_DISCOVERY_PORT,

redisinsight/api/test/helpers/data/redis.ts

@@ -235,6 +235,27 @@ export const initDataHelper = (rte) => {
       await truncate();
     }
 
+    await client.xadd(constants.TEST_STREAM_KEY_1, '*', constants.TEST_STREAM_FIELD_1, constants.TEST_STREAM_VALUE_1)
+    await sendCommand('xgroup', [
+      'create',
+      constants.TEST_STREAM_KEY_1,
+      constants.TEST_STREAM_GROUP_1,
+      constants.TEST_STREAM_ID_1
+    ])
+    await sendCommand('xgroup', [
+      'create',
+      constants.TEST_STREAM_KEY_1,
+      constants.TEST_STREAM_GROUP_2,
+      constants.TEST_STREAM_ID_1
+    ])
+    await client.xadd(constants.TEST_STREAM_KEY_2, '*', constants.TEST_STREAM_FIELD_1, constants.TEST_STREAM_VALUE_1)
+  };
+
+  const generateStreamsWithoutStrictMode = async (clean: boolean = false) => {
+    if (clean) {
+      await truncate();
+    }
+
     await client.xadd(constants.TEST_STREAM_KEY_1, constants.TEST_STREAM_ID_1, constants.TEST_STREAM_FIELD_1, constants.TEST_STREAM_VALUE_1)
     await sendCommand('xgroup', [
       'create',
@@ -361,7 +382,9 @@ export const initDataHelper = (rte) => {
     generateNKeys,
     generateNReJSONs,
     generateNTimeSeries,
+    generateStrings,
     generateStreams,
+    generateStreamsWithoutStrictMode,
     generateNStreams,
     generateNGraphs,
     getClientNodes,

redisinsight/api/test/helpers/redis.ts

@@ -185,6 +185,7 @@ export const initRTE = async () => {
     cloud: !!constants.TEST_CLOUD_RTE,
     sharedData: constants.TEST_RTE_SHARED_DATA,
     bigData: constants.TEST_RTE_BIG_DATA,
+    crdt: constants.TEST_RTE_CRDT,
     nodes: [],
   };
 

redisinsight/api/test/test-runs/re-crdt/.env

@@ -3,3 +3,4 @@ [email protected]
 TEST_RE_PASS=123456
 TEST_REDIS_PORT=12000
 TEST_RTE_SHARED_DATA=true
+TEST_RTE_CRDT=true