cdk/crates/cdk-cli/src/sub_commands/send.rs

use std::str::FromStr;

use anyhow::{anyhow, Result};
use cdk::mint_url::MintUrl;
use cdk::nuts::{Conditions, PublicKey, SpendingConditions};
use cdk::wallet::types::SendKind;
use cdk::wallet::{MultiMintWallet, SendMemo, SendOptions};
use cdk::Amount;
use clap::Args;

use crate::utils::get_number_input;

#[derive(Args)]
pub struct SendSubCommand {
    /// Token Memo
    #[arg(short, long)]
    memo: Option<String>,
    /// Preimage
    #[arg(long, conflicts_with = "hash")]
    preimage: Option<String>,
    /// Hash for HTLC (alternative to preimage)
    #[arg(long, conflicts_with = "preimage")]
    hash: Option<String>,
    /// Required number of signatures
    #[arg(long)]
    required_sigs: Option<u64>,
    /// Locktime before refund keys can be used
    #[arg(short, long)]
    locktime: Option<u64>,
    /// Pubkey to lock proofs to
    #[arg(short, long, action = clap::ArgAction::Append)]
    pubkey: Vec<String>,
    /// Refund keys that can be used after locktime
    #[arg(long, action = clap::ArgAction::Append)]
    refund_keys: Vec<String>,
    /// Token as V3 token
    #[arg(short, long)]
    v3: bool,
    /// Should the send be offline only
    #[arg(short, long)]
    offline: bool,
    /// Include fee to redeem in token
    #[arg(short, long)]
    include_fee: bool,
    /// Amount willing to overpay to avoid a swap
    #[arg(short, long)]
    tolerance: Option<u64>,
    /// Mint URL to use for sending
    #[arg(long)]
    mint_url: Option<String>,
    /// Allow transferring funds from other mints if the target mint has insufficient balance
    #[arg(long)]
    allow_transfer: bool,
    /// Maximum amount to transfer from other mints
    #[arg(long)]
    max_transfer_amount: Option<u64>,

    /// Specific mints to exclude from transfers (can be specified multiple times)
    #[arg(long, action = clap::ArgAction::Append)]
    excluded_mints: Vec<String>,
}

pub async fn send(
    multi_mint_wallet: &MultiMintWallet,
    sub_command_args: &SendSubCommand,
) -> Result<()> {
    // Determine which mint to use for sending BEFORE asking for amount
    let selected_mint = if let Some(mint_url) = &sub_command_args.mint_url {
        Some(MintUrl::from_str(mint_url)?)
    } else {
        // Display all mints with their balances and let user select
        let balances_map = multi_mint_wallet.get_balances().await?;
        if balances_map.is_empty() {
            return Err(anyhow!("No mints available in the wallet"));
        }

        let balances_vec: Vec<(MintUrl, Amount)> = balances_map.into_iter().collect();

        println!("\nAvailable mints and balances:");
        for (index, (mint_url, balance)) in balances_vec.iter().enumerate() {
            println!(
                "  {}: {} - {} {}",
                index,
                mint_url,
                balance,
                multi_mint_wallet.unit()
            );
        }
        println!("  {}: Any mint (auto-select best)", balances_vec.len());

        let selection = loop {
            let selection: usize =
                get_number_input("Enter mint number to send from (or select Any)")?;

            if selection == balances_vec.len() {
                break None; // "Any" option selected
            }

            if let Some((mint_url, _)) = balances_vec.get(selection) {
                break Some(mint_url.clone());
            }

            println!("Invalid selection, please try again.");
        };

        selection
    };

    let token_amount = Amount::from(get_number_input::<u64>(&format!(
        "Enter value of token in {}",
        multi_mint_wallet.unit()
    ))?);

    // Check total balance across all wallets
    let total_balance = multi_mint_wallet.total_balance().await?;
    if total_balance < token_amount {
        return Err(anyhow!(
            "Insufficient funds. Total balance: {}, Required: {}",
            total_balance,
            token_amount
        ));
    }

    let conditions = match (&sub_command_args.preimage, &sub_command_args.hash) {
        (Some(_), Some(_)) => {
            // This case shouldn't be reached due to Clap's conflicts_with attribute
            unreachable!("Both preimage and hash were provided despite conflicts_with attribute")
        }
        (Some(preimage), None) => {
            let pubkeys = match sub_command_args.pubkey.is_empty() {
                true => None,
                false => Some(
                    sub_command_args
                        .pubkey
                        .iter()
                        .map(|p| PublicKey::from_str(p).unwrap())
                        .collect(),
                ),
            };

            let refund_keys = match sub_command_args.refund_keys.is_empty() {
                true => None,
                false => Some(
                    sub_command_args
                        .refund_keys
                        .iter()
                        .map(|p| PublicKey::from_str(p).unwrap())
                        .collect(),
                ),
            };

            let conditions = Conditions::new(
                sub_command_args.locktime,
                pubkeys,
                refund_keys,
                sub_command_args.required_sigs,
                None,
                None,
            )
            .unwrap();

            Some(SpendingConditions::new_htlc(
                preimage.clone(),
                Some(conditions),
            )?)
        }
        (None, Some(hash)) => {
            let pubkeys = match sub_command_args.pubkey.is_empty() {
                true => None,
                false => Some(
                    sub_command_args
                        .pubkey
                        .iter()
                        .map(|p| PublicKey::from_str(p).unwrap())
                        .collect(),
                ),
            };

            let refund_keys = match sub_command_args.refund_keys.is_empty() {
                true => None,
                false => Some(
                    sub_command_args
                        .refund_keys
                        .iter()
                        .map(|p| PublicKey::from_str(p).unwrap())
                        .collect(),
                ),
            };

            let conditions = Conditions::new(
                sub_command_args.locktime,
                pubkeys,
                refund_keys,
                sub_command_args.required_sigs,
                None,
                None,
            )?;

            Some(SpendingConditions::new_htlc_hash(hash, Some(conditions))?)
        }
        (None, None) => match sub_command_args.pubkey.is_empty() {
            true => None,
            false => {
                let pubkeys: Vec<PublicKey> = sub_command_args
                    .pubkey
                    .iter()
                    .map(|p| PublicKey::from_str(p).unwrap())
                    .collect();

                let refund_keys: Vec<PublicKey> = sub_command_args
                    .refund_keys
                    .iter()
                    .map(|p| PublicKey::from_str(p).unwrap())
                    .collect();

                let refund_keys = (!refund_keys.is_empty()).then_some(refund_keys);

                let data_pubkey = pubkeys[0];
                let pubkeys = pubkeys[1..].to_vec();
                let pubkeys = (!pubkeys.is_empty()).then_some(pubkeys);

                let conditions = Conditions::new(
                    sub_command_args.locktime,
                    pubkeys,
                    refund_keys,
                    sub_command_args.required_sigs,
                    None,
                    None,
                )?;

                Some(SpendingConditions::P2PKConditions {
                    data: data_pubkey,
                    conditions: Some(conditions),
                })
            }
        },
    };

    let send_kind = match (sub_command_args.offline, sub_command_args.tolerance) {
        (true, Some(amount)) => SendKind::OfflineTolerance(Amount::from(amount)),
        (true, None) => SendKind::OfflineExact,
        (false, Some(amount)) => SendKind::OnlineTolerance(Amount::from(amount)),
        (false, None) => SendKind::OnlineExact,
    };

    let send_options = SendOptions {
        memo: sub_command_args.memo.clone().map(|memo| SendMemo {
            memo,
            include_memo: true,
        }),
        send_kind,
        include_fee: sub_command_args.include_fee,
        conditions,
        ..Default::default()
    };

    // Parse excluded mints from CLI arguments
    let excluded_mints: Result<Vec<MintUrl>, _> = sub_command_args
        .excluded_mints
        .iter()
        .map(|url| MintUrl::from_str(url))
        .collect();
    let excluded_mints = excluded_mints?;

    // Prepare and confirm the send based on mint selection
    let token = if let Some(specific_mint) = selected_mint {
        // User selected a specific mint
        let multi_mint_options = cdk::wallet::multi_mint_wallet::MultiMintSendOptions {
            allow_transfer: sub_command_args.allow_transfer,
            max_transfer_amount: sub_command_args.max_transfer_amount.map(Amount::from),
            allowed_mints: vec![specific_mint.clone()], // Use selected mint as the only allowed mint
            excluded_mints,
            send_options: send_options.clone(),
        };

        let prepared = multi_mint_wallet
            .prepare_send(specific_mint, token_amount, multi_mint_options)
            .await?;

        let memo = send_options.memo.clone();
        prepared.confirm(memo).await?
    } else {
        // User selected "Any" - find the first mint with sufficient balance
        let balances = multi_mint_wallet.get_balances().await?;
        let best_mint = balances
            .into_iter()
            .find(|(_, balance)| *balance >= token_amount)
            .map(|(mint_url, _)| mint_url)
            .ok_or_else(|| anyhow!("No mint has sufficient balance for the requested amount"))?;

        let multi_mint_options = cdk::wallet::multi_mint_wallet::MultiMintSendOptions {
            allow_transfer: sub_command_args.allow_transfer,
            max_transfer_amount: sub_command_args.max_transfer_amount.map(Amount::from),
            allowed_mints: vec![best_mint.clone()], // Use the best mint as the only allowed mint
            excluded_mints,
            send_options: send_options.clone(),
        };

        let prepared = multi_mint_wallet
            .prepare_send(best_mint, token_amount, multi_mint_options)
            .await?;

        let memo = send_options.memo.clone();
        prepared.confirm(memo).await?
    };

    match sub_command_args.v3 {
        true => {
            let token = token;

            println!("{}", token.to_v3_string());
        }
        false => {
            println!("{token}");
        }
    }

    Ok(())
}