Fix bigint and decimal transformers not added for null type entity field in codegen (#451)

packages/cli/src/job-runner.ts

@@ -108,6 +108,7 @@ export class JobRunnerCmd {
 
     const jobRunner = new JobRunner(config.jobQueue, indexer, jobQueue);
 
+    // Delete all active and pending (before completed) jobs to start job-runner without old queued jobs
     await jobRunner.jobQueue.deleteAllJobs('completed');
     await jobRunner.resetToPrevIndexedBlock();
 

packages/cli/src/server.ts

@@ -281,7 +281,7 @@ export class ServerCmd {
     assert(eventWatcher);
 
     if (config.server.kind === KIND_ACTIVE) {
-      // Delete jobs before completed state to prevent creating jobs after completion of processing previous block.
+      // Delete all active and pending (before completed) jobs to prevent creating jobs after completion of processing previous block
       await jobQueue.deleteAllJobs('completed');
       await eventWatcher.start();
     }

packages/codegen/src/entity.ts

@@ -347,45 +347,46 @@ export class Entity {
     });
 
     entityObject.columns.forEach((column: any) => {
-      // Implement bigintTransformer for bigint type.
+      if (column.tsType.includes('bigint')) {
-      if (column.tsType === 'bigint') {
+        // Check if it is of array type
-        column.columnOptions.push(
+        if (column.tsType.includes('bigint[]')) {
-          {
+          // Implement bigintArrayTransformer for array of bigint type.
-            option: 'transformer',
+          column.columnOptions.push(
-            value: 'bigintTransformer'
+            {
+              option: 'transformer',
+              value: 'bigintArrayTransformer'
+            }
+          );
+
+          if (importObject) {
+            importObject.toImport.add('bigintArrayTransformer');
+          } else {
+            importObject = {
+              toImport: new Set(['bigintArrayTransformer']),
+              from: '@cerc-io/util'
+            };
+
+            entityObject.imports.push(importObject);
           }
-        );
-
-        if (importObject) {
-          importObject.toImport.add('bigintTransformer');
         } else {
-          importObject = {
+          // Implement bigintTransformer for bigint type.
-            toImport: new Set(['bigintTransformer']),
+          column.columnOptions.push(
-            from: '@cerc-io/util'
+            {
-          };
+              option: 'transformer',
+              value: 'bigintTransformer'
+            }
+          );
 
-          entityObject.imports.push(importObject);
+          if (importObject) {
-        }
+            importObject.toImport.add('bigintTransformer');
-      }
+          } else {
+            importObject = {
+              toImport: new Set(['bigintTransformer']),
+              from: '@cerc-io/util'
+            };
 
-      // Implement bigintArrayTransformer for array of bigint type.
+            entityObject.imports.push(importObject);
-      if (column.tsType === 'bigint[]') {
-        column.columnOptions.push(
-          {
-            option: 'transformer',
-            value: 'bigintArrayTransformer'
           }
-        );
-
-        if (importObject) {
-          importObject.toImport.add('bigintArrayTransformer');
-        } else {
-          importObject = {
-            toImport: new Set(['bigintArrayTransformer']),
-            from: '@cerc-io/util'
-          };
-
-          entityObject.imports.push(importObject);
         }
       }
     });
@@ -399,49 +400,48 @@ export class Entity {
     let isDecimalRequired = false;
 
     entityObject.columns.forEach((column: any) => {
-      // Implement decimalTransformer for Decimal type.
+      if (column.tsType.includes('Decimal')) {
-      if (column.tsType === 'Decimal') {
         isDecimalRequired = true;
 
-        column.columnOptions.push(
+        // Check if it is of array type
-          {
+        if (column.tsType.includes('Decimal[]')) {
-            option: 'transformer',
+          // Implement decimalArrayTransformer for array of Decimal type.
-            value: 'decimalTransformer'
+          column.columnOptions.push(
+            {
+              option: 'transformer',
+              value: 'decimalArrayTransformer'
+            }
+          );
+
+          if (importObject) {
+            importObject.toImport.add('decimalArrayTransformer');
+          } else {
+            importObject = {
+              toImport: new Set(['decimalArrayTransformer']),
+              from: '@cerc-io/util'
+            };
+
+            entityObject.imports.push(importObject);
           }
-        );
-
-        if (importObject) {
-          importObject.toImport.add('decimalTransformer');
         } else {
-          importObject = {
+          // Implement decimalTransformer for Decimal type.
-            toImport: new Set(['decimalTransformer']),
+          column.columnOptions.push(
-            from: '@cerc-io/util'
+            {
-          };
+              option: 'transformer',
+              value: 'decimalTransformer'
+            }
+          );
 
-          entityObject.imports.push(importObject);
+          if (importObject) {
-        }
+            importObject.toImport.add('decimalTransformer');
-      }
+          } else {
+            importObject = {
+              toImport: new Set(['decimalTransformer']),
+              from: '@cerc-io/util'
+            };
 
-      // Implement decimalArrayTransformer for array of Decimal type.
+            entityObject.imports.push(importObject);
-      if (column.tsType === 'Decimal[]') {
-        isDecimalRequired = true;
-
-        column.columnOptions.push(
-          {
-            option: 'transformer',
-            value: 'decimalArrayTransformer'
           }
-        );
-
-        if (importObject) {
-          importObject.toImport.add('decimalArrayTransformer');
-        } else {
-          importObject = {
-            toImport: new Set(['decimalArrayTransformer']),
-            from: '@cerc-io/util'
-          };
-
-          entityObject.imports.push(importObject);
         }
       }
     });

packages/codegen/src/templates/indexer-template.handlebars

@@ -661,6 +661,14 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.fetchEventsAndSaveBlocks(blocks, this._eventSignaturesMap, this.parseEventNameAndArgs.bind(this));
   }
 
+  async fetchAndSaveFilteredEventsAndBlocks (startBlock: number, endBlock: number): Promise<{ blockProgress: BlockProgress, events: DeepPartial<Event>[] }[]> {
+    return this._baseIndexer.fetchAndSaveFilteredEventsAndBlocks(startBlock, endBlock, this._eventSignaturesMap, this.parseEventNameAndArgs.bind(this));
+  }
+
+  async fetchEventsForContracts (blockHash: string, blockNumber: number, addresses: string[]): Promise<DeepPartial<Event>[]> {
+    return this._baseIndexer.fetchEventsForContracts(blockHash, blockNumber, addresses, this._eventSignaturesMap, this.parseEventNameAndArgs.bind(this));
+  }
+
   async saveBlockAndFetchEvents (block: DeepPartial<BlockProgress>): Promise<[BlockProgress, DeepPartial<Event>[]]> {
     return this._saveBlockAndFetchEvents(block);
   }

packages/util/src/job-runner.ts

@@ -171,7 +171,6 @@ export class JobRunner {
       } else {
         // Check that startBlock is one greater than previous batch end block
         if (startBlock - 1 !== this._historicalProcessingCompletedUpto) {
-          // TODO: Debug jobQueue deleteJobs for historical processing not working
           await this.jobQueue.markComplete(
             job,
             { isComplete: false }

packages/util/src/misc.ts

@@ -133,6 +133,7 @@ export const resetJobs = async (config: Config): Promise<void> => {
 
   const jobQueue = new JobQueue({ dbConnectionString, maxCompletionLag: maxCompletionLagInSecs });
   await jobQueue.start();
+  // Delete all active and pending (before completed) jobs
   await jobQueue.deleteAllJobs('completed');
 };