#RI-2943 BE rename PendingMessage -> PendingEntry

Author: Artem

redisinsight/api/src/modules/browser/controllers/stream/consumer.controller.ts

@@ -11,7 +11,7 @@ import { ApiRedisInstanceOperation } from 'src/decorators/api-redis-instance-ope
 import {
   ConsumerDto,
   ConsumerGroupDto,
-  GetConsumersDto, GetPendingMessagesDto, PendingMessageDto,
+  GetConsumersDto, GetPendingEntriesDto, PendingEntryDto,
 } from 'src/modules/browser/dto/stream.dto';
 import { ConsumerService } from 'src/modules/browser/services/stream/consumer.service';
 
@@ -47,15 +47,15 @@ export class ConsumerController {
     responses: [
       {
         status: 200,
-        type: PendingMessageDto,
+        type: PendingEntryDto,
         isArray: true,
       },
     ],
   })
   async getPendingMessages(
     @Param('dbInstance') instanceId: string,
-      @Body() dto: GetPendingMessagesDto,
-  ): Promise<PendingMessageDto[]> {
+      @Body() dto: GetPendingEntriesDto,
+  ): Promise<PendingEntryDto[]> {
     return this.service.getPendingMessages({ instanceId }, dto);
   }
 }

redisinsight/api/src/modules/browser/dto/stream.dto.ts

@@ -325,7 +325,7 @@ export class GetConsumersDto extends KeyDto {
   groupName: string;
 }
 
-export class PendingMessageDto {
+export class PendingEntryDto {
   @ApiProperty({
     type: String,
     description: 'Entry ID',
@@ -356,7 +356,7 @@ export class PendingMessageDto {
   delivered: number = 0;
 }
 
-export class GetPendingMessagesDto extends IntersectionType(
+export class GetPendingEntriesDto extends IntersectionType(
   KeyDto,
   GetConsumersDto,
 ) {

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

@@ -11,7 +11,7 @@ import { BrowserToolService } from 'src/modules/browser/services/browser-tool/br
 import ERROR_MESSAGES from 'src/constants/error-messages';
 import {
   ConsumerDto,
-  GetConsumersDto, GetPendingMessagesDto, PendingMessageDto,
+  GetConsumersDto, GetPendingEntriesDto, PendingEntryDto,
 } from 'src/modules/browser/dto/stream.dto';
 
 @Injectable()
@@ -67,8 +67,8 @@ export class ConsumerService {
    */
   async getPendingMessages(
     clientOptions: IFindRedisClientInstanceByOptions,
-    dto: GetPendingMessagesDto,
-  ): Promise<PendingMessageDto[]> {
+    dto: GetPendingEntriesDto,
+  ): Promise<PendingEntryDto[]> {
     try {
       this.logger.log('Getting pending messages list.');
 
@@ -167,15 +167,15 @@ export class ConsumerService {
    * ]
    * @param reply
    */
-  static formatReplyToPendingMessagesDto(reply: Array<Array<string | number>>): PendingMessageDto[] {
+  static formatReplyToPendingMessagesDto(reply: Array<Array<string | number>>): PendingEntryDto[] {
     return reply.map(ConsumerService.formatArrayToPendingMessageDto);
   }
 
   /**
    * Format single reply entry to DTO
    * @param entry
    */
-  static formatArrayToPendingMessageDto(entry: Array<string | number>): PendingMessageDto {
+  static formatArrayToPendingMessageDto(entry: Array<string | number>): PendingEntryDto {
     if (!entry?.length) {
       return null;
     }