diff --git a/terminator/src/accounts.rs b/terminator/src/accounts.rs index 7ec2242..095b017 100644 --- a/terminator/src/accounts.rs +++ b/terminator/src/accounts.rs @@ -216,7 +216,7 @@ pub async fn unwrap_wsol_ata(klend_client: &KlendClient) -> Result { .build(&[]) .await?; - let (sig, _) = klend_client.client.send_and_confirm_transaction(tx).await?; + let (sig, _) = klend_client.client.send_retry_and_confirm_transaction(tx, None, false).await?; info!("Executed unwrap transaction: {:?}", sig); Ok(sig.to_string()) diff --git a/terminator/src/client.rs b/terminator/src/client.rs index 41ee4fc..3bca8ae 100644 --- a/terminator/src/client.rs +++ b/terminator/src/client.rs @@ -250,7 +250,7 @@ impl KlendClient { let txn = self.client.create_tx(&[create_lookup_table], &[]).await?; - self.client.send_and_confirm_transaction(txn).await?; + self.client.send_retry_and_confirm_transaction(txn, None, false).await?; let keys = keys .iter() @@ -304,7 +304,7 @@ impl KlendClient { if num_retries > max_retries { return Err(anyhow!("Max retries reached")); } - let (sig, res) = self.client.send_and_confirm_transaction(tx.clone()).await?; + let (sig, res) = self.client.send_retry_and_confirm_transaction(tx.clone(), None, false).await?; if let Some(Err(TransactionError::BlockhashNotFound)) = res { continue; } else { diff --git a/terminator/src/main.rs b/terminator/src/main.rs index ba6dca2..5a9c981 100644 --- a/terminator/src/main.rs +++ b/terminator/src/main.rs @@ -438,7 +438,7 @@ pub mod swap { let tx = builder.build(&[]).await?; info!("Sending transaction..."); - let (sig, _) = klend_client.client.send_and_confirm_transaction(tx).await?; + let (sig, _) = klend_client.client.send_retry_and_confirm_transaction(tx, None, false).await?; info!("Executed transaction: {:?}", sig); Ok(()) @@ -634,7 +634,7 @@ async fn liquidate(klend_client: &KlendClient, obligation: &Pubkey) -> Result<() if should_send { let sig = klend_client .client - .send_and_confirm_transaction(txn) + .send_retry_and_confirm_transaction(txn, None, false) .await .unwrap();