soroban-cli 26.0.0

use crate::print::Print;
use soroban_rpc::GetTransactionResponse;
use std::ffi::OsString;

use crate::{
    commands::global,
    config::{self, locator, network},
};

use stellar_xdr::curr;

#[derive(thiserror::Error, Debug)]
pub enum Error {
    #[error(transparent)]
    XdrArgs(#[from] super::xdr::Error),
    #[error(transparent)]
    Network(#[from] network::Error),
    #[error(transparent)]
    Config(#[from] config::Error),
    #[error(transparent)]
    Rpc(#[from] crate::rpc::Error),
    #[error(transparent)]
    SerdeJson(#[from] serde_json::Error),
    #[error("xdr processing error: {0}")]
    Xdr(#[from] curr::Error),
}

#[derive(Debug, clap::Parser, Clone)]
#[group(skip)]
/// Command to send a transaction envelope to the network
/// e.g. `stellar tx send file.txt` or `cat file.txt | stellar tx send`
pub struct Cmd {
    /// Base-64 transaction envelope XDR or file containing XDR to decode, or stdin if empty
    #[arg()]
    pub tx_xdr: Option<OsString>,
    #[clap(flatten)]
    pub network: network::Args,
    #[clap(flatten)]
    pub locator: locator::Args,
}

impl Cmd {
    pub async fn run(&self, global_args: &global::Args) -> Result<(), Error> {
        let response = self
            .execute(
                &config::Args {
                    locator: self.locator.clone(),
                    network: self.network.clone(),
                    source_account: config::UnresolvedMuxedAccount::default(),
                    sign_with: config::sign_with::Args::default(),
                    fee: None,
                    inclusion_fee: None,
                },
                global_args.quiet,
            )
            .await?;
        println!("{}", serde_json::to_string_pretty(&response)?);
        Ok(())
    }

    pub async fn execute(
        &self,
        config: &config::Args,
        quiet: bool,
    ) -> Result<GetTransactionResponse, Error> {
        let network = config.get_network()?;
        let client = network.rpc_client()?;
        let tx_env = super::xdr::tx_envelope_from_input(&self.tx_xdr)?;

        if let Ok(txn) = super::xdr::unwrap_envelope_v1(tx_env.clone()) {
            let print = Print::new(quiet);
            print.log_transaction(&txn, &network, true)?;
        }

        Ok(client.send_transaction_polling(&tx_env).await?)
    }
}