chore: Remove unused imports and code

Author: tacxou

src/app.service.ts

@@ -1,20 +1,20 @@
 import { Injectable } from '@nestjs/common';
 import { ModuleRef } from '@nestjs/core';
 import { AbstractService } from './_common/abstracts/abstract.service';
-import { PackageJson } from 'types-package-json';
+// import { PackageJson } from 'types-package-json';
 //import { readFileSync } from 'node:fs';
 //import { pick } from 'radash';
 
 @Injectable()
 export class AppService extends AbstractService {
-  protected package: Partial<PackageJson>;
+  // protected package: Partial<PackageJson>;
 
   public constructor(protected moduleRef: ModuleRef) {
     super({ moduleRef });
     //this.package = JSON.parse(readFileSync('package.json', 'utf-8'));
   }
 
-//  public getInfo(): Partial<PackageJson> {
+  //  public getInfo(): Partial<PackageJson> {
   //  return pick(this.package, ['name', 'version']);
-//  }
+  //  }
 }

src/backend-runner/_executors/catch-all.executor.ts

@@ -17,7 +17,7 @@ interface ValidationRecursive {
 export class CatchAllExecutor implements ExecutorInterface {
   public constructor(public service: BackendRunnerService) { }
 
-  public async execute({ job }): Promise<ExecutorExecuteResponseInterface> {
+  public async execute({ job }: { job: Job<any, any, string> }): Promise<ExecutorExecuteResponseInterface> {
     let status = 0;
     const data = [];
 
@@ -36,6 +36,7 @@ export class CatchAllExecutor implements ExecutorInterface {
 
       if (backend.actions[job.name].onError === 'stop' && result.status !== 0) {
         this.service.logger.log('stop on Error');
+        await job.updateProgress(100);
         break;
       }
 

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

@@ -10,14 +10,14 @@ import { ActionType } from './_enum/action-type.enum';
 import { ExecutorConfigInterface } from '~/_common/interfaces/executor-config.interface';
 import Redis from 'ioredis';
 import { DumpPackageConfigExecutor } from './_executors/dump-package-config.executor';
-import { PackageJson } from 'types-package-json';
+// import { PackageJson } from 'types-package-json';
 import { readFileSync } from 'node:fs';
 //import { PackageJson } from 'types-package-json';
 //import { readFileSync } from 'node:fs';
 
 @Injectable()
 export class BackendRunnerService implements OnApplicationBootstrap, OnModuleInit {
-  protected _package: Partial<PackageJson>;
+  protected _package: Partial<any>;
   private readonly _logger = new Logger(BackendRunnerService.name);
 
   protected executors: Map<string, ExecutorInterface> = new Map<string, ExecutorInterface>();
@@ -30,7 +30,7 @@ export class BackendRunnerService implements OnApplicationBootstrap, OnModuleIni
     return this._logger;
   }
 
-  public get packageJson(): Partial<PackageJson> {
+  public get packageJson(): Partial<any> {
     return this._package;
   }
 
@@ -43,13 +43,14 @@ export class BackendRunnerService implements OnApplicationBootstrap, OnModuleIni
     private readonly _backendsConfig: BackendConfigService,
     @InjectRedis() private readonly redis: Redis,
   ) {
-    try {
-
-      this._package = JSON.parse(readFileSync('package.json', 'utf-8'));
-    } catch (e) {
-      this._logger.error('Error reading package.json file: ', e);
-      this._package = {};
-    }
+    console.log('pkg', (process as any).pkg)
+    this._package = {};
+    // try {
+    //   this._package = JSON.parse(readFileSync('package.json', 'utf-8'));
+    // } catch (e) {
+    //   this._logger.error('Error reading package.json file: ', e);
+    //   this._package = {};
+    // }
   }
 
   public async onModuleInit() {
@@ -77,13 +78,14 @@ export class BackendRunnerService implements OnApplicationBootstrap, OnModuleIni
         this.logger.verbose(`Job ${job.name} executed with status ${result.status}`);
 
         if (result.status !== 0) {
-          this.logger.error(`Job ${job.name} failed with status ${result.status}`);
           const errMsg = []
+          this.logger.error(`Job ${job.name} failed with status ${result.status}`);
+
           for (const data of result.data) {
             errMsg.push(data?.error?.message || 'No error message');
           }
 
-          throw new UnrecoverableError(`Job ${job.name} failed with status ${result.status}: ${errMsg.join(', ')}`);
+          return result;
         }
 
         this.logger.log(`Job ${job.name} success with status ${result.status}`);