diff --git a/daemon/src/maker.rs b/daemon/src/maker.rs index 7e3ad3a..7602a89 100644 --- a/daemon/src/maker.rs +++ b/daemon/src/maker.rs @@ -5,7 +5,7 @@ use crate::seed::Seed; use crate::wallet::Wallet; use anyhow::{Context, Result}; use bdk::bitcoin; -use bdk::bitcoin::secp256k1::{schnorrsig, SECP256K1}; +use bdk::bitcoin::secp256k1::schnorrsig; use clap::Clap; use model::cfd::Order; use model::WalletInfo; @@ -13,6 +13,7 @@ use rocket::fairing::AdHoc; use rocket_db_pools::Database; use std::collections::HashMap; use std::path::PathBuf; +use std::str::FromStr; use std::task::Poll; use std::time::Duration; use tokio::sync::watch; @@ -149,7 +150,10 @@ async fn main() -> Result<()> { auth_password ); - let oracle = schnorrsig::KeyPair::new(SECP256K1, &mut rand::thread_rng()); // TODO: Fetch oracle public key from oracle. + // TODO: Actually fetch it from Olivia + let oracle = schnorrsig::PublicKey::from_str( + "ddd4636845a90185991826be5a494cde9f4a6947b1727217afedc6292fa4caf7", + )?; let (order_feed_sender, order_feed_receiver) = watch::channel::>(None); let (wallet_feed_sender, wallet_feed_receiver) = watch::channel::(wallet_info); @@ -217,7 +221,7 @@ async fn main() -> Result<()> { let cfd_maker_actor_inbox = maker_cfd::Actor::new( db, wallet.clone(), - schnorrsig::PublicKey::from_keypair(SECP256K1, &oracle), + oracle, cfd_feed_sender, order_feed_sender, update_cfd_feed_sender, diff --git a/daemon/src/taker.rs b/daemon/src/taker.rs index 4dcdd65..cf9c74e 100644 --- a/daemon/src/taker.rs +++ b/daemon/src/taker.rs @@ -4,7 +4,7 @@ use crate::model::WalletInfo; use crate::wallet::Wallet; use anyhow::{Context, Result}; use bdk::bitcoin; -use bdk::bitcoin::secp256k1::{schnorrsig, SECP256K1}; +use bdk::bitcoin::secp256k1::schnorrsig; use clap::Clap; use futures::StreamExt; use model::cfd::Order; @@ -14,6 +14,7 @@ use seed::Seed; use std::collections::HashMap; use std::net::SocketAddr; use std::path::PathBuf; +use std::str::FromStr; use std::thread::sleep; use std::time::Duration; use tokio::sync::watch; @@ -142,7 +143,10 @@ async fn main() -> Result<()> { .await?; let wallet_info = wallet.sync().await.unwrap(); - let oracle = schnorrsig::KeyPair::new(SECP256K1, &mut rand::thread_rng()); // TODO: Fetch oracle public key from oracle. + // TODO: Actually fetch it from Olivia + let oracle = schnorrsig::PublicKey::from_str( + "ddd4636845a90185991826be5a494cde9f4a6947b1727217afedc6292fa4caf7", + )?; let (order_feed_sender, order_feed_receiver) = watch::channel::>(None); let (wallet_feed_sender, wallet_feed_receiver) = watch::channel::(wallet_info); @@ -217,7 +221,7 @@ async fn main() -> Result<()> { let cfd_actor_inbox = taker_cfd::Actor::new( db.clone(), wallet.clone(), - schnorrsig::PublicKey::from_keypair(SECP256K1, &oracle), + oracle, cfd_feed_sender, order_feed_sender, update_cfd_feed_sender,