solana-cli 4.0.0-beta.7

use {
    crate::cli::{CliCommand, CliCommandInfo, CliConfig, CliError, ProcessResult},
    clap::{App, Arg, ArgMatches, SubCommand},
    solana_clap_utils::{
        input_parsers::{pubkeys_of, value_of},
        input_validators::is_valid_pubkey,
        keypair::*,
    },
    solana_cli_output::{
        CliEpochRewardsMetadata, CliInflation, CliKeyedEpochReward, CliKeyedEpochRewards,
    },
    solana_clock::{Epoch, Slot, UnixTimestamp},
    solana_pubkey::Pubkey,
    solana_remote_wallet::remote_wallet::RemoteWalletManager,
    solana_rpc_client::nonblocking::rpc_client::RpcClient,
    std::{collections::HashMap, rc::Rc},
};

#[derive(Debug, PartialEq, Eq)]
pub enum InflationCliCommand {
    Show,
    Rewards(Vec<Pubkey>, Option<Epoch>),
}

pub trait InflationSubCommands {
    fn inflation_subcommands(self) -> Self;
}

impl InflationSubCommands for App<'_, '_> {
    fn inflation_subcommands(self) -> Self {
        self.subcommand(
            SubCommand::with_name("inflation")
                .about("Show inflation information")
                .subcommand(
                    SubCommand::with_name("rewards")
                        .about("Show inflation rewards for a set of addresses")
                        .arg(pubkey!(
                            Arg::with_name("addresses")
                                .value_name("ADDRESS")
                                .index(1)
                                .multiple(true)
                                .required(true),
                            "Account to query for rewards."
                        ))
                        .arg(
                            Arg::with_name("rewards_epoch")
                                .long("rewards-epoch")
                                .takes_value(true)
                                .value_name("EPOCH")
                                .help("Display rewards for specific epoch [default: latest epoch]"),
                        ),
                ),
        )
    }
}

pub fn parse_inflation_subcommand(
    matches: &ArgMatches<'_>,
    _default_signer: &DefaultSigner,
    _wallet_manager: &mut Option<Rc<RemoteWalletManager>>,
) -> Result<CliCommandInfo, CliError> {
    let command = match matches.subcommand() {
        ("rewards", Some(matches)) => {
            let addresses = pubkeys_of(matches, "addresses").unwrap();
            let rewards_epoch = value_of(matches, "rewards_epoch");
            InflationCliCommand::Rewards(addresses, rewards_epoch)
        }
        _ => InflationCliCommand::Show,
    };
    Ok(CliCommandInfo::without_signers(CliCommand::Inflation(
        command,
    )))
}

pub async fn process_inflation_subcommand(
    rpc_client: &RpcClient,
    config: &CliConfig<'_>,
    inflation_subcommand: &InflationCliCommand,
) -> ProcessResult {
    match inflation_subcommand {
        InflationCliCommand::Show => process_show(rpc_client, config).await,
        InflationCliCommand::Rewards(addresses, rewards_epoch) => {
            process_rewards(rpc_client, config, addresses, *rewards_epoch).await
        }
    }
}

async fn process_show(rpc_client: &RpcClient, config: &CliConfig<'_>) -> ProcessResult {
    let governor = rpc_client.get_inflation_governor().await?;
    let current_rate = rpc_client.get_inflation_rate().await?;

    let inflation = CliInflation {
        governor,
        current_rate,
    };

    Ok(config.output_format.formatted_string(&inflation))
}

async fn process_rewards(
    rpc_client: &RpcClient,
    config: &CliConfig<'_>,
    addresses: &[Pubkey],
    rewards_epoch: Option<Epoch>,
) -> ProcessResult {
    let rewards = rpc_client
        .get_inflation_reward(addresses, rewards_epoch)
        .await
        .map_err(|err| {
            if let Some(epoch) = rewards_epoch {
                format!("Rewards not available for epoch {epoch}")
            } else {
                format!("Rewards not available {err}")
            }
        })?;
    let epoch_schedule = rpc_client.get_epoch_schedule().await?;

    let mut epoch_rewards: Vec<CliKeyedEpochReward> = vec![];
    let mut block_times: HashMap<Slot, UnixTimestamp> = HashMap::new();
    let epoch_metadata = if let Some(Some(first_reward)) = rewards.iter().find(|&v| v.is_some()) {
        let (epoch_start_time, epoch_end_time) =
            crate::stake::get_epoch_boundary_timestamps(rpc_client, first_reward, &epoch_schedule)
                .await?;
        for (reward, address) in rewards.iter().zip(addresses) {
            let cli_reward = if let Some(reward) = reward {
                let block_time = if let Some(block_time) = block_times.get(&reward.effective_slot) {
                    *block_time
                } else {
                    let block_time = rpc_client.get_block_time(reward.effective_slot).await?;
                    block_times.insert(reward.effective_slot, block_time);
                    block_time
                };
                crate::stake::make_cli_reward(reward, block_time, epoch_start_time, epoch_end_time)
            } else {
                None
            };
            epoch_rewards.push(CliKeyedEpochReward {
                address: address.to_string(),
                reward: cli_reward,
            });
        }
        Some(CliEpochRewardsMetadata {
            epoch: first_reward.epoch,
            ..CliEpochRewardsMetadata::default()
        })
    } else {
        None
    };
    let cli_rewards = CliKeyedEpochRewards {
        epoch_metadata,
        rewards: epoch_rewards,
    };
    Ok(config.output_format.formatted_string(&cli_rewards))
}