Another attempt at refunding the failed SNEED transfers (#5375)

open-chat-labs · Feb 14, 2024 · 2b8e50d · 2b8e50d
1 parent cb4d6e8
commit 2b8e50d
Show file tree

Hide file tree

Showing 4 changed files with 53 additions and 26 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/backend/canisters/escrow/CHANGELOG.md b/backend/canisters/escrow/CHANGELOG.md
@@ -7,6 +7,12 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 ### Changed
 
+- Another attempt at refunding the failed SNEED transfers ([#5375](https://github.com/open-chat-labs/open-chat/pull/5375))
+
+## [[2.0.1062](https://github.com/open-chat-labs/open-chat/releases/tag/v2.0.1062-escrow)] - 2024-02-14
+
+### Changed
+
 - Refund 2 more failed SNEED p2p swaps ([#5359](https://github.com/open-chat-labs/open-chat/pull/5359))
 
 ## [[2.0.1050](https://github.com/open-chat-labs/open-chat/releases/tag/v2.0.1050-escrow)] - 2024-02-08

diff --git a/backend/canisters/escrow/impl/Cargo.toml b/backend/canisters/escrow/impl/Cargo.toml
@@ -18,6 +18,7 @@ canister_state_macros = { path = "../../../libraries/canister_state_macros" }
 canister_timer_jobs = { path = "../../../libraries/canister_timer_jobs" }
 canister_tracing_macros = { path = "../../../libraries/canister_tracing_macros" }
 escrow_canister = { path = "../api" }
+hex = { workspace = true }
 http_request = { path = "../../../libraries/http_request" }
 ic-cdk = { workspace = true }
 ic-cdk-macros = { workspace = true }

diff --git a/backend/canisters/escrow/impl/src/lifecycle/post_upgrade.rs b/backend/canisters/escrow/impl/src/lifecycle/post_upgrade.rs
@@ -1,15 +1,16 @@
 use crate::lifecycle::{init_env, init_state};
 use crate::memory::get_upgrades_memory;
-use crate::model::pending_payments_queue::{PendingPayment, PendingPaymentReason};
-use crate::{mutate_state, Data};
+use crate::Data;
 use candid::Principal;
 use canister_logger::LogEntry;
 use canister_tracing_macros::trace;
 use escrow_canister::post_upgrade::Args;
 use ic_cdk_macros::post_upgrade;
+use icrc_ledger_types::icrc1::transfer::TransferArg;
 use stable_memory::get_reader;
+use std::time::Duration;
 use tracing::info;
-use types::UserId;
+use types::CanisterId;
 use utils::cycles::init_cycles_dispenser_client;
 
 #[post_upgrade]
@@ -28,27 +29,45 @@ fn post_upgrade(args: Args) {
 
     info!(version = %args.wasm_version, "Post-upgrade complete");
 
-    mutate_state(|state| {
-        let now = state.env.now();
-        if let Some(swap) = state.data.swaps.get_mut(107) {
-            state.data.pending_payments_queue.push(PendingPayment {
-                user_id: UserId::from(Principal::from_text("vfhvn-qyaaa-aaaaf-adoxa-cai").unwrap()),
-                timestamp: now,
-                token_info: swap.token1.clone(),
-                amount: swap.amount1 - swap.token1.fee,
-                swap_id: swap.id,
-                reason: PendingPaymentReason::Refund,
-            });
-        }
-        if let Some(swap) = state.data.swaps.get_mut(148) {
-            state.data.pending_payments_queue.push(PendingPayment {
-                user_id: UserId::from(Principal::from_text("mzhg4-fqaaa-aaaar-ay7iq-cai").unwrap()),
-                timestamp: now,
-                token_info: swap.token1.clone(),
-                amount: swap.amount1 - swap.token1.fee,
-                swap_id: swap.id,
-                reason: PendingPaymentReason::Refund,
-            });
-        }
-    });
+    ic_cdk_timers::set_timer(Duration::ZERO, || ic_cdk::spawn(refund_sneed()));
+}
+
+async fn refund_sneed() {
+    let sneed_ledger = CanisterId::from_text("r7cp6-6aaaa-aaaag-qco5q-cai").unwrap();
+
+    let _ = icrc_ledger_canister_c2c_client::icrc1_transfer(
+        sneed_ledger,
+        &TransferArg {
+            from_subaccount: Some(
+                hex::decode("c37c2e0eeb36394cca8cc735c34ce577885180e76b489918fab97f7ca37de73c")
+                    .unwrap()
+                    .try_into()
+                    .unwrap(),
+            ),
+            to: Principal::from_text("vfhvn-qyaaa-aaaaf-adoxa-cai").unwrap().into(),
+            fee: None,
+            created_at_time: None,
+            memo: None,
+            amount: (10_000_000_000u64 - 100_000_000).into(),
+        },
+    )
+    .await;
+
+    let _ = icrc_ledger_canister_c2c_client::icrc1_transfer(
+        sneed_ledger,
+        &TransferArg {
+            from_subaccount: Some(
+                hex::decode("52f2f597bd96647b71742ad6b1763c90e80b092ba25ea2e909167d9cffc37963")
+                    .unwrap()
+                    .try_into()
+                    .unwrap(),
+            ),
+            to: Principal::from_text("mzhg4-fqaaa-aaaar-ay7iq-cai").unwrap().into(),
+            fee: None,
+            created_at_time: None,
+            memo: None,
+            amount: (250_000_000_000u64 - 100_000_000).into(),
+        },
+    )
+    .await;
 }