From 55938c9ffca0a2607ec45e82d0d0e94f34b9791d Mon Sep 17 00:00:00 2001 From: f321x Date: Mon, 24 Jun 2024 17:19:16 +0000 Subject: [PATCH] coordinator wallet --- taptrade-cli-demo/coordinator/src/communication/mod.rs | 3 +++ taptrade-cli-demo/coordinator/src/main.rs | 4 ++++ 2 files changed, 7 insertions(+) diff --git a/taptrade-cli-demo/coordinator/src/communication/mod.rs b/taptrade-cli-demo/coordinator/src/communication/mod.rs index 2abb8bd..eeb5ade 100755 --- a/taptrade-cli-demo/coordinator/src/communication/mod.rs +++ b/taptrade-cli-demo/coordinator/src/communication/mod.rs @@ -25,6 +25,9 @@ async fn receive_order( // order.field2 // ) + // insert offer into sql database + // generate locking address for bond + println!("Coordinator received new offer: {:?}", order); Ok(Json(BondRequirementResponse { bond_address: bond_address, diff --git a/taptrade-cli-demo/coordinator/src/main.rs b/taptrade-cli-demo/coordinator/src/main.rs index b2c9743..bbb64f7 100755 --- a/taptrade-cli-demo/coordinator/src/main.rs +++ b/taptrade-cli-demo/coordinator/src/main.rs @@ -2,6 +2,8 @@ mod communication; mod coordinator; use anyhow::{anyhow, Error, Result}; +use bdk::database::MemoryDatabase; +use bdk::Wallet; use communication::api_server; use dotenv::dotenv; use serde::{Deserialize, Serialize}; @@ -12,6 +14,7 @@ use std::sync::Arc; #[derive(Clone, Debug)] pub struct Coordinator { pub db_pool: Arc>, + pub wallet: Arc>, // using sqlite for Wallet? } // populate .env with values before starting @@ -27,6 +30,7 @@ async fn main() -> Result<()> { let coordinator = Coordinator { db_pool: shared_db_pool, + wallet: // impl wallet }; api_server(coordinator).await?;