use std::io::Write;
use color_eyre::eyre::Context;
use inquire::Text;
use crate::common::JsonRpcClientExt;
#[derive(Debug, Clone, interactive_clap::InteractiveClap)]
#[interactive_clap(input_context = crate::GlobalContext)]
#[interactive_clap(output_context = ContractContext)]
pub struct Contract {
#[interactive_clap(skip_default_input_arg)]
account_id: crate::types::account_id::AccountId,
#[interactive_clap(named_arg)]
save_to_file: DownloadContract,
}
#[derive(Debug, Clone)]
pub struct ContractContext {
global_context: crate::GlobalContext,
account_id: unc_primitives::types::AccountId,
}
impl ContractContext {
pub fn from_previous_context(
previous_context: crate::GlobalContext,
scope: &<Contract as interactive_clap::ToInteractiveClapContextScope>::InteractiveClapContextScope,
) -> color_eyre::eyre::Result<Self> {
Ok(Self {
global_context: previous_context,
account_id: scope.account_id.clone().into(),
})
}
}
impl Contract {
pub fn input_account_id(
context: &crate::GlobalContext,
) -> color_eyre::eyre::Result<Option<crate::types::account_id::AccountId>> {
crate::common::input_non_signer_account_id_from_used_account_list(
&context.config.credentials_home_dir,
"What is the contract account ID?",
)
}
}
#[derive(Debug, Clone, interactive_clap::InteractiveClap)]
#[interactive_clap(input_context = ContractContext)]
#[interactive_clap(output_context = DownloadContractContext)]
pub struct DownloadContract {
#[interactive_clap(skip_default_input_arg)]
file_path: crate::types::path_buf::PathBuf,
#[interactive_clap(named_arg)]
network_config: crate::network_view_at_block::NetworkViewAtBlockArgs,
}
#[derive(Clone)]
pub struct DownloadContractContext(crate::network_view_at_block::ArgsForViewContext);
impl DownloadContractContext {
pub fn from_previous_context(
previous_context: ContractContext,
scope: &<DownloadContract as interactive_clap::ToInteractiveClapContextScope>::InteractiveClapContextScope,
) -> color_eyre::eyre::Result<Self> {
let on_after_getting_block_reference_callback: crate::network_view_at_block::OnAfterGettingBlockReferenceCallback = std::sync::Arc::new({
let account_id = previous_context.account_id.clone();
let file_path: std::path::PathBuf = scope.file_path.clone().into();
move |network_config, block_reference| {
let query_view_method_response = network_config
.json_rpc_client()
.blocking_call(unc_jsonrpc_client::methods::query::RpcQueryRequest {
block_reference: block_reference.clone(),
request: unc_primitives::views::QueryRequest::ViewCode {
account_id: account_id.clone(),
},
})
.wrap_err_with(|| format!("Failed to fetch query ViewCode for <{}> on network <{}>", &account_id, network_config.network_name))?;
let call_access_view =
if let unc_jsonrpc_primitives::types::query::QueryResponseKind::ViewCode(result) =
query_view_method_response.kind
{
result
} else {
return Err(color_eyre::Report::msg("Error call result".to_string()));
};
std::fs::File::create(&file_path)
.wrap_err_with(|| format!("Failed to create file: {:?}", &file_path))?
.write(&call_access_view.code)
.wrap_err_with(|| {
format!("Failed to write to file: {:?}", &file_path)
})?;
eprintln!("\nThe file {:?} was downloaded successfully", &file_path);
Ok(())
}
});
Ok(Self(crate::network_view_at_block::ArgsForViewContext {
config: previous_context.global_context.config,
on_after_getting_block_reference_callback,
interacting_with_account_ids: vec![previous_context.account_id],
}))
}
}
impl From<DownloadContractContext> for crate::network_view_at_block::ArgsForViewContext {
fn from(item: DownloadContractContext) -> Self {
item.0
}
}
impl DownloadContract {
fn input_file_path(
context: &ContractContext,
) -> color_eyre::eyre::Result<Option<crate::types::path_buf::PathBuf>> {
let input_file_path = Text::new("Enter the name of the file to save the contract:")
.with_initial_value(&format!(
"{}.wasm",
context.account_id.as_str().replace('.', "_")
))
.prompt()?;
Ok(Some(shellexpand::tilde(&input_file_path).as_ref().parse()?))
}
}