chore: Update ioredis dependency to version 5.4.1

Author: tacxou

package.json

@@ -21,47 +21,47 @@
     "test:e2e": "jest --config ./test/jest-e2e.json"
   },
   "dependencies": {
-    "@nestjs-modules/ioredis": "^1.0.1",
-    "@nestjs/common": "^10.0.0",
-    "@nestjs/config": "^3.1.1",
-    "@nestjs/core": "^10.0.0",
+    "@nestjs-modules/ioredis": "^2.0.2",
+    "@nestjs/common": "^10.3.8",
+    "@nestjs/config": "^3.2.2",
+    "@nestjs/core": "^10.3.8",
     "@nestjs/event-emitter": "^2.0.4",
-    "@nestjs/platform-express": "^10.0.0",
-    "bullmq": "^4.13.2",
+    "@nestjs/platform-express": "^10.3.8",
+    "bullmq": "^5.7.8",
     "class-transformer": "^0.5.1",
-    "class-validator": "^0.14.0",
+    "class-validator": "^0.14.1",
     "fdir": "^6.1.1",
-    "ioredis": "^5.3.2",
+    "ioredis": "^5.4.1",
     "radash": "^12.1.0",
-    "reflect-metadata": "^0.1.13",
+    "reflect-metadata": "^0.2.2",
     "rxjs": "^7.8.1",
     "types-package-json": "^2.0.39",
-    "yaml": "^2.3.4"
+    "yaml": "^2.4.2"
   },
   "devDependencies": {
-    "@nestjs/cli": "^10.0.0",
-    "@nestjs/schematics": "^10.0.0",
-    "@nestjs/testing": "^10.0.0",
-    "@swc/cli": "^0.1.63",
-    "@swc/core": "^1.3.100",
-    "@types/express": "^4.17.17",
-    "@types/jest": "^29.5.2",
-    "@types/node": "^20.3.1",
-    "@types/supertest": "^2.0.12",
-    "@typescript-eslint/eslint-plugin": "^6.0.0",
-    "@typescript-eslint/parser": "^6.0.0",
-    "eslint": "^8.42.0",
-    "eslint-config-prettier": "^9.0.0",
-    "eslint-plugin-prettier": "^5.0.0",
-    "jest": "^29.5.0",
-    "prettier": "^3.0.0",
+    "@nestjs/cli": "^10.3.2",
+    "@nestjs/schematics": "^10.1.1",
+    "@nestjs/testing": "^10.3.8",
+    "@swc/cli": "^0.3.12",
+    "@swc/core": "^1.5.7",
+    "@types/express": "^4.17.21",
+    "@types/jest": "^29.5.12",
+    "@types/node": "^20.12.12",
+    "@types/supertest": "^6.0.2",
+    "@typescript-eslint/eslint-plugin": "^7.9.0",
+    "@typescript-eslint/parser": "^7.9.0",
+    "eslint": "^9.2.0",
+    "eslint-config-prettier": "^9.1.0",
+    "eslint-plugin-prettier": "^5.1.3",
+    "jest": "^29.7.0",
+    "prettier": "^3.2.5",
     "source-map-support": "^0.5.21",
-    "supertest": "^6.3.3",
-    "ts-jest": "^29.1.0",
-    "ts-loader": "^9.4.3",
-    "ts-node": "^10.9.1",
+    "supertest": "^7.0.0",
+    "ts-jest": "^29.1.2",
+    "ts-loader": "^9.5.1",
+    "ts-node": "^10.9.2",
     "tsconfig-paths": "^4.2.0",
-    "typescript": "^5.1.3"
+    "typescript": "^5.4.5"
   },
   "jest": {
     "moduleFileExtensions": [

src/_common/tasks/executor.task.ts

@@ -11,12 +11,16 @@ export async function executorTask(
 ): Promise<ExecutorResponseInterface> {
   return new Promise((resolve, reject) => {
     const jobDataArg = JSON.stringify(job.data);
-    const escapedJobDataArg = `'${jobDataArg.replace(/'/g, "'\\''")}'`;
+    // const escapedJobDataArg = `'${jobDataArg.replace(/'/g, "'\\''")}'`;
 
-    const child = spawn(join(command), [escapedJobDataArg], {
+    const child = spawn(join(command), {
       shell: options?.shell ?? true,
+      // stdio: 'pipe',
     });
 
+    child.stdin.write(jobDataArg);
+    child.stdin.end();
+
     let outputChunk = '';
     let errorChunk = '';
 

src/app.module.ts

@@ -16,14 +16,13 @@ import { RedisOptions } from 'ioredis';
       imports: [ConfigModule],
       inject: [ConfigService],
       useFactory: async (config: ConfigService) => ({
-        config: {
-          ...config.get<RedisOptions>('ioredis.options'),
-          url: config.get<string>('ioredis.uri'),
-        },
+        type: 'single',
+        url: config.get<string>('ioredis.uri'),
+        options: config.get<RedisOptions>('ioredis.options'),
       }),
     }),
     BackendRunnerModule,
   ],
   providers: [AppService],
 })
-export class AppModule {}
+export class AppModule { }

src/backend-runner/backend-runner.service.ts

@@ -1,4 +1,4 @@
-import { InjectRedis, Redis } from '@nestjs-modules/ioredis';
+import { InjectRedis } from '@nestjs-modules/ioredis';
 import { Injectable, Logger, OnApplicationBootstrap, OnModuleInit } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
 import { Worker } from 'bullmq';
@@ -8,6 +8,7 @@ import { ExecutorExecuteResponseInterface, ExecutorInterface } from './executors
 import { BackendConfigService } from './backend-config.service';
 import { ActionType } from './_enum/action-type.enum';
 import { ExecutorConfigInterface } from '~/_common/interfaces/executor-config.interface';
+import Redis from 'ioredis';
 
 @Injectable()
 export class BackendRunnerService implements OnApplicationBootstrap, OnModuleInit {
@@ -31,7 +32,7 @@ export class BackendRunnerService implements OnApplicationBootstrap, OnModuleIni
     private readonly _config: ConfigService,
     private readonly _backendsConfig: BackendConfigService,
     @InjectRedis() private readonly redis: Redis,
-  ) {}
+  ) { }
 
   public async onModuleInit() {
     this.executors.set('*', new CatchAllExecutor(this));

src/config.ts

@@ -29,6 +29,7 @@ export default (): ConfigInstance => {
       uri: process.env['SESAME_REDIS_URI'] || 'redis://localhost:6379/0',
       options: {
         showFriendlyErrorStack: true,
+        maxRetriesPerRequest: null,
       },
     },
   };