diff --git a/taptrade-cli-demo/coordinator/src/coordinator/coordinator_utils.rs b/taptrade-cli-demo/coordinator/src/coordinator/coordinator_utils.rs index 28ae302..b4d4546 100644 --- a/taptrade-cli-demo/coordinator/src/coordinator/coordinator_utils.rs +++ b/taptrade-cli-demo/coordinator/src/coordinator/coordinator_utils.rs @@ -1,6 +1,3 @@ -use bitcoin::secp256k1::Scalar; -use hex::ToHex; - use super::*; #[derive(Debug)] diff --git a/taptrade-cli-demo/coordinator/src/coordinator/mod.rs b/taptrade-cli-demo/coordinator/src/coordinator/mod.rs index 9546412..48ac8d3 100755 --- a/taptrade-cli-demo/coordinator/src/coordinator/mod.rs +++ b/taptrade-cli-demo/coordinator/src/coordinator/mod.rs @@ -379,5 +379,14 @@ pub async fn handle_payout_signature( .broadcast_keyspend_tx(&keyspend_information) .await .map_err(|e| RequestError::CoordinatorError(e.to_string()))?; + database + .delete_complete_offer(&payload.offer_id_hex) + .await + .map_err(|e| { + RequestError::Database(format!( + "Failed to delete complete offer from taken_offers: {}", + e.to_string() + )) + })?; Ok(true) } diff --git a/taptrade-cli-demo/coordinator/src/database/mod.rs b/taptrade-cli-demo/coordinator/src/database/mod.rs index 73b711c..790e5b8 100644 --- a/taptrade-cli-demo/coordinator/src/database/mod.rs +++ b/taptrade-cli-demo/coordinator/src/database/mod.rs @@ -1022,4 +1022,12 @@ impl CoordinatorDB { trace!("Toggled processing status for offer {}", offer_id); Ok(result.get::(0) == 1) } + + pub async fn delete_complete_offer(&self, offer_id: &str) -> Result<()> { + sqlx::query("DELETE FROM taken_offers WHERE offer_id = ?") + .bind(offer_id) + .execute(&*self.db_pool) + .await?; + Ok(()) + } } diff --git a/taptrade-cli-demo/coordinator/src/main.rs b/taptrade-cli-demo/coordinator/src/main.rs index 87da65d..0ac6091 100755 --- a/taptrade-cli-demo/coordinator/src/main.rs +++ b/taptrade-cli-demo/coordinator/src/main.rs @@ -63,7 +63,7 @@ use tokio::{ sync::{oneshot, Mutex}, }; use validator::{Validate, ValidationError}; -use wallet::{escrow_psbt::*, wallet_utils::*, *}; +use wallet::{wallet_utils::*, *}; pub struct Coordinator { pub coordinator_db: Arc,