do not resend unfulfilled commands

Author: ArtemHoruzhenko

redisinsight/api/src/constants/error-messages.ts

@@ -5,6 +5,7 @@ export default {
   BAD_REQUEST: 'Bad request',
   NOT_FOUND: 'Resource was not found',
   INTERNAL_SERVER_ERROR: 'Server error',
+  REQUEST_TIMEOUT: 'Request timeout out',
 
   INVALID_DATABASE_INSTANCE_ID: 'Invalid database instance id.',
   COMMAND_EXECUTION_NOT_FOUND: 'Command execution was not found.',

redisinsight/api/src/modules/browser/browser.base.controller.ts

@@ -0,0 +1,6 @@
+import { UseInterceptors } from '@nestjs/common';
+import { TimeoutInterceptor } from 'src/common/interceptors';
+import ERROR_MESSAGES from 'src/constants/error-messages';
+
+@UseInterceptors(new TimeoutInterceptor(ERROR_MESSAGES.REQUEST_TIMEOUT))
+export class BrowserBaseController {}

redisinsight/api/src/modules/browser/hash/hash.controller.ts

@@ -26,13 +26,16 @@ import {
   GetHashFieldsResponse, UpdateHashFieldsTtlDto,
 } from 'src/modules/browser/hash/dto';
 import { HashService } from 'src/modules/browser/hash/hash.service';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: Hash')
 @UseInterceptors(BrowserSerializeInterceptor)
 @Controller('hash')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class HashController {
-  constructor(private hashService: HashService) {}
+export class HashController extends BrowserBaseController {
+  constructor(private hashService: HashService) {
+    super();
+  }
 
   @Post('')
   @ApiOperation({ description: 'Set key to hold Hash data type' })

redisinsight/api/src/modules/browser/list/list.controller.ts

@@ -38,13 +38,16 @@ import { ApiQueryRedisStringEncoding } from 'src/common/decorators';
 import { ClientMetadata } from 'src/common/models';
 import { BrowserSerializeInterceptor } from 'src/common/interceptors';
 import { ListService } from 'src/modules/browser/list/list.service';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: List')
 @UseInterceptors(BrowserSerializeInterceptor)
 @Controller('list')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class ListController {
-  constructor(private listService: ListService) { }
+export class ListController extends BrowserBaseController {
+  constructor(private listService: ListService) {
+    super();
+  }
 
   @Post('')
   @ApiOperation({ description: 'Set key to hold list data type' })

redisinsight/api/src/modules/browser/redisearch/redisearch.controller.ts

@@ -26,13 +26,16 @@ import { GetKeysWithDetailsResponse } from 'src/modules/browser/keys/dto';
 import { RedisearchService } from 'src/modules/browser/redisearch/redisearch.service';
 import { ClientMetadata } from 'src/common/models';
 import { BrowserSerializeInterceptor } from 'src/common/interceptors';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: RediSearch')
 @UseInterceptors(BrowserSerializeInterceptor)
 @Controller('redisearch')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class RedisearchController {
-  constructor(private service: RedisearchService) {}
+export class RedisearchController extends BrowserBaseController {
+  constructor(private service: RedisearchService) {
+    super();
+  }
 
   @Get('')
   @ApiOperation({ description: 'Get list of available indexes' })

redisinsight/api/src/modules/browser/rejson-rl/rejson-rl.controller.ts

@@ -21,12 +21,15 @@ import { RejsonRlService } from 'src/modules/browser/rejson-rl/rejson-rl.service
 import { ApiRedisInstanceOperation } from 'src/decorators/api-redis-instance-operation.decorator';
 import { BrowserClientMetadata } from 'src/modules/browser/decorators/browser-client-metadata.decorator';
 import { ClientMetadata } from 'src/common/models';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: REJSON-RL')
 @Controller('rejson-rl')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class RejsonRlController {
-  constructor(private service: RejsonRlService) {}
+export class RejsonRlController extends BrowserBaseController {
+  constructor(private service: RejsonRlService) {
+    super();
+  }
 
   @Post('/get')
   @ApiRedisInstanceOperation({

redisinsight/api/src/modules/browser/services/keys-business/scanner/strategies/standalone.strategy.ts

@@ -26,13 +26,16 @@ import {
 } from 'src/modules/browser/set/dto';
 import { SetService } from 'src/modules/browser/set/set.service';
 import { BrowserSerializeInterceptor } from 'src/common/interceptors';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: Set')
 @UseInterceptors(BrowserSerializeInterceptor)
 @Controller('set')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class SetController {
-  constructor(private setService: SetService) {}
+export class SetController extends BrowserBaseController {
+  constructor(private setService: SetService) {
+    super();
+  }
 
   @Post('')
   @ApiOperation({ description: 'Set key to hold Set data type' })

redisinsight/api/src/modules/browser/set/set.controller.ts

@@ -23,13 +23,16 @@ import { BrowserClientMetadata } from 'src/modules/browser/decorators/browser-cl
 import { ApiQueryRedisStringEncoding } from 'src/common/decorators';
 import { ClientMetadata } from 'src/common/models';
 import { BrowserSerializeInterceptor } from 'src/common/interceptors';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: Streams')
 @UseInterceptors(BrowserSerializeInterceptor)
 @Controller('streams/consumer-groups')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class ConsumerGroupController {
-  constructor(private service: ConsumerGroupService) {}
+export class ConsumerGroupController extends BrowserBaseController {
+  constructor(private service: ConsumerGroupService) {
+    super();
+  }
 
   @Post('/get')
   @ApiRedisInstanceOperation({

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

@@ -26,13 +26,16 @@ import { BrowserClientMetadata } from 'src/modules/browser/decorators/browser-cl
 import { ApiQueryRedisStringEncoding } from 'src/common/decorators';
 import { ClientMetadata } from 'src/common/models';
 import { BrowserSerializeInterceptor } from 'src/common/interceptors';
+import { BrowserBaseController } from 'src/modules/browser/browser.base.controller';
 
 @ApiTags('Browser: Streams')
 @UseInterceptors(BrowserSerializeInterceptor)
 @Controller('streams/consumer-groups/consumers')
 @UsePipes(new ValidationPipe({ transform: true }))
-export class ConsumerController {
-  constructor(private service: ConsumerService) {}
+export class ConsumerController extends BrowserBaseController {
+  constructor(private service: ConsumerService) {
+    super();
+  }
 
   @Post('/get')
   @ApiRedisInstanceOperation({