#RI-3063-fix IT

RedisInsight · Jun 23, 2022 · abba002 · abba002
1 parent c1e384d
commit abba002
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 23 deletions.
diff --git a/redisinsight/api/src/modules/browser/dto/stream.dto.ts b/redisinsight/api/src/modules/browser/dto/stream.dto.ts
@@ -33,7 +33,7 @@ export class StreamEntryDto {
   @ApiProperty({
     type: Object,
     description: 'Entry fields',
-    example: { field1: 'value1', field2: 'value2' },
+    example: [['field1', 'value1'], ['field2', 'value2']],
   })
   @IsDefined()
   @IsNotEmpty()

diff --git a/redisinsight/api/test/api/stream/POST-instance-id-streams-entries.test.ts b/redisinsight/api/test/api/stream/POST-instance-id-streams-entries.test.ts
@@ -16,21 +16,20 @@ const { server, request, constants, rte } = deps;
 const endpoint = (instanceId = constants.TEST_INSTANCE_ID) =>
   request(server).post(`/instance/${instanceId}/streams/entries`);
 
-const entrySchema = Joi.object().keys({
-  id: Joi.string().label('entries.0.id').required(),
-  fields: Joi.object().label('entries.0.fields').required()
-    .messages({
-      'object.base': '{#label} must be an array',
+  const entrySchema = Joi.object().keys({
+    id: Joi.string().label('entries.0.id').required(),  
+    fields: Joi.array().label('entries.0.fields').items(Joi.any()).required().messages({
+      'array.base': '{#label} must be an array',
     }),
-});
-
-const dataSchema = Joi.object({
-  keyName: Joi.string().allow('').required(),
-  entries: Joi.array().items(entrySchema).required().messages({
-    'array.sparse': 'entries must be either object or array',
-    'array.base': 'property {#label} must be either object or array',
-  }),
-}).strict();
+  });
+  
+  const dataSchema = Joi.object({
+    keyName: Joi.string().allow('').required(),
+    entries: Joi.array().items(entrySchema).required().messages({
+      'array.sparse': 'entries must be either object or array',
+      'array.base': '{#label} must be either object or array',
+    }),
+  }).strict();
 
 const responseSchema = Joi.object().keys({
   keyName: Joi.string().required(),
@@ -191,8 +190,8 @@ describe('POST /instance/:instanceId/streams/entries', () => {
             {
               id: '*',
               fields: [
-                [constants.TEST_STREAM_FIELD_1, constants.TEST_STREAM_FIELD_1],
-                [constants.TEST_STREAM_FIELD_2, constants.TEST_STREAM_FIELD_2]
+                [constants.TEST_STREAM_VALUE_1, constants.TEST_STREAM_VALUE_1],
+                [constants.TEST_STREAM_VALUE_2, constants.TEST_STREAM_VALUE_2]
               ],
             },
           ]

diff --git a/redisinsight/api/test/api/stream/POST-instance-id-streams.test.ts b/redisinsight/api/test/api/stream/POST-instance-id-streams.test.ts
@@ -17,18 +17,17 @@ const endpoint = (instanceId = constants.TEST_INSTANCE_ID) =>
   request(server).post(`/instance/${instanceId}/streams`);
 
 const entrySchema = Joi.object().keys({
-  id: Joi.string().label('entries.0.id').required(),
-  fields: Joi.array().label('entries.0.fields').required()
-    .messages({
-      'object.base': '{#label} must be an array',
-    }),
+  id: Joi.string().label('entries.0.id').required(),  
+  fields: Joi.array().label('entries.0.fields').items(Joi.any()).required().messages({
+    'array.base': '{#label} must be an array',
+  }),
 });
 
 const dataSchema = Joi.object({
   keyName: Joi.string().allow('').required(),
   entries: Joi.array().items(entrySchema).required().messages({
     'array.sparse': 'entries must be either object or array',
-    'array.base': 'property {#label} must be an array',
+    'array.base': '{#label} must be either object or array',
   }),
   expire: Joi.number().integer().allow(null).min(1).max(2147483647),
 }).strict();