feat(src): wait the transaction in commit

Wait the transaction and get its receipt in commit.
numbersprotocol · Jun 15, 2023 · 7143152 · 7143152
1 parent 60219be
commit 7143152
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 9 deletions.
diff --git a/src/nit.ts b/src/nit.ts
@@ -315,7 +315,7 @@ export async function pull(assetCid: string, blockchainInfo) {
 //  }
 //}
 
-export async function commit(assetCid: string, commitData: string, blockchainInfo) {
+export async function commit(assetCid: string, commitData: string, blockchainInfo, confirms: number = 1) {
   const commitString = addActionNameInCommit(commitData);
   let r;
   if (blockchainInfo.gasPrice != null) {
@@ -324,7 +324,9 @@ export async function commit(assetCid: string, commitData: string, blockchainInf
   } else {
     r = await blockchainInfo.contract.commit(assetCid, commitString, { gasLimit: blockchainInfo.gasLimit });
   }
-  return r;
+
+  // Wait for the transaction to be mined
+  return await r.wait(confirms);
 }
 
 export async function log(assetCid: string, blockchainInfo, fromIndex: number, toIndex: number = null) {

diff --git a/src/run.ts b/src/run.ts
@@ -609,15 +609,11 @@ async function main() {
       } else {
         commitEventIndexCid = nit.assetCidMock;
       }
-      const commitResult = await nit.commit(commitEventIndexCid, JSON.stringify(commitData), blockchain);
-
-      console.log(`Commit Tx: ${commitResult.hash}`);
-      console.log(`Commit Explorer: ${blockchain.explorerBaseUrl}/${commitResult.hash}`);
 
       try {
-        // Wait for the transaction to be mined
-        const transactionReceipt = await commitResult.wait();
-        console.log(`Block Number: ${transactionReceipt.blockNumber}`);
+        const transactionReceipt = await nit.commit(commitEventIndexCid, JSON.stringify(commitData), blockchain);
+        console.log(`Commit Tx: ${transactionReceipt.transactionHash}`);
+        console.log(`Commit Explorer: ${blockchain.explorerBaseUrl}/${transactionReceipt.transactionHash}`);
       } catch (error) {
         console.error(`Transaction error: ${error}`);
       }