feat: implement token transfers in SweepController

Author: Ummi-001

contracts/sweep_controller/src/lib.rs

@@ -3,7 +3,7 @@
 mod authorization;
 mod errors;
 mod storage;
-// mod transfers;
+mod transfers;
 
 use ephemeral_account::EphemeralAccountContractClient as EphemeralAccountClient;
 use soroban_sdk::{contract, contractimpl, contracttype, Address, BytesN, Env};
@@ -115,17 +115,16 @@ impl SweepController {
             return Err(Error::AccountNotReady);
         }
 
-        // Execute the actual token transfer
-        // Note: In production, the ephemeral account would need to authorize this transfer
-        // let transfer_ctx = TransferContext::new(
-        //     info.payment_asset,
-        //     ephemeral_account.clone(),
-        //     destination.clone(),
-        //     amount,
-        // );
-        // transfer_ctx.execute(&env)?;
-
-        // Emit sweep executed event
+        // Execute the actual token transfers for all recorded payments
+        let mut payments_vec = soroban_sdk::Vec::new(&env);
+        for payment in info.payments.iter() {
+            payments_vec.push_back(payment);
+        }
+
+        transfers::execute_transfers(&env, &ephemeral_account, &destination, &payments_vec)
+            .map_err(|_| Error::TransferFailed)?;
+
+        // Emit sweep completed event after successful transfer
         emit_sweep_completed(&env, ephemeral_account, destination, amount);
 
         Ok(())

contracts/sweep_controller/src/transfers.rs

@@ -1,43 +1,34 @@
 use crate::errors::Error;
+use bridgelet_shared::Payment;
 use soroban_sdk::token::TokenClient;
-use soroban_sdk::{Address, Env};
+use soroban_sdk::{Address, Env, Vec};
 
-/// Execute token transfer from ephemeral account to destination
-pub fn execute_transfer(
+/// Execute token transfers for all payments from the ephemeral account to the destination.
+///
+/// Iterates over each recorded payment and calls the SEP-41 token contract's
+/// `transfer()` function, moving funds from `from` to `destination`.
+///
+/// The ephemeral account must have already authorized this contract to transfer
+/// on its behalf — this is enforced by the Soroban auth model when `from.require_auth()`
+/// is satisfied by the ephemeral account's invocation context.
+///
+/// # Arguments
+/// * `env` - Soroban environment
+/// * `from` - Ephemeral account address (source of funds)
+/// * `destination` - Recipient wallet address
+/// * `payments` - All recorded payments to transfer
+///
+/// # Errors
+/// Returns `Error::TransferFailed` if any individual transfer fails
+pub fn execute_transfers(
     env: &Env,
-    token_address: &Address,
     from: &Address,
-    to: &Address,
-    amount: i128,
+    destination: &Address,
+    payments: &Vec<Payment>,
 ) -> Result<(), Error> {
-    // Create token client
-    let token = TokenClient::new(env, token_address);
-
-    // Execute transfer
-    token.transfer(from, to, &amount);
-
-    Ok(())
-}
-
-/// Transfer context for sweep operations
-pub struct TransferContext {
-    pub asset: Address,
-    pub from: Address,
-    pub to: Address,
-    pub amount: i128,
-}
-
-impl TransferContext {
-    pub fn new(asset: Address, from: Address, to: Address, amount: i128) -> Self {
-        Self {
-            asset,
-            from,
-            to,
-            amount,
-        }
-    }
-
-    pub fn execute(&self, env: &Env) -> Result<(), Error> {
-        execute_transfer(env, &self.asset, &self.from, &self.to, self.amount)
+    for payment in payments.iter() {
+        let token = TokenClient::new(env, &payment.asset);
+        token.transfer(from, destination, &payment.amount);
     }
+    Ok(())
 }