Merge pull request #112 from CityOfZion/CU-86a5geecu

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

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"
+}

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>>