Admin api

packages/node-core/src/configure/ProjectUpgrade.service.ts

@@ -278,7 +278,7 @@ export class ProjectUpgradeService<P extends ISubqueryProject = ISubqueryProject
           await this.migrate(project, newProject, undefined);
         }
       } catch (e: any) {
-        exitWithError(`Failed to complete upgrading project, ${e}`, logger, 1);
+        exitWithError(new Error(`Failed to complete upgrading project`, {cause: e}), logger, 1);
       }
 
       logger.info(`Project upgraded to ${newProject.id} at height ${height}`);

packages/node-core/src/db/db.module.ts

@@ -45,7 +45,7 @@ async function establishConnectionSequelize(option: SequelizeOption, numRetries:
       await delay(3);
       return establishConnectionSequelize(option, numRetries - 1);
     } else {
-      exitWithError(`Unable to connect to the database,${error}`, logger);
+      exitWithError(new Error(`Unable to connect to the database`, {cause: error}), logger);
     }
   }
   return sequelize;

packages/node-core/src/indexer/blockDispatcher/base-block-dispatcher.ts

@@ -194,6 +194,7 @@ export abstract class BaseBlockDispatcher<Q extends IQueue, DS, B> implements IB
         return;
       } catch (e: any) {
         this.eventEmitter.emit(IndexerEvent.RewindFailure, {success: false, message: e.message});
+        monitorWrite(`***** Rewind failed: ${e.message}`);
         throw e;
       }
     } else {
@@ -217,7 +218,7 @@ export abstract class BaseBlockDispatcher<Q extends IQueue, DS, B> implements IB
     if (this.nodeConfig.storeCacheAsync) {
       // Flush all completed block data and don't wait
       await this.storeCacheService.flushAndWaitForCapacity(false)?.catch((e) => {
-        exitWithError(`Flushing cache failed,${e}`, logger);
+        exitWithError(new Error(`Flushing cache failed`, {cause: e}), logger);
       });
     } else {
       // Flush all data from cache and wait
@@ -226,9 +227,8 @@ export abstract class BaseBlockDispatcher<Q extends IQueue, DS, B> implements IB
 
     if (!this.projectService.hasDataSourcesAfterHeight(height)) {
       const msg = `All data sources have been processed up to block number ${height}. Exiting gracefully...`;
-      logger.info(msg);
       await this.storeCacheService.flushCache(false);
-      exitWithError(msg, undefined, 0);
+      exitWithError(msg, logger, 0);
     }
   }
 

packages/node-core/src/indexer/blockDispatcher/block-dispatcher.ts

@@ -197,7 +197,7 @@ export abstract class BlockDispatcher<B, DS>
               // Do nothing, fetching the block was flushed, this could be caused by forked blocks or dynamic datasources
               return;
             }
-            exitWithError(`Failed to enqueue fetched block to process,${e}`, logger);
+            exitWithError(new Error(`Failed to enqueue fetched block to process`, {cause: e}), logger);
           });
 
         this.eventEmitter.emit(IndexerEvent.BlockQueueSize, {
@@ -206,7 +206,7 @@ export abstract class BlockDispatcher<B, DS>
       }
     } catch (e: any) {
       if (!this.isShutdown) {
-        exitWithError(`Failed to process blocks from queue,${e}`, logger);
+        exitWithError(new Error(`Failed to process blocks from queue`, {cause: e}), logger);
       }
     } finally {
       this.fetching = false;

packages/node-core/src/indexer/dynamic-ds.service.ts

@@ -81,7 +81,7 @@ export abstract class DynamicDsService<DS, P extends ISubqueryProject = ISubquer
 
       return ds;
     } catch (e: any) {
-      exitWithError(`Failed to create dynamic ds, ${e}`, logger);
+      exitWithError(new Error(`Failed to create dynamic ds`, {cause: e}), logger);
     }
   }
 

packages/node-core/src/indexer/poi/poiSync.service.ts

@@ -156,7 +156,7 @@ export class PoiSyncService implements OnApplicationShutdown {
       this.isSyncing = false;
     } catch (e) {
       this.isSyncing = false;
-      exitWithError(`Failed to sync poi: ${e}`, logger);
+      exitWithError(new Error(`Failed to sync poi`, {cause: e}), logger);
     }
   }
 

packages/node-core/src/indexer/store.service.ts

@@ -152,7 +152,7 @@ export class StoreService {
     try {
       await this.syncSchema(schema);
     } catch (e: any) {
-      exitWithError(`Having a problem when syncing schema, ${e}`, logger);
+      exitWithError(new Error(`Having a problem when syncing schema`, {cause: e}), logger);
     }
     await this.updateModels(schema, modelsRelations);
   }
@@ -209,7 +209,7 @@ export class StoreService {
     try {
       this._modelIndexedFields = await this.getAllIndexFields(schema);
     } catch (e: any) {
-      exitWithError(`Having a problem when get indexed fields, ${e}`, logger);
+      exitWithError(new Error(`Having a problem when get indexed fields`, {cause: e}), logger);
     }
   }
 

packages/node-core/src/indexer/storeCache/csvStore.service.ts

@@ -18,7 +18,7 @@ export class CsvStoreService implements Exporter {
     this.writeStream = fs.createWriteStream(this.getCsvFilePath(), {flags: 'a'});
 
     this.stringifyStream = stringify({header: !this.fileExist}).on('error', (err) => {
-      exitWithError(`Failed to write to CSV,${err}`, logger);
+      exitWithError(new Error(`Failed to write to CSV`, err), logger);
     });
     this.stringifyStream.pipe(this.writeStream);
   }

packages/node-core/src/subcommands/foreceClean.init.ts

@@ -14,7 +14,7 @@ export async function forceClean(forceCleanModule: any): Promise<void> {
     const forceCleanService = app.get(ForceCleanService);
     await forceCleanService.forceClean();
   } catch (e: any) {
-    exitWithError(`Force-clean failed to execute,${e}`, logger);
+    exitWithError(new Error(`Force-clean failed to execute`, {cause: e}), logger);
   }
 
   process.exit(0);

packages/node-core/src/subcommands/reindex.init.ts

@@ -23,7 +23,7 @@ export async function reindexInit(reindexModule: any, targetHeight: number): Pro
     }
     await reindexService.reindex(actualReindexHeight);
   } catch (e: any) {
-    exitWithError(`Reindex failed to execute,${e}`, logger);
+    exitWithError(new Error(`Reindex failed to execute`, {cause: e}), logger);
   }
   process.exit(0);
 }

packages/node-core/src/utils/project.ts

@@ -61,7 +61,7 @@ export async function getExistingProjectSchema(
     });
     schemas = result.map((x: any) => x.schema_name);
   } catch (err) {
-    exitWithError(`Unable to fetch all schemas: ${err}`, logger);
+    exitWithError(new Error(`Unable to fetch all schemas`, {cause: err}), logger);
   }
   if (!schemas.includes(schema)) {
     return undefined;

packages/node-core/tsconfig.json

@@ -7,7 +7,9 @@
     "noImplicitAny": true,
     "esModuleInterop": true,
     "importHelpers": true,
-    "strict": true
+    "strict": true,
+    "target": "ES2022",
+    "lib": ["ES2022"]
   },
   "references": [{"path": "../common"}, {"path": "../utils"}, {"path": "../testing"}],
   "include": ["src/**/*"]

packages/node/src/indexer/api.service.ts

@@ -98,7 +98,7 @@ export class ApiService
         network.endpoint.push(this.nodeConfig.primaryNetworkEndpoint);
       }
     } catch (e) {
-      exitWithError(e, logger);
+      exitWithError(new Error(`Failed to init api`, { cause: e }), logger);
     }
 
     if (chainTypes) {

packages/node/src/init.ts

@@ -47,6 +47,6 @@ export async function bootstrap(): Promise<void> {
 
     logger.info(`Node started on port: ${port}`);
   } catch (e) {
-    exitWithError(`Node failed to start,${e}`, logger);
+    exitWithError(new Error(`Node failed to start`, { cause: e }), logger);
   }
 }

packages/node/src/subcommands/testing.init.ts

@@ -13,7 +13,7 @@ export async function testingInit(): Promise<void> {
     const testingService = new TestingService(nodeConfig, project);
     await testingService.run();
   } catch (e) {
-    exitWithError(`Testing failed,${e}`, logger);
+    exitWithError(new Error('Testing failed', { cause: e }), logger);
   }
   process.exit(0);
 }

packages/node/tsconfig.json

@@ -1,7 +1,8 @@
 {
   "extends": "../../tsconfig.json",
   "compilerOptions": {
-    "target": "es2017",
+    "target": "ES2022",
+    "lib": ["ES2022"],
     "sourceMap": true,
     "tsBuildInfoFile": "dist/.tsbuildinfo",
     "rootDir": "src",