finish submit-taker-bond

This commit is contained in:
f321x
2024-07-01 15:51:35 +00:00
parent 0335957ea8
commit 12304df468
2 changed files with 21 additions and 4 deletions

View File

@ -102,8 +102,22 @@ async fn submit_taker_bond(
} }
Err(_) => return Ok(StatusCode::NOT_FOUND.into_response()), Err(_) => return Ok(StatusCode::NOT_FOUND.into_response()),
} }
database.add_taker_info_and_move_table(&payload).await?;
Ok(Json(OfferTakenResponse { trade_psbt_hex }).into_response()) let trade_contract_psbt_taker = "".to_string(); // implement psbt
let trade_contract_psbt_maker = "".to_string(); // implement psbt
panic!("Trade contract PSBT not implemented!");
database
.add_taker_info_and_move_table(
&payload,
&trade_contract_psbt_maker,
&trade_contract_psbt_taker,
)
.await?;
Ok(Json(OfferTakenResponse {
trade_psbt_hex_to_sign: trade_contract_psbt_taker,
})
.into_response())
} }
pub async fn api_server(database: CoordinatorDB, wallet: CoordinatorWallet) -> Result<()> { pub async fn api_server(database: CoordinatorDB, wallet: CoordinatorWallet) -> Result<()> {

View File

@ -305,6 +305,8 @@ impl CoordinatorDB {
pub async fn add_taker_info_and_move_table( pub async fn add_taker_info_and_move_table(
&self, &self,
trade_and_taker_info: &OfferPsbtRequest, trade_and_taker_info: &OfferPsbtRequest,
trade_contract_psbt_maker: &String,
trade_contract_psbt_taker: &String,
) -> Result<()> { ) -> Result<()> {
let public_offer = self let public_offer = self
.fetch_and_delete_offer_from_public_offers_table( .fetch_and_delete_offer_from_public_offers_table(
@ -337,10 +339,11 @@ impl CoordinatorDB {
.bind(public_offer.musig_pubkey_hex_maker) .bind(public_offer.musig_pubkey_hex_maker)
.bind(trade_and_taker_info.trade_data.musig_pub_nonce_hex.clone()) .bind(trade_and_taker_info.trade_data.musig_pub_nonce_hex.clone())
.bind(trade_and_taker_info.trade_data.musig_pubkey_hex.clone()) .bind(trade_and_taker_info.trade_data.musig_pubkey_hex.clone())
.bind(escrow psbt maker) .bind(trade_contract_psbt_maker.clone())
.bind(escrow psbt taker) .bind(trade_contract_psbt_taker.clone())
.execute(&*self.db_pool) .execute(&*self.db_pool)
.await?; .await?;
Ok(()) Ok(())
} }
} }