Improve tx confirmation rate by spamming sendRawTransaction() (#381)

CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 Version changes are pinned to SDK releases.
 
+## [1.26.2]
+
+- Spam sendRawTransaction() in utils.processTransaction(). ([#381](https://github.com/zetamarkets/sdk/pull/381))
+
 ## [1.26.1]
 
 - Add new update pricing ix. ([#379](https://github.com/zetamarkets/sdk/pull/379))

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@zetamarkets/sdk",
   "repository": "https://github.com/zetamarkets/sdk/",
-  "version": "1.26.1",
+  "version": "1.26.2",
   "description": "Zeta SDK",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/utils.ts

@@ -1036,13 +1036,20 @@ export async function processTransaction(
 
       txSig = await provider.connection.sendRawTransaction(rawTx, {
         skipPreflight: true,
+        preflightCommitment: provider.connection.commitment,
       });
 
       // Poll the tx confirmation for N seconds
       // Polling is more reliable than websockets using confirmTransaction()
       let currentBlockHeight = 0;
       if (!skipConfirmation) {
         while (currentBlockHeight < recentBlockhash.lastValidBlockHeight) {
+          // Keep resending to maximise the chance of confirmation
+          await provider.connection.sendRawTransaction(rawTx, {
+            skipPreflight: true,
+            preflightCommitment: provider.connection.commitment,
+          });
+
           let status = await provider.connection.getSignatureStatus(txSig);
           currentBlockHeight = await provider.connection.getBlockHeight(
             provider.connection.commitment
@@ -1064,7 +1071,7 @@ export async function processTransaction(
               return txSig;
             }
           }
-          await sleep(1500); // Don't spam the RPC
+          await sleep(500); // Don't spam the RPC
         }
         throw Error(`Transaction ${txSig} was not confirmed`);
       } else {