feat: add script to update missing xrp transaction result fields

Author: kuco23

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

@@ -21,7 +21,10 @@ export interface IXrpTransaction {
   hash: string
   metaData?: {
     TransactionResult: string
-  },
+  }
+  meta?: {
+    TransactionResult: string
+  }
   Destination?: string
   ledger_index: number
   date: number

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

@@ -3,6 +3,7 @@ import type {
   IXrpAccountInfoResponse, IXrpAccountTxResponse,
   IXrpBlock, IXrpBlockQueryResponse,
   IXrpLedgerCurrentResponse, IXrpServerInfoResponse,
+  IXrpTransaction,
   IXrpWeirdAfTx
 } from "./interface"
 
@@ -16,6 +17,15 @@ export class XrpClient {
     return resp.result.ledger
   }
 
+  async transaction(hash: string): Promise<IXrpTransaction> {
+    const resp = await this.request('tx', [{
+      transaction: hash,
+      binary: false
+    }])
+    this.ensureSuccess(resp)
+    return resp.result
+  }
+
   async blockHeight(): Promise<number> {
     let current_block = 0
     if (this.config.xrpNodeIsAmendmentBlocked) {

packages/fasset-indexer-xrp/src/scripts/add-transaction-results.ts

@@ -0,0 +1,29 @@
+import { UnderlyingTransaction } from "fasset-indexer-core/entities"
+import { XrpContext } from "../context"
+import { XrpClient } from "../client/xrp-client"
+import { XrpConfigLoader } from "../config/config"
+
+const TX_UPDATE_LIMIT = 1e4
+
+export async function addTransactionResults(context: XrpContext, client: XrpClient) {
+  const em = context.orm.em.fork()
+  const transactions = await em.find(UnderlyingTransaction, { result: null }, { limit: TX_UPDATE_LIMIT })
+  console.log(`transaction to process ${transactions.length}`)
+  for (const transaction of transactions) {
+    const tx = await client.transaction(transaction.hash)
+    transaction.result = tx.meta?.TransactionResult
+    console.log(`obtained tx with result ${transaction.result}`)
+    transaction.fee = BigInt(tx.Fee ?? 0)
+    await em.persistAndFlush(transaction)
+  }
+  await context.orm.close()
+}
+
+async function main() {
+  const config = new XrpConfigLoader()
+  const client = new XrpClient(config)
+  const context = await XrpContext.create(config)
+  await addTransactionResults(context, client)
+}
+
+main()