graphql: use unfinalized height in processor status resolver (#342)

* use unfinalized height in processor status resolver * changes
subsquid · Sep 20, 2024 · 2c0d96c · 2c0d96c
1 parent 3c2f741
commit 2c0d96c
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 8 deletions.
diff --git a/common/changes/@subsquid/graphql-server/status-resolver-hot_2024-09-20-13-42.json b/common/changes/@subsquid/graphql-server/status-resolver-hot_2024-09-20-13-42.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/graphql-server",
+      "comment": "use unfinalized height in processor status resolver",
+      "type": "minor"
+    }
+  ],
+  "packageName": "@subsquid/graphql-server"
+}
diff --git a/graphql/graphql-server/src/server.ts b/graphql/graphql-server/src/server.ts
@@ -15,7 +15,7 @@ import {isTsNode} from '@subsquid/util-internal-ts-node'
 import {ApolloServerPluginCacheControl, KeyValueCache, PluginDefinition} from 'apollo-server-core'
 import responseCachePlugin from 'apollo-server-plugin-response-cache'
 import assert from 'assert'
-import {GraphQLInt, GraphQLObjectType, GraphQLSchema} from 'graphql'
+import {GraphQLInt, GraphQLObjectType, GraphQLSchema, GraphQLString} from 'graphql'
 import Keyv from 'keyv'
 import * as path from 'path'
 import {Pool} from 'pg'
@@ -128,13 +128,29 @@ export class Server {
     @def
     private squidStatusSchema(): GraphQLSchema {
         let statusQuery = {
-            sql: `SELECT height FROM squid_processor.status WHERE id = 0`,
+            sql: `
+                SELECT
+                    f.height AS "finalizedHeight",
+                    f.hash AS "finalizedHash",
+                    COALESCE(h.height, f.height) AS "height",
+                    COALESCE(h.hash, f.hash) AS "hash"
+                FROM squid_processor.status AS f
+                FULL JOIN (
+                    SELECT hash, height FROM squid_processor.hot_block
+                    ORDER BY height DESC
+                    LIMIT 1)
+                AS h ON TRUE
+                WHERE f.id = 0`,
             params: [],
-            map(rows: any[][]): {height: number} {
+            map(rows: any[][]): {finalizedHeight: number; finalizedHash: string; height: number; hash: string} {
                 assert(rows.length == 1)
-                let height = parseInt(rows[0][0], 10)
-                return {height}
-            }
+                return {
+                    finalizedHeight: parseInt(rows[0][0], 10),
+                    finalizedHash: rows[0][1],
+                    height: parseInt(rows[0][2], 10),
+                    hash: rows[0][3],
+                }
+            },
         }
 
         return new GraphQLSchema({
@@ -147,8 +163,20 @@ export class Server {
                             fields: {
                                 height: {
                                     type: GraphQLInt,
-                                    description: 'The height of the processed part of the chain'
-                                }
+                                    description: 'The height of the last processed block',
+                                },
+                                hash: {
+                                    type: GraphQLString,
+                                    description: 'The hash of the last processed block',
+                                },
+                                finalizedHeight: {
+                                    type: GraphQLInt,
+                                    description: 'The height of the last processed finalized block',
+                                },
+                                finalizedHash: {
+                                    type: GraphQLString,
+                                    description: 'The hash of the last processed finalized block',
+                                },
                             }
                         }),
                         resolve(source, args, context: Context) {