fix: add custom loop for waiting for transaction confirmation

holaplex · Oct 12, 2023 · fe8bb0d · fe8bb0d
1 parent db4a8d4
commit fe8bb0d
Showing 1 changed file with 14 additions and 5 deletions.
diff --git a/consumer/src/solana.rs b/consumer/src/solana.rs
@@ -12,7 +12,7 @@ use hub_core::{
     backon::{ExponentialBuilder, Retryable},
     bs58, clap,
     prelude::*,
-    thiserror,
+    thiserror, tokio,
     uuid::Uuid,
 };
 use mpl_bubblegum::state::metaplex_adapter::{
@@ -209,10 +209,9 @@ impl Solana {
         &self,
         signature: &Signature,
     ) -> Result<u32, SolanaAssetIdError> {
-        let response = with_retry!(
-            self.rpc()
-                .get_transaction(signature, UiTransactionEncoding::Json)
-        )
+        let response = with_retry!(self
+            .rpc()
+            .get_transaction(signature, UiTransactionEncoding::Json))
         .await?;
 
         let meta = response
@@ -291,6 +290,16 @@ impl Solana {
                 anyhow!(msg)
             })?;
 
+        loop {
+            let confirmed = with_retry!(self.rpc().confirm_transaction(&signature)).await?;
+
+            if confirmed {
+                break;
+            }
+
+            tokio::time::sleep(std::time::Duration::from_millis(250)).await;
+        }
+
         Ok(signature.to_string())
     }
 }