feat: move transfers with undeployed token_id to stuck_transfers table

Near-One · Jan 29, 2025 · 80bbb8f · 80bbb8f
1 parent 4c967a7
commit 80bbb8f
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 0 deletions.
diff --git a/omni-relayer/src/utils/redis.rs b/omni-relayer/src/utils/redis.rs
@@ -13,6 +13,7 @@ pub const SOLANA_EVENTS: &str = "solana_events";
 pub const SOLANA_INIT_TRANSFER_EVENTS: &str = "solana_init_transfer_events";
 
 pub const FINALIZED_TRANSFERS: &str = "finalized_transfers";
+pub const STUCK_TRANSFERS: &str = "stuck_transfers";
 
 pub const KEEP_INSUFFICIENT_FEE_TRANSFERS_FOR: i64 = 60 * 60 * 24 * 14; // 14 days
 pub const CHECK_INSUFFICIENT_FEE_TRANSFERS_EVERY_SECS: i64 = 60 * 30; // 30 minutes

diff --git a/omni-relayer/src/workers/evm.rs b/omni-relayer/src/workers/evm.rs
@@ -231,6 +231,19 @@ async fn handle_init_transfer_event(
         Ok(actions) => actions,
         Err(err) => {
             warn!("{}", err);
+            utils::redis::remove_event(
+                &mut redis_connection,
+                utils::redis::EVM_INIT_TRANSFER_EVENTS,
+                &key,
+            )
+            .await;
+            utils::redis::add_event(
+                &mut redis_connection,
+                utils::redis::STUCK_TRANSFERS,
+                key,
+                init_transfer_with_timestamp,
+            )
+            .await;
             return;
         }
     };

diff --git a/omni-relayer/src/workers/solana.rs b/omni-relayer/src/workers/solana.rs
@@ -291,6 +291,19 @@ async fn handle_init_transfer_event(
         Ok(actions) => actions,
         Err(err) => {
             warn!("{}", err);
+            utils::redis::remove_event(
+                &mut redis_connection,
+                utils::redis::SOLANA_INIT_TRANSFER_EVENTS,
+                &key,
+            )
+            .await;
+            utils::redis::add_event(
+                &mut redis_connection,
+                utils::redis::STUCK_TRANSFERS,
+                key,
+                init_transfer_with_timestamp,
+            )
+            .await;
             return;
         }
     };