use hermes_cli_components::traits::build::CanLoadBuilder;
use hermes_cli_framework::command::CommandRunner;
use hermes_cli_framework::output::{json, Output};
use hermes_cosmos_relayer::contexts::chain::CosmosChain;
use hermes_relayer_components::chain::traits::queries::packet_commitments::CanQueryPacketCommitments;
use ibc_relayer_types::core::ics24_host::identifier::{ChainId, ChannelId, PortId};
use crate::commands::query::packet::util::PacketSequences;
use crate::contexts::app::HermesApp;
use crate::Result;
#[derive(Debug, clap::Parser)]
pub struct QueryPacketCommitments {
#[clap(
long = "chain",
required = true,
value_name = "CHAIN_ID",
help_heading = "REQUIRED"
)]
chain_id: ChainId,
#[clap(
long = "port",
required = true,
value_name = "PORT_ID",
help_heading = "REQUIRED"
)]
port_id: PortId,
#[clap(
long = "channel",
required = true,
value_name = "CHANNEL_ID",
help_heading = "REQUIRED"
)]
channel_id: ChannelId,
}
impl CommandRunner<HermesApp> for QueryPacketCommitments {
async fn run(&self, app: &HermesApp) -> Result<Output> {
let builder = app.load_builder().await?;
let chain = builder.build_chain(&self.chain_id).await?;
let (sequences, height) =
<CosmosChain as CanQueryPacketCommitments<CosmosChain>>::query_packet_commitments(
&chain,
&self.channel_id,
&self.port_id,
)
.await?;
let packet_sequences = PacketSequences::new(height, sequences);
if json() {
Ok(Output::success(packet_sequences))
} else {
Ok(Output::success(packet_sequences.collated()))
}
}
}