Release/2.2.0

.circleci/e2e/test.app-image.sh

@@ -1,3 +1,6 @@
+#!/bin/bash
+set -e
+
 yarn --cwd tests/e2e install
 
 # mount app resources

.circleci/redisstack/app-image.repack.sh

@@ -1,4 +1,5 @@
 #!/bin/bash
+set -e
 
 ARCH=${ARCH:-x86_64}
 WORKING_DIRECTORY=$(pwd)

.circleci/redisstack/build.sh

@@ -1,4 +1,5 @@
 #!/bin/bash
+set -e
 
 # install deps
 yarn

.circleci/redisstack/build_modules.sh

@@ -1,4 +1,5 @@
 #!/bin/bash
+set -e
 
 PLATFORM=${PLATFORM:-'linux'}
 ELECTRON_VERSION=$(cat electron/version)

.circleci/redisstack/dmg.repack.sh

@@ -1,4 +1,5 @@
 #!/bin/bash
+set -e
 
 ARCH=${ARCH:-x64}
 WORKING_DIRECTORY=$(pwd)

Dockerfile

@@ -11,6 +11,10 @@ COPY scripts ./scripts
 COPY redisinsight ./redisinsight
 RUN SKIP_POSTINSTALL=1 yarn install
 RUN yarn --cwd redisinsight/api
+ARG SERVER_TLS_CERT
+ARG SERVER_TLS_KEY
+ENV SERVER_TLS_CERT=${SERVER_TLS_CERT}
+ENV SERVER_TLS_KEY=${SERVER_TLS_KEY}
 RUN yarn build:web
 RUN yarn build:statics
 

package.json

@@ -14,8 +14,8 @@
     "build:main:stage": "webpack --config ./configs/webpack.config.main.stage.babel.js",
     "build:web": "webpack --config ./configs/webpack.config.web.prod.babel.js",
     "build:defaults": "yarn --cwd redisinsight/api build:defaults",
-    "build:statics": "yarn build:defaults & sh ./scripts/build-statics.sh",
-    "build:statics:win": "yarn build:defaults & ./scripts/build-statics.cmd",
+    "build:statics": "yarn build:defaults && sh ./scripts/build-statics.sh",
+    "build:statics:win": "yarn build:defaults && ./scripts/build-statics.cmd",
     "build:renderer": "webpack --config ./configs/webpack.config.renderer.prod.babel.js",
     "build:renderer:stage": "webpack --config ./configs/webpack.config.renderer.stage.babel.js",
     "rebuild": "electron-rebuild --parallel --types prod,dev,optional --module-dir redisinsight/ui",

redisinsight/about-panel.ts

@@ -7,7 +7,7 @@ const ICON_PATH = app.isPackaged
 
 export default {
   applicationName: 'RedisInsight-v2',
-  applicationVersion: app.getVersion() || '2.0',
+  applicationVersion: app.getVersion() || '2.2.0',
   copyright: `Copyright © ${new Date().getFullYear()} Redis Ltd.`,
   iconPath: ICON_PATH,
 };

redisinsight/api/src/app.module.ts

@@ -11,6 +11,7 @@ import config from 'src/utils/config';
 import { PluginModule } from 'src/modules/plugin/plugin.module';
 import { CommandsModule } from 'src/modules/commands/commands.module';
 import { WorkbenchModule } from 'src/modules/workbench/workbench.module';
+import { SlowLogModule } from 'src/modules/slow-log/slow-log.module';
 import { SharedModule } from './modules/shared/shared.module';
 import { InstancesModule } from './modules/instances/instances.module';
 import { BrowserModule } from './modules/browser/browser.module';
@@ -42,6 +43,7 @@ const PATH_CONFIG = config.get('dir_path');
     PluginModule,
     CommandsModule,
     ProfilerModule,
+    SlowLogModule,
     EventEmitterModule.forRoot(),
     ...(SERVER_CONFIG.staticContent
       ? [

redisinsight/api/src/app.routes.ts

@@ -5,6 +5,7 @@ import { RedisEnterpriseModule } from 'src/modules/redis-enterprise/redis-enterp
 import { RedisSentinelModule } from 'src/modules/redis-sentinel/redis-sentinel.module';
 import { CliModule } from 'src/modules/cli/cli.module';
 import { WorkbenchModule } from 'src/modules/workbench/workbench.module';
+import { SlowLogModule } from 'src/modules/slow-log/slow-log.module';
 
 export const routes: Routes = [
   {
@@ -23,6 +24,10 @@ export const routes: Routes = [
         path: '/:dbInstance',
         module: WorkbenchModule,
       },
+      {
+        path: '/:dbInstance',
+        module: SlowLogModule,
+      },
     ],
   },
   {

redisinsight/api/src/constants/telemetry-events.ts

@@ -41,4 +41,8 @@ export enum TelemetryEvents {
   // Profiler
   ProfilerLogDownloaded = 'PROFILER_LOG_DOWNLOADED',
   ProfilerLogDeleted = 'PROFILER_LOG_DELETED',
+
+  // Slowlog
+  SlowlogSetLogSlowerThan = 'SLOWLOG_SET_LOG_SLOWER_THAN',
+  SlowlogSetMaxLen = 'SLOWLOG_SET_MAX_LEN',
 }

redisinsight/api/src/modules/browser/browser.module.ts

@@ -2,6 +2,8 @@ import { MiddlewareConsumer, Module, NestModule } from '@nestjs/common';
 import { RouterModule } from 'nest-router';
 import { SharedModule } from 'src/modules/shared/shared.module';
 import { RedisConnectionMiddleware } from 'src/middleware/redis-connection.middleware';
+import { StreamController } from 'src/modules/browser/controllers/stream/stream.controller';
+import { StreamService } from 'src/modules/browser/services/stream/stream.service';
 import { HashController } from './controllers/hash/hash.controller';
 import { KeysController } from './controllers/keys/keys.controller';
 import { KeysBusinessService } from './services/keys-business/keys-business.service';
@@ -29,6 +31,7 @@ import { BrowserToolClusterService } from './services/browser-tool-cluster/brows
     ZSetController,
     RejsonRlController,
     HashController,
+    StreamController,
   ],
   providers: [
     KeysBusinessService,
@@ -38,6 +41,7 @@ import { BrowserToolClusterService } from './services/browser-tool-cluster/brows
     ZSetBusinessService,
     RejsonRlBusinessService,
     HashBusinessService,
+    StreamService,
     BrowserToolService,
     BrowserToolClusterService,
   ],

redisinsight/api/src/modules/browser/constants/browser-tool-commands.ts

@@ -75,6 +75,11 @@ export enum BrowserToolGraphCommands {
 }
 export enum BrowserToolStreamCommands {
   XLen = 'xlen',
+  XInfoStream = 'xinfo stream',
+  XRange = 'xrange',
+  XRevRange = 'xrevrange',
+  XAdd = 'xadd',
+  XDel = 'xdel',
 }
 
 export enum BrowserToolTSCommands {

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

@@ -0,0 +1,101 @@
+import {
+  Body,
+  Controller,
+  Delete,
+  Param,
+  Post,
+  UsePipes,
+  ValidationPipe,
+} from '@nestjs/common';
+import { ApiTags } from '@nestjs/swagger';
+import { ApiRedisInstanceOperation } from 'src/decorators/api-redis-instance-operation.decorator';
+import {
+  AddStreamEntriesDto, AddStreamEntriesResponse,
+  CreateStreamDto,
+  GetStreamEntriesDto,
+  GetStreamEntriesResponse,
+  DeleteStreamEntriesDto,
+  DeleteStreamEntriesResponse,
+} from 'src/modules/browser/dto/stream.dto';
+import { StreamService } from 'src/modules/browser/services/stream/stream.service';
+
+@ApiTags('Streams')
+@Controller('streams')
+@UsePipes(new ValidationPipe({ transform: true }))
+export class StreamController {
+  constructor(private service: StreamService) {}
+
+  @Post('')
+  @ApiRedisInstanceOperation({
+    description: 'Create stream',
+    statusCode: 201,
+  })
+  async createStream(
+    @Param('dbInstance') instanceId: string,
+      @Body() dto: CreateStreamDto,
+  ): Promise<void> {
+    return this.service.createStream({ instanceId }, dto);
+  }
+
+  @Post('entries')
+  @ApiRedisInstanceOperation({
+    description: 'Add entries to the stream',
+    statusCode: 200,
+    responses: [
+      {
+        status: 200,
+        description: 'Returns entries IDs added',
+        type: AddStreamEntriesResponse,
+      },
+    ],
+  })
+  async addEntries(
+    @Param('dbInstance') instanceId: string,
+      @Body() dto: AddStreamEntriesDto,
+  ): Promise<AddStreamEntriesResponse> {
+    return this.service.addEntries({ instanceId }, dto);
+  }
+
+  @Post('/entries/get')
+  @ApiRedisInstanceOperation({
+    description: 'Get stream entries',
+    statusCode: 200,
+    responses: [
+      {
+        status: 200,
+        description: 'Returns ordered stream entries in defined range.',
+        type: GetStreamEntriesResponse,
+      },
+    ],
+  })
+  async getEntries(
+    @Param('dbInstance') instanceId: string,
+      @Body() dto: GetStreamEntriesDto,
+  ): Promise<GetStreamEntriesResponse> {
+    return this.service.getEntries({ instanceId }, dto);
+  }
+
+  @Delete('/entries')
+  @ApiRedisInstanceOperation({
+    description: 'Remove the specified entries from the Stream stored at key',
+    statusCode: 200,
+    responses: [
+      {
+        status: 200,
+        description: 'Ok',
+        type: DeleteStreamEntriesResponse,
+      },
+    ],
+  })
+  async deleteEntries(
+    @Param('dbInstance') dbInstance: string,
+      @Body() dto: DeleteStreamEntriesDto,
+  ): Promise<DeleteStreamEntriesResponse> {
+    return await this.service.deleteEntries(
+      {
+        instanceId: dbInstance,
+      },
+      dto,
+    );
+  }
+}