feat: add support for xrp nodes with amendment blocked

Author: kuco23

packages/fasset-indexer-xrp/.env.template

@@ -9,6 +9,9 @@ DB_PASSWORD=
 # rpc
 XRP_RPC_URL=
 XRP_RPC_API_KEY=
+# if node doesn't sync full history there
+# are differences in server responses
+XRP_RPC_AMENDMENT_BLOCKED=false
 
 # indexing params
 XRP_MIN_BLOCK_NUMBER=

packages/fasset-indexer-xrp/src/client/interface.ts

@@ -29,9 +29,20 @@ export interface IXrpMemo {
   }
 }
 
-export interface IXrpInfoResponse {
+export interface IXrpLedgerCurrentResponse {
   result: {
     ledger_current_index: number
     status: string
   }
+}
+
+export interface IXrpServerInfoResponse {
+  result: {
+    info: {
+      validated_ledger: {
+        seq: number
+      }
+    }
+    status: string
+  }
 }

packages/fasset-indexer-xrp/src/client/xrp-client.ts

@@ -1,5 +1,5 @@
 import { XrpConfigLoader } from "../config/config"
-import { IXrpBlock, IXrpBlockQueryResponse, IXrpInfoResponse } from "./interface"
+import { IXrpBlock, IXrpBlockQueryResponse, IXrpLedgerCurrentResponse, IXrpServerInfoResponse } from "./interface"
 
 export class XrpClient {
 
@@ -12,15 +12,27 @@ export class XrpClient {
   }
 
   async blockHeight(): Promise<number> {
-    const resp = await this.getLedgerCurrent()
-    this.ensureSuccess(resp)
-    return resp.result.ledger_current_index
+    let current_block = 0
+    if (this.config.xrpNodeIsAmendmentBlocked) {
+      const resp = await this.getServerInfo()
+      this.ensureSuccess(resp)
+      current_block = resp.result.info.validated_ledger.seq
+    } else {
+      const resp = await this.getLedgerCurrent()
+      this.ensureSuccess(resp)
+      current_block = resp.result.ledger_current_index
+    }
+    return current_block
   }
 
-  private async getLedgerCurrent(): Promise<IXrpInfoResponse> {
+  private async getLedgerCurrent(): Promise<IXrpLedgerCurrentResponse> {
     return this.request('ledger_current', [])
   }
 
+  private async getServerInfo(): Promise<IXrpServerInfoResponse> {
+    return this.request('server_info', [{}])
+  }
+
   private async getLedger(n: number): Promise<IXrpBlockQueryResponse> {
     return this.request('ledger', [{
       id: 1,
@@ -39,9 +51,9 @@ export class XrpClient {
     return resp.json()
   }
 
-  private ensureSuccess(resp: { result: { status: string }}): any {
+  private ensureSuccess(resp: { result: { status: string, error_message?: string }}): any {
     if (resp.result.status != 'success') {
-      throw new Error(`rpc returned ${resp}`)
+      throw new Error(`rpc returned ${JSON.stringify(resp.result.error_message)}`)
     }
   }
 }

packages/fasset-indexer-xrp/src/config/config.ts

@@ -13,4 +13,8 @@ export class XrpConfigLoader extends ConfigLoader {
   get xrpMinBlockNumber(): number {
     return parseInt(this.required('XRP_MIN_BLOCK_NUMBER'))
   }
+
+  get xrpNodeIsAmendmentBlocked(): boolean {
+    return process.env.XRP_RPC_AMENDMENT_BLOCKED === "true"
+  }
 }