Add GQL query for sync status (#159)

* Add sync status GQL query

* Add sync status GQL query in codegen

packages/codegen/src/schema.ts

@@ -95,6 +95,9 @@ export class Schema {
     // Add a mutation for watching a contract.
     this._addWatchContractMutation();
 
+    // Add type and query for SyncStatus.
+    this._addSyncStatus();
+
     // Add IPLDBlock type and queries.
     this._addIPLDType();
     this._addIPLDQuery();
@@ -331,6 +334,26 @@ export class Schema {
     });
   }
 
+  _addSyncStatus (): void {
+    const typeComposer = this._composer.createObjectTC({
+      name: 'SyncStatus',
+      fields: {
+        latestIndexedBlockHash: 'String!',
+        latestIndexedBlockNumber: 'Int!',
+        latestCanonicalBlockHash: 'String!',
+        latestCanonicalBlockNumber: 'Int!'
+      }
+    });
+
+    this._composer.addSchemaMustHaveType(typeComposer);
+
+    this._composer.Query.addFields({
+      getSyncStatus: {
+        type: this._composer.getOTC('SyncStatus')
+      }
+    });
+  }
+
   _addIPLDType (): void {
     const typeComposer = this._composer.createObjectTC({
       name: 'ResultIPLDBlock',

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

@@ -114,12 +114,18 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
       },
 
-      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Diff }: { blockHash: string, contractAddress: string, kind: string }) => {
+      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Checkpoint }: { blockHash: string, contractAddress: string, kind: string }) => {
         log('getState', blockHash, contractAddress, kind);
 
         const ipldBlock = await indexer.getPrevIPLDBlock(blockHash, contractAddress, kind);
 
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
+      },
+
+      getSyncStatus: async () => {
+        log('getSyncStatus');
+
+        return indexer.getSyncStatus();
       }
     }
   };

packages/eden-watcher/src/resolvers.ts

@@ -217,12 +217,18 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
       },
 
-      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Diff }: { blockHash: string, contractAddress: string, kind: string }) => {
+      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Checkpoint }: { blockHash: string, contractAddress: string, kind: string }) => {
         log('getState', blockHash, contractAddress, kind);
 
         const ipldBlock = await indexer.getPrevIPLDBlock(blockHash, contractAddress, kind);
 
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
+      },
+
+      getSyncStatus: async () => {
+        log('getSyncStatus');
+
+        return indexer.getSyncStatus();
       }
     }
   };

packages/eden-watcher/src/schema.gql

@@ -211,6 +211,13 @@ type ResultIPLDBlock {
   data: String!
 }
 
+type SyncStatus {
+  latestIndexedBlockHash: String!
+  latestIndexedBlockNumber: Int!
+  latestCanonicalBlockHash: String!
+  latestCanonicalBlockNumber: Int!
+}
+
 type Query {
   events(blockHash: String!, contractAddress: String!, name: String): [ResultEvent!]
   eventsInRange(fromBlockNumber: Int!, toBlockNumber: Int!): [ResultEvent!]
@@ -234,6 +241,7 @@ type Query {
   account(id: String!, block: Block_height): Account!
   getStateByCID(cid: String!): ResultIPLDBlock
   getState(blockHash: String!, contractAddress: String!, kind: String): ResultIPLDBlock
+  getSyncStatus: SyncStatus
 }
 
 type Producer {

packages/erc20-watcher/src/resolvers.ts

@@ -97,6 +97,12 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
 
         const events = await indexer.getEventsInRange(fromBlockNumber, toBlockNumber);
         return events.map(event => indexer.getResultEvent(event));
+      },
+
+      getSyncStatus: async () => {
+        log('getSyncStatus');
+
+        return indexer.getSyncStatus();
       }
     }
   };

packages/erc20-watcher/src/schema.ts

@@ -72,6 +72,13 @@ type WatchedEvent {
   event: ResultEvent!
 }
 
+type SyncStatus {
+  latestIndexedBlockHash: String!
+  latestIndexedBlockNumber: Int!
+  latestCanonicalBlockHash: String!
+  latestCanonicalBlockNumber: Int!
+}
+
 #
 # Queries
 #
@@ -139,6 +146,8 @@ type Query {
     fromBlockNumber: Int!
     toBlockNumber: Int!
   ): [ResultEvent!]
+
+  getSyncStatus: SyncStatus
 }
 
 #

packages/erc721-watcher/src/resolvers.ts

@@ -166,12 +166,18 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
       },
 
-      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Diff }: { blockHash: string, contractAddress: string, kind: string }) => {
+      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Checkpoint }: { blockHash: string, contractAddress: string, kind: string }) => {
         log('getState', blockHash, contractAddress, kind);
 
         const ipldBlock = await indexer.getPrevIPLDBlock(blockHash, contractAddress, kind);
 
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
+      },
+
+      getSyncStatus: async () => {
+        log('getSyncStatus');
+
+        return indexer.getSyncStatus();
       }
     }
   };

packages/erc721-watcher/src/schema.gql

@@ -85,6 +85,13 @@ type ResultIPLDBlock {
   data: String!
 }
 
+type SyncStatus {
+  latestIndexedBlockHash: String!
+  latestIndexedBlockNumber: Int!
+  latestCanonicalBlockHash: String!
+  latestCanonicalBlockNumber: Int!
+}
+
 type Query {
   events(blockHash: String!, contractAddress: String!, name: String): [ResultEvent!]
   eventsInRange(fromBlockNumber: Int!, toBlockNumber: Int!): [ResultEvent!]
@@ -104,6 +111,7 @@ type Query {
   _operatorApprovals(blockHash: String!, contractAddress: String!, key0: String!, key1: String!): ResultBoolean!
   getStateByCID(cid: String!): ResultIPLDBlock
   getState(blockHash: String!, contractAddress: String!, kind: String): ResultIPLDBlock
+  getSyncStatus: SyncStatus
   transferCount(id: String!, block: Block_height): TransferCount!
 }
 

packages/graph-test-watcher/src/resolvers.ts

@@ -122,12 +122,18 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
       },
 
-      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Diff }: { blockHash: string, contractAddress: string, kind: string }) => {
+      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Checkpoint }: { blockHash: string, contractAddress: string, kind: string }) => {
         log('getState', blockHash, contractAddress, kind);
 
         const ipldBlock = await indexer.getPrevIPLDBlock(blockHash, contractAddress, kind);
 
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
+      },
+
+      getSyncStatus: async () => {
+        log('getSyncStatus');
+
+        return indexer.getSyncStatus();
       }
     }
   };

packages/graph-test-watcher/src/schema.gql

@@ -86,6 +86,13 @@ type ResultIPLDBlock {
   data: String!
 }
 
+type SyncStatus {
+  latestIndexedBlockHash: String!
+  latestIndexedBlockNumber: Int!
+  latestCanonicalBlockHash: String!
+  latestCanonicalBlockNumber: Int!
+}
+
 type Query {
   events(blockHash: String!, contractAddress: String!, name: String): [ResultEvent!]
   eventsInRange(fromBlockNumber: Int!, toBlockNumber: Int!): [ResultEvent!]
@@ -96,6 +103,7 @@ type Query {
   category(id: String!, block: Block_height): Category!
   getStateByCID(cid: String!): ResultIPLDBlock
   getState(blockHash: String!, contractAddress: String!, kind: String): ResultIPLDBlock
+  getSyncStatus: SyncStatus
 }
 
 enum BlogKind {

packages/mobymask-watcher/src/resolvers.ts

@@ -110,7 +110,7 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
       },
 
-      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Diff }: { blockHash: string, contractAddress: string, kind: string }) => {
+      getState: async (_: any, { blockHash, contractAddress, kind = StateKind.Checkpoint }: { blockHash: string, contractAddress: string, kind: string }) => {
         log('getState', blockHash, contractAddress, kind);
 
         const ipldBlock = await indexer.getPrevIPLDBlock(blockHash, contractAddress, kind);
@@ -118,6 +118,12 @@ export const createResolvers = async (indexer: Indexer, eventWatcher: EventWatch
         return ipldBlock && ipldBlock.block.isComplete ? indexer.getResultIPLDBlock(ipldBlock) : undefined;
       },
 
+      getSyncStatus: async () => {
+        log('getSyncStatus');
+
+        return indexer.getSyncStatus();
+      },
+
       latestBlock: async () => {
         log('latestBlock');
 

packages/mobymask-watcher/src/schema.gql

@@ -87,6 +87,13 @@ type ResultIPLDBlock {
   data: String!
 }
 
+type SyncStatus {
+  latestIndexedBlockHash: String!
+  latestIndexedBlockNumber: Int!
+  latestCanonicalBlockHash: String!
+  latestCanonicalBlockNumber: Int!
+}
+
 type Query {
   events(blockHash: String!, contractAddress: String!, name: String): [ResultEvent!]
   eventsInRange(fromBlockNumber: Int!, toBlockNumber: Int!): [ResultEvent!]
@@ -97,6 +104,7 @@ type Query {
   isMember(blockHash: String!, contractAddress: String!, key0: String!): ResultBoolean!
   getStateByCID(cid: String!): ResultIPLDBlock
   getState(blockHash: String!, contractAddress: String!, kind: String): ResultIPLDBlock
+  getSyncStatus: SyncStatus
   latestBlock: Block_height
 }