Merge pull request #3153 from RedisInsight/be/feature/RI-5531_stream-entries

fix strem entry info

Author: Artem

redisinsight/api/src/modules/browser/stream/services/stream.service.ts

@@ -29,6 +29,7 @@ import { ClientMetadata } from 'src/common/models';
 import { DatabaseClientFactory } from 'src/modules/database/providers/database.client.factory';
 import { RedisClient } from 'src/modules/redis/client';
 import { checkIfKeyExists, checkIfKeyNotExists } from 'src/modules/browser/utils';
+import { convertArrayReplyToObject } from 'src/modules/redis/utils';
 
 @Injectable()
 export class StreamService {
@@ -55,10 +56,10 @@ export class StreamService {
 
       await checkIfKeyNotExists(keyName, client);
 
-      const info = await client.sendCommand([
+      const info = convertArrayReplyToObject(await client.sendCommand([
         BrowserToolStreamCommands.XInfoStream,
         keyName,
-      ]);
+      ]) as string[]);
 
       let entries = [];
       if (sortOrder && sortOrder === SortOrder.Asc) {
@@ -71,10 +72,10 @@ export class StreamService {
 
       return plainToClass(GetStreamEntriesResponse, {
         keyName,
-        total: info[1],
-        lastGeneratedId: info[7].toString(),
-        firstEntry: StreamService.formatArrayToDto(info[11]),
-        lastEntry: StreamService.formatArrayToDto(info[13]),
+        total: info['length'],
+        lastGeneratedId: info['last-generated-id'].toString(),
+        firstEntry: StreamService.formatArrayToDto(info['first-entry']),
+        lastEntry: StreamService.formatArrayToDto(info['last-entry']),
         entries,
       });
     } catch (error) {

redisinsight/api/src/modules/redis/utils/reply.util.ts

@@ -26,7 +26,7 @@ export const convertArrayReplyToObject = (input: string[]): { [key: string]: any
   2,
 ).reduce((prev: any, current: string[]) => {
   const [key, value] = current;
-  return { ...prev, [key.toLowerCase()]: value };
+  return { ...prev, [key.toString().toLowerCase()]: value };
 }, {});
 
 /**