CU-86a5geecu - BS Lib - Improve wait transaction functionality

CityOfZion · Nov 7, 2024 · cd426af · cd426af
1 parent 70fc092
commit cd426af
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 0 deletions.
diff --git a/common/changes/@cityofzion/blockchain-service/CU-86a5geecu_2024-11-07-17-25.json b/common/changes/@cityofzion/blockchain-service/CU-86a5geecu_2024-11-07-17-25.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@cityofzion/blockchain-service",
+      "comment": "Add a new function to wait for a specific transaction by an account",
+      "type": "minor"
+    }
+  ],
+  "packageName": "@cityofzion/blockchain-service"
+}
diff --git a/packages/blockchain-service/src/functions.ts b/packages/blockchain-service/src/functions.ts
@@ -72,6 +72,33 @@ export async function waitForTransaction<BSName extends string = string>(
   return false
 }
 
+export async function waitForAccountTransaction<BSName extends string = string>(
+  service: BlockchainService<BSName>,
+  txId: string,
+  account: Account<BSName>
+): Promise<boolean> {
+  const maxAttempts = 10
+
+  let attempts = 1
+
+  do {
+    await wait(60000)
+
+    try {
+      const response = await service.blockchainDataService.getTransactionsByAddress({ address: account.address })
+      const isTransactionConfirmed = response.transactions.some(transaction => transaction.hash === txId)
+
+      if (isTransactionConfirmed) return true
+    } catch {
+      // Empty block
+    }
+
+    attempts++
+  } while (attempts < maxAttempts)
+
+  return false
+}
+
 export async function fetchAccountsForBlockchainServices<BSName extends string = string>(
   blockchainServices: BlockchainService<BSName>[],
   getAccountCallback: (service: BlockchainService<BSName>, index: number) => Promise<Account<BSName>>