musigd.rs

use std::error::Error;
use std::sync::Arc;

use bmp_tracing::tracing::info;
use clap::Parser;
use rpc::bmp_service::BmpServiceImpl;
use rpc::bmp_wallet_service::BmpWalletServiceImpl;
use rpc::pb::bmp_protocol::bmp_protocol_service_server::BmpProtocolServiceServer;
use rpc::pb::bmp_wallet::wallet_server::WalletServer as BmpWalletServer;
use rpc::server::{MusigImpl, MusigServer, WalletImpl, WalletServer};
use rpc::wallet::WalletServiceImpl;
use testenv::TestEnv;
use tonic::transport::Server;

#[derive(Debug, Parser)]
#[command(version, about, long_about = None)]
#[expect(clippy::doc_markdown, reason = "doc comments are used verbatim by Clap and not intended to be markdown")]
struct Cli {
    /// The port of the MuSig daemon
    #[arg(short, long, default_value_t = 50051)]
    port: u16,
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let cli: Cli = Cli::parse();

    bmp_tracing::init("info");

    let testenv = TestEnv::new()?;

    let addr = format!("127.0.0.1:{}", cli.port).parse()?;
    let musig = MusigImpl::default();
    let wallet = WalletImpl { wallet_service: Arc::new(WalletServiceImpl::create_with_rpc_params(testenv.bitcoin_core_rpc_client()?)) };
    wallet.wallet_service.clone().spawn_connection();

    let bmp_protocol_impl = BmpServiceImpl::default();
    let bmp_wallet_service = BmpWalletServiceImpl::default();

    info!(port = cli.port, "Starting gRPC server.");
    Server::builder()
        .add_service(MusigServer::new(musig))
        .add_service(WalletServer::new(wallet))
        .add_service(BmpProtocolServiceServer::new(bmp_protocol_impl))
        .add_service(BmpWalletServer::new(bmp_wallet_service))
        .serve(addr)
        .await?;

    Ok(())
}