Make method to update state status map synchronous

cerc-io · Oct 19, 2022 · 4baaa81 · 4baaa81
1 parent 042d616
commit 4baaa81
Show file tree

Hide file tree

Showing 9 changed files with 16 additions and 16 deletions.
diff --git a/packages/codegen/src/templates/indexer-template.handlebars b/packages/codegen/src/templates/indexer-template.handlebars
@@ -523,8 +523,8 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.watchContract(address, kind, checkpoint, startingBlock);
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
-    await this._baseIndexer.updateStateStatusMap(address, stateStatus);
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
+    this._baseIndexer.updateStateStatusMap(address, stateStatus);
   }
 
   cacheContract (contract: Contract): void {

diff --git a/packages/eden-watcher/src/indexer.ts b/packages/eden-watcher/src/indexer.ts
@@ -458,8 +458,8 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.watchContract(address, kind, checkpoint, startingBlock);
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
-    await this._baseIndexer.updateStateStatusMap(address, stateStatus);
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
+    this._baseIndexer.updateStateStatusMap(address, stateStatus);
   }
 
   cacheContract (contract: Contract): void {

diff --git a/packages/erc20-watcher/src/indexer.ts b/packages/erc20-watcher/src/indexer.ts
@@ -342,8 +342,8 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.watchContract(address, kind, checkpoint, startingBlock);
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
-    await this._baseIndexer.updateStateStatusMap(address, stateStatus);
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
+    this._baseIndexer.updateStateStatusMap(address, stateStatus);
   }
 
   cacheContract (contract: Contract): void {

diff --git a/packages/erc721-watcher/src/indexer.ts b/packages/erc721-watcher/src/indexer.ts
@@ -825,8 +825,8 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.watchContract(address, kind, checkpoint, startingBlock);
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
-    await this._baseIndexer.updateStateStatusMap(address, stateStatus);
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
+    this._baseIndexer.updateStateStatusMap(address, stateStatus);
   }
 
   cacheContract (contract: Contract): void {

diff --git a/packages/graph-node/test/utils/indexer.ts b/packages/graph-node/test/utils/indexer.ts
@@ -194,7 +194,7 @@ export class Indexer implements IndexerInterface {
     return undefined;
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
     return undefined;
   }
 }

diff --git a/packages/graph-test-watcher/src/indexer.ts b/packages/graph-test-watcher/src/indexer.ts
@@ -454,8 +454,8 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.watchContract(address, kind, checkpoint, startingBlock);
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
-    await this._baseIndexer.updateStateStatusMap(address, stateStatus);
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
+    this._baseIndexer.updateStateStatusMap(address, stateStatus);
   }
 
   cacheContract (contract: Contract): void {

diff --git a/packages/mobymask-watcher/src/indexer.ts b/packages/mobymask-watcher/src/indexer.ts
@@ -552,8 +552,8 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.watchContract(address, kind, checkpoint, startingBlock);
   }
 
-  async updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void> {
-    await this._baseIndexer.updateStateStatusMap(address, stateStatus);
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void {
+    this._baseIndexer.updateStateStatusMap(address, stateStatus);
   }
 
   cacheContract (contract: Contract): void {

diff --git a/packages/util/src/job-runner.ts b/packages/util/src/job-runner.ts
@@ -81,7 +81,7 @@ export class JobRunner {
         break;
 
       case JOB_KIND_CONTRACT:
-        await this._updateWatchedContracts(job);
+        this._updateWatchedContracts(job);
         break;
 
       default:
@@ -375,7 +375,7 @@ export class JobRunner {
     }
   }
 
-  async _updateWatchedContracts (job: any): Promise<void> {
+  _updateWatchedContracts (job: any): void {
     const { data: { contract } } = job;
 
     assert(this._indexer.cacheContract);

diff --git a/packages/util/src/types.ts b/packages/util/src/types.ts
@@ -119,7 +119,7 @@ export interface IndexerInterface {
   processCheckpoint (blockHash: string): Promise<void>
   getStorageValue (storageLayout: StorageLayout, blockHash: string, contractAddress: string, variable: string, ...mappingKeys: MappingKey[]): Promise<ValueResult>
   updateSubgraphState?: (contractAddress: string, data: any) => void
-  updateStateStatusMap (address: string, stateStatus: StateStatus): Promise<void>
+  updateStateStatusMap (address: string, stateStatus: StateStatus): void
   getStateData (state: StateInterface): any
 }