Merge pull request #2188 from RedisInsight/feature/RI-4502_triggered_functions

Feature/ri 4502 triggered functions

Author: mariasergeenko

.circleci/config.yml

@@ -173,10 +173,10 @@ orbs:
 executors:
   linux-executor:
     machine:
-      image: ubuntu-2004:202010-01
+      image: ubuntu-2004:2023.04.2
   linux-executor-dlc:
     machine:
-      image: ubuntu-2004:202010-01
+      image: ubuntu-2004:2023.04.2
       docker_layer_caching: true
 
 jobs:

configs/webpack.config.renderer.dev.ts

@@ -232,7 +232,7 @@ const configuration: webpack.Configuration = {
 
     new ReactRefreshWebpackPlugin(),
 
-    new MonacoWebpackPlugin({ languages: ['json'], features: ['!rename'] }),
+    new MonacoWebpackPlugin({ languages: ['json', 'javascript', 'typescript'], features: ['!rename'] }),
 
     ...htmlPagesNames.map((htmlPageName) => (
       new HtmlWebpackPlugin({

configs/webpack.config.renderer.prod.ts

@@ -180,7 +180,7 @@ const configuration: webpack.Configuration = {
   },
 
   plugins: [
-    new MonacoWebpackPlugin({ languages: ['json'], features: ['!rename'] }),
+    new MonacoWebpackPlugin({ languages: ['json', 'javascript', 'typescript'], features: ['!rename'] }),
 
     new webpack.EnvironmentPlugin({
       NODE_ENV: 'production',

configs/webpack.config.web.common.ts

@@ -70,7 +70,7 @@ export default {
 
     new HtmlWebpackPlugin({ template: 'index.html.ejs' }),
 
-    new MonacoWebpackPlugin({ languages: ['json'], features: ['!rename'] }),
+    new MonacoWebpackPlugin({ languages: ['json', 'javascript', 'typescript'], features: ['!rename'] }),
 
     new webpack.IgnorePlugin({
       checkResource(resource) {

redisinsight/__mocks__/monacoMock.js

@@ -15,8 +15,10 @@ export default function MonacoEditor(props) {
         createContextKey: jest.fn(),
         focus: jest.fn(),
         onDidChangeCursorPosition: jest.fn(),
+        onDidAttemptReadOnlyEdit: jest.fn(),
         executeEdits: jest.fn(),
-        updateOptions: jest.fn()
+        updateOptions: jest.fn(),
+        setSelection: jest.fn(),
       },
       // monaco
       {
@@ -57,3 +59,7 @@ export const languages = {
     InsertAsSnippet: 4
   }
 }
+
+export const monaco = {
+  Selection: jest.fn().mockImplementation(() => { return {} })
+}

redisinsight/api/src/__mocks__/index.ts

@@ -24,3 +24,4 @@ export * from './browser-history';
 export * from './database-recommendation';
 export * from './feature';
 export * from './cloud-autodiscovery';
+export * from './triggered-functions';

redisinsight/api/src/__mocks__/triggered-functions.ts

@@ -0,0 +1,36 @@
+export const mockCommonLibraryReply = [
+  'api_version', '1.0',
+  'engine', 'js',
+  'configuration', null,
+  'name', 'libraryName',
+  'pending_jobs', 0,
+  'user', 'default',
+];
+
+export const mockSimpleLibraryReply = [
+  'api_version', '1.0',
+  'engine', 'js',
+  'configuration', null,
+  'functions', ['foo'],
+  'keyspace_triggers', ['keyspace'],
+  'cluster_functions', ['cluster'],
+  'stream_triggers', ['stream'],
+  'name', 'libraryName',
+  'pending_jobs', 0,
+  'user', 'default',
+];
+
+export const mockVerboseLibraryReply = [
+  'api_version', '1.0',
+  'engine', 'js',
+  'configuration', null,
+  'name', 'libraryName',
+  'pending_jobs', 0,
+  'user', 'default',
+  'functions', [['name', 'function', 'description', 'description', 'is_async', 1, 'flags', ['flag1']]],
+  'keyspace_triggers', [],
+  'cluster_functions', ['foo', 'bar'],
+  'stream_triggers', [[
+    'name', 'stream', 'description', 'description', 'prefix', 'prefix', 'trim', 0, 'window', 1, 'streams', [['key', 'value']],
+  ]],
+];

redisinsight/api/src/app.module.ts

@@ -15,6 +15,7 @@ import { NotificationModule } from 'src/modules/notification/notification.module
 import { BulkActionsModule } from 'src/modules/bulk-actions/bulk-actions.module';
 import { ClusterMonitorModule } from 'src/modules/cluster-monitor/cluster-monitor.module';
 import { DatabaseAnalysisModule } from 'src/modules/database-analysis/database-analysis.module';
+import { TriggeredFunctionsModule } from 'src/modules/triggered-functions/triggered-functions.module';
 import { ServerModule } from 'src/modules/server/server.module';
 import { LocalDatabaseModule } from 'src/local-database.module';
 import { CoreModule } from 'src/core.module';
@@ -59,6 +60,7 @@ const PATH_CONFIG = config.get('dir_path');
     CustomTutorialModule.register(),
     DatabaseAnalysisModule,
     DatabaseImportModule,
+    TriggeredFunctionsModule,
     ...(SERVER_CONFIG.staticContent
       ? [
         ServeStaticModule.forRoot({

redisinsight/api/src/app.routes.ts

@@ -6,6 +6,7 @@ import { SlowLogModule } from 'src/modules/slow-log/slow-log.module';
 import { PubSubModule } from 'src/modules/pub-sub/pub-sub.module';
 import { ClusterMonitorModule } from 'src/modules/cluster-monitor/cluster-monitor.module';
 import { DatabaseAnalysisModule } from 'src/modules/database-analysis/database-analysis.module';
+import { TriggeredFunctionsModule } from 'src/modules/triggered-functions/triggered-functions.module';
 import { BulkActionsModule } from 'src/modules/bulk-actions/bulk-actions.module';
 import { DatabaseRecommendationModule } from 'src/modules/database-recommendation/database-recommendation.module';
 
@@ -49,6 +50,10 @@ export const routes: Routes = [
         path: '/:dbInstance',
         module: DatabaseRecommendationModule,
       },
+      {
+        path: '/:dbInstance',
+        module: TriggeredFunctionsModule,
+      },
     ],
   },
 ];

redisinsight/api/src/common/constants/recommendations.ts

@@ -1,11 +1,11 @@
 export enum SearchVisualizationCommands {
-  FT_INFO = "FT.INFO",
-  FT_SEARCH = "FT.SEARCH",
-  FT_AGGREGATE = "FT.AGGREGATE",
-  FT_PROFILE = "FT.PROFILE",
-  FT_EXPLAIN = "FT.EXPLAIN",
-  TS_RANGE = "TS.RANGE",
-  TS_MRANGE = "TS.MRANGE",
+  FT_INFO = 'FT.INFO',
+  FT_SEARCH = 'FT.SEARCH',
+  FT_AGGREGATE = 'FT.AGGREGATE',
+  FT_PROFILE = 'FT.PROFILE',
+  FT_EXPLAIN = 'FT.EXPLAIN',
+  TS_RANGE = 'TS.RANGE',
+  TS_MRANGE = 'TS.MRANGE',
 }
 
 export const LUA_SCRIPT_RECOMMENDATION_COUNT = 10;
@@ -23,3 +23,4 @@ export const COMBINE_SMALL_STRINGS_TO_HASHES_RECOMMENDATION_KEYS_COUNT = 10;
 export const SEARCH_HASH_RECOMMENDATION_KEYS_FOR_CHECK = 50;
 export const SEARCH_HASH_RECOMMENDATION_KEYS_LENGTH = 2;
 export const RTS_KEYS_FOR_CHECK = 100;
+export const LUA_TO_FUNCTIONS_RECOMMENDATION_COUNT = 0;