use std::{
collections::HashMap,
path::{Path, PathBuf}
};
use anyhow::Result;
use clap::ArgMatches;
use odra::{
contract_def::HasIdent,
entry_point_callback::EntryPointsCaller,
host::{EntryPointsCallerProvider, HostEnv},
schema::{SchemaCustomTypes, SchemaEntrypoints, SchemaEvents},
OdraContract
};
use crate::{
cmd::{
ContractsCmd, DeployCmd, DeployScript, MainCmd, MutableCommand, OdraCommand,
PrintEventsCmd, Scenario, ScenarioMetadata, ScenariosCmd, WhoamiCmd, CONTRACTS_SUBCOMMAND,
DEPLOY_SUBCOMMAND, PRINT_EVENTS_SUBCOMMAND, SCENARIOS_SUBCOMMAND, WHOAMI_SUBCOMMAND
},
container::FileContractStorage,
custom_types::CustomTypes,
utils::get_default_contracts_file,
ContractProvider, DeployedContractsContainer
};
pub struct OdraCli {
main_cmd: MainCmd,
deploy_cmd: Option<DeployCmd>,
contracts_cmd: ContractsCmd,
print_events_cmd: PrintEventsCmd,
scenarios_cmd: ScenariosCmd,
whoami_cmd: WhoamiCmd,
custom_types: CustomTypes,
host_env: HostEnv,
callers: HashMap<(String, String), EntryPointsCaller>,
default_contract_path: Option<PathBuf>
}
impl Default for OdraCli {
fn default() -> Self {
Self::new()
}
}
impl OdraCli {
pub fn new() -> Self {
Self {
main_cmd: MainCmd::default(),
deploy_cmd: None,
contracts_cmd: ContractsCmd::default(),
print_events_cmd: PrintEventsCmd::default(),
scenarios_cmd: ScenariosCmd::default(),
whoami_cmd: WhoamiCmd::new(),
host_env: odra_casper_livenet_env::env(),
custom_types: CustomTypes::default(),
callers: HashMap::default(),
default_contract_path: None
}
}
pub fn about(mut self, about: &'static str) -> Self {
self.main_cmd = self.main_cmd.about(about);
self
}
pub fn contracts_file<P: AsRef<Path>>(mut self, path: P) -> Self {
self.default_contract_path = Some(path.as_ref().to_path_buf());
self
}
pub fn contract<T: SchemaEntrypoints + SchemaCustomTypes + SchemaEvents + OdraContract>(
mut self
) -> Self {
self.callers.insert(
(T::HostRef::ident(), T::HostRef::ident()),
T::HostRef::entry_points_caller(&self.host_env)
);
self.custom_types.register::<T>();
self.contracts_cmd.add_contract::<T>();
self.print_events_cmd.add_contract::<T>();
self
}
pub fn named_contract<
T: SchemaEntrypoints + SchemaCustomTypes + SchemaEvents + OdraContract
>(
mut self,
name: String
) -> Self {
self.callers.insert(
(T::HostRef::ident(), name.clone()),
T::HostRef::entry_points_caller(&self.host_env)
);
self.custom_types.register::<T>();
self.contracts_cmd.add_contract_named::<T>(name.clone());
self.print_events_cmd.add_contract_named::<T>(name);
self
}
pub fn deploy(mut self, script: impl DeployScript + 'static) -> Self {
let cmd = DeployCmd::new(script);
self.main_cmd = self.main_cmd.subcommand(&cmd);
self.deploy_cmd = Some(cmd);
self
}
pub fn scenario<S: ScenarioMetadata + Scenario>(mut self, scenario: S) -> Self {
self.scenarios_cmd.add_scenario(scenario);
self
}
pub fn build(mut self) -> Self {
self.main_cmd = self.main_cmd.subcommand(&self.contracts_cmd);
self.main_cmd = self.main_cmd.subcommand(&self.scenarios_cmd);
self.main_cmd = self.main_cmd.subcommand(&self.print_events_cmd);
self.main_cmd = self.main_cmd.subcommand(&self.whoami_cmd);
self
}
pub fn run(self) {
let (cmd, args, contracts_path) = self.main_cmd.get_matches();
let contracts_path = match contracts_path {
Some(path) => Some(path),
None => self.default_contract_path.clone()
};
let storage = FileContractStorage::new(contracts_path.clone()).unwrap_or_else(|e| {
prettycli::error(&format!("Failed to create contract storage: {e}"));
std::process::exit(1);
});
let mut container = DeployedContractsContainer::instance(storage);
for deployed_contract in container.all_contracts() {
let caller = self.callers.get(&(deployed_contract.name(), deployed_contract.key_name())).unwrap_or_else(|| {
let path = match &contracts_path {
Some(path) => path.to_str().map(|s| s.to_string()).unwrap_or_default(),
None => get_default_contracts_file()
};
prettycli::error(&format!(
"Caller for `{}` not found. The contract is registered in '{}' file, but not in the CLI builder. Make sure you have added it to the builder using `.contract::<{}>()`.",
&deployed_contract.key_name(), path, &deployed_contract.name()
));
std::process::exit(1);
}).clone();
self.host_env.register_contract(
deployed_contract.address(),
deployed_contract.key_name(),
caller
);
}
let result = match cmd.as_str() {
DEPLOY_SUBCOMMAND => self
.deploy_cmd
.as_ref()
.unwrap_or_else(|| {
prettycli::error("Deploy command not found. Did you forget to add it?");
std::process::exit(1);
})
.run(&self.host_env, &args, &self.custom_types, &mut container),
CONTRACTS_SUBCOMMAND => self.run_command(&self.contracts_cmd, args, &container),
PRINT_EVENTS_SUBCOMMAND => self.run_command(&self.print_events_cmd, args, &container),
SCENARIOS_SUBCOMMAND => self.run_command(&self.scenarios_cmd, args, &container),
WHOAMI_SUBCOMMAND => self.run_command(&self.whoami_cmd, args, &container),
_ => unreachable!()
};
match result {
Ok(_) => {}
Err(err) => prettycli::error(&format!("{err}"))
}
}
fn run_command<T: OdraCommand>(
&self,
cmd: &T,
args: ArgMatches,
container: &DeployedContractsContainer
) -> Result<()> {
cmd.run(&self.host_env, &args, &self.custom_types, container)
}
}