mithril_client_cli/commands/cardano_transaction/

snapshot_list.rs

use clap::Parser;
use cli_table::format::Justify;
use cli_table::{print_stdout, Cell, Table};

use crate::commands::{client_builder_with_fallback_genesis_key, SharedArgs};
use crate::CommandContext;
use mithril_client::MithrilResult;

/// Cardano transaction snapshot list command
#[derive(Parser, Debug, Clone)]
pub struct CardanoTransactionSnapshotListCommand {
    #[clap(flatten)]
    shared_args: SharedArgs,
}

impl CardanoTransactionSnapshotListCommand {
    /// Is JSON output enabled
    pub fn is_json_output_enabled(&self) -> bool {
        self.shared_args.json
    }

    /// Main command execution
    pub async fn execute(&self, context: CommandContext) -> MithrilResult<()> {
        let params = context.config_parameters()?;
        let client = client_builder_with_fallback_genesis_key(&params)?
            .with_logger(context.logger().clone())
            .build()?;
        let lines = client.cardano_transaction().list_snapshots().await?;

        if self.is_json_output_enabled() {
            println!("{}", serde_json::to_string(&lines)?);
        } else {
            let lines = lines
                .into_iter()
                .map(|item| {
                    vec![
                        format!("{}", item.epoch).cell(),
                        format!("{}", item.block_number).cell(),
                        item.hash.cell(),
                        item.certificate_hash.cell(),
                        item.created_at.to_string().cell(),
                    ]
                })
                .collect::<Vec<_>>()
                .table()
                .title(vec![
                    "Epoch".cell(),
                    "Block Number".cell(),
                    "Hash".cell(),
                    "Certificate Hash".cell(),
                    "Created".cell().justify(Justify::Right),
                ]);
            print_stdout(lines)?;
        }

        Ok(())
    }
}