dont override the commitment level

Author: barnjamin

platforms/solana/src/platform.ts

@@ -209,13 +209,11 @@ export class SolanaPlatform<N extends Network> extends PlatformContext<
     rpc: Connection,
     commitment?: Commitment,
   ): Promise<{ blockhash: string; lastValidBlockHeight: number }> {
-    // Use finalized to prevent blockhash not found errors
-    // Note: this may mean we have less time to submit transactions?
-    return rpc.getLatestBlockhash(commitment ?? 'finalized');
+    return rpc.getLatestBlockhash(commitment ?? rpc.commitment);
   }
 
   static async getLatestBlock(rpc: Connection): Promise<number> {
-    const { lastValidBlockHeight } = await this.latestBlock(rpc, 'confirmed');
+    const { lastValidBlockHeight } = await this.latestBlock(rpc);
     return lastValidBlockHeight;
   }
 

platforms/solana/src/testing/sendSigner.ts

@@ -1,4 +1,5 @@
 import {
+  ComputeBudgetProgram,
   Connection,
   Keypair,
   SendOptions,
@@ -26,6 +27,7 @@ export class SolanaSendSigner<
     private _keypair: Keypair,
     private _debug: boolean = false,
     private _sendOpts?: SendOptions,
+    private _priotifyFeeAmount?: bigint,
   ) {
     this._sendOpts = this._sendOpts ?? {
       preflightCommitment: this._rpc.commitment,
@@ -42,6 +44,7 @@ export class SolanaSendSigner<
 
   // Handles retrying a Transaction if the error is deemed to be
   // recoverable. Currently handles:
+  // - Transaction expired
   // - Blockhash not found
   // - Not enough bytes (storage account not seen yet)
   private retryable(e: any): boolean {
@@ -75,7 +78,6 @@ export class SolanaSendSigner<
   async signAndSend(tx: UnsignedTransaction[]): Promise<any[]> {
     let { blockhash, lastValidBlockHeight } = await SolanaPlatform.latestBlock(
       this._rpc,
-      'finalized',
     );
 
     const txids: string[] = [];
@@ -86,6 +88,13 @@ export class SolanaSendSigner<
       } = txn as SolanaUnsignedTransaction<N, C>;
       console.log(`Signing: ${description} for ${this.address()}`);
 
+      if (this._priotifyFeeAmount)
+        transaction.add(
+          ComputeBudgetProgram.setComputeUnitPrice({
+            microLamports: this._priotifyFeeAmount,
+          }),
+        );
+
       if (this._debug) logTxDetails(transaction);
 
       // Try to send the transaction up to 5 times
@@ -103,9 +112,12 @@ export class SolanaSendSigner<
         } catch (e) {
           if (!this.retryable(e)) throw e;
 
+          // TODO: check that the previous one is expired before
+          // re-signing
+
           // If it is retryable, we should grab a new block hash
           ({ blockhash, lastValidBlockHeight } =
-            await SolanaPlatform.latestBlock(this._rpc, 'finalized'));
+            await SolanaPlatform.latestBlock(this._rpc));
         }
       }
     }

platforms/solana/src/testing/signer.ts

@@ -27,10 +27,7 @@ export class SolanaSigner<N extends Network, C extends SolanaChains = 'Solana'>
   }
 
   async sign(tx: UnsignedTransaction[]): Promise<any[]> {
-    const { blockhash } = await SolanaPlatform.latestBlock(
-      this._rpc,
-      'finalized',
-    );
+    const { blockhash } = await SolanaPlatform.latestBlock(this._rpc);
 
     const signed = [];
     for (const txn of tx) {