You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
211 lines
5.6 KiB
Rust
211 lines
5.6 KiB
Rust
use testcontainers::{core::WaitFor, Image, ImageArgs};
|
|
|
|
pub const MONEROD_DAEMON_CONTAINER_NAME: &str = "monerod";
|
|
pub const MONEROD_DEFAULT_NETWORK: &str = "monero_network";
|
|
|
|
/// The port we use for all RPC communication.
|
|
///
|
|
/// This is the default when running monerod.
|
|
/// For `monero-wallet-rpc` we always need to specify a port. To make things
|
|
/// simpler, we just specify the same one. They are in different containers so
|
|
/// this doesn't matter.
|
|
pub const RPC_PORT: u16 = 18081;
|
|
|
|
#[derive(Clone, Copy, Debug, Default)]
|
|
pub struct Monerod;
|
|
|
|
impl Image for Monerod {
|
|
type Args = MonerodArgs;
|
|
|
|
fn name(&self) -> String {
|
|
"rinocommunity/monero".into()
|
|
}
|
|
|
|
fn tag(&self) -> String {
|
|
"v0.18.1.2".into()
|
|
}
|
|
|
|
fn ready_conditions(&self) -> Vec<WaitFor> {
|
|
vec![WaitFor::message_on_stdout("RPC server started ok")]
|
|
}
|
|
|
|
fn entrypoint(&self) -> Option<String> {
|
|
Some("".to_owned()) // an empty entrypoint disables the entrypoint
|
|
// script and gives us full control
|
|
}
|
|
}
|
|
|
|
#[derive(Clone, Copy, Debug)]
|
|
pub struct MoneroWalletRpc;
|
|
|
|
impl Image for MoneroWalletRpc {
|
|
type Args = MoneroWalletRpcArgs;
|
|
|
|
fn name(&self) -> String {
|
|
"rinocommunity/monero".into()
|
|
}
|
|
|
|
fn tag(&self) -> String {
|
|
"v0.18.1.2".into()
|
|
}
|
|
|
|
fn ready_conditions(&self) -> Vec<WaitFor> {
|
|
vec![WaitFor::message_on_stdout("Run server thread name: RPC")]
|
|
}
|
|
|
|
fn entrypoint(&self) -> Option<String> {
|
|
Some("".to_owned()) // an empty entrypoint disables the entrypoint
|
|
// script and gives us full control
|
|
}
|
|
}
|
|
|
|
impl MoneroWalletRpc {
|
|
pub fn new(name: &str, daemon_address: String) -> (Self, MoneroWalletRpcArgs) {
|
|
let args = MoneroWalletRpcArgs::new(name, daemon_address);
|
|
(Self, args)
|
|
}
|
|
}
|
|
|
|
#[derive(Debug, Clone)]
|
|
pub struct MonerodArgs {
|
|
pub regtest: bool,
|
|
pub offline: bool,
|
|
pub rpc_payment_allow_free_loopback: bool,
|
|
pub confirm_external_bind: bool,
|
|
pub no_igd: bool,
|
|
pub hide_my_port: bool,
|
|
pub rpc_bind_ip: String,
|
|
pub fixed_difficulty: u32,
|
|
pub data_dir: String,
|
|
}
|
|
|
|
impl Default for MonerodArgs {
|
|
fn default() -> Self {
|
|
Self {
|
|
regtest: true,
|
|
offline: true,
|
|
rpc_payment_allow_free_loopback: true,
|
|
confirm_external_bind: true,
|
|
no_igd: true,
|
|
hide_my_port: true,
|
|
rpc_bind_ip: "0.0.0.0".to_string(),
|
|
fixed_difficulty: 1,
|
|
data_dir: "/monero".to_string(),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl IntoIterator for MonerodArgs {
|
|
type Item = String;
|
|
type IntoIter = ::std::vec::IntoIter<String>;
|
|
|
|
fn into_iter(self) -> <Self as IntoIterator>::IntoIter {
|
|
let mut args = vec![
|
|
"monerod".to_string(),
|
|
"--log-level=4".to_string(),
|
|
"--non-interactive".to_string(),
|
|
];
|
|
|
|
if self.regtest {
|
|
args.push("--regtest".to_string())
|
|
}
|
|
|
|
if self.offline {
|
|
args.push("--offline".to_string())
|
|
}
|
|
|
|
if self.rpc_payment_allow_free_loopback {
|
|
args.push("--rpc-payment-allow-free-loopback".to_string())
|
|
}
|
|
|
|
if self.confirm_external_bind {
|
|
args.push("--confirm-external-bind".to_string())
|
|
}
|
|
|
|
if self.no_igd {
|
|
args.push("--no-igd".to_string())
|
|
}
|
|
|
|
if self.hide_my_port {
|
|
args.push("--hide-my-port".to_string())
|
|
}
|
|
|
|
if !self.rpc_bind_ip.is_empty() {
|
|
args.push(format!("--rpc-bind-ip={}", self.rpc_bind_ip));
|
|
}
|
|
|
|
if !self.data_dir.is_empty() {
|
|
args.push(format!("--data-dir={}", self.data_dir));
|
|
}
|
|
|
|
if self.fixed_difficulty != 0 {
|
|
args.push(format!("--fixed-difficulty={}", self.fixed_difficulty));
|
|
}
|
|
|
|
args.into_iter()
|
|
}
|
|
}
|
|
|
|
impl ImageArgs for MonerodArgs {
|
|
fn into_iterator(self) -> Box<dyn Iterator<Item = String>> {
|
|
Box::new(self.into_iter())
|
|
}
|
|
}
|
|
|
|
#[derive(Debug, Clone)]
|
|
pub struct MoneroWalletRpcArgs {
|
|
pub disable_rpc_login: bool,
|
|
pub confirm_external_bind: bool,
|
|
pub wallet_dir: String,
|
|
pub rpc_bind_ip: String,
|
|
pub daemon_address: String,
|
|
}
|
|
|
|
impl MoneroWalletRpcArgs {
|
|
pub fn new(wallet_name: &str, daemon_address: String) -> Self {
|
|
Self {
|
|
disable_rpc_login: true,
|
|
confirm_external_bind: true,
|
|
wallet_dir: wallet_name.into(),
|
|
rpc_bind_ip: "0.0.0.0".into(),
|
|
daemon_address,
|
|
}
|
|
}
|
|
}
|
|
|
|
impl IntoIterator for MoneroWalletRpcArgs {
|
|
type Item = String;
|
|
type IntoIter = ::std::vec::IntoIter<String>;
|
|
|
|
fn into_iter(self) -> <Self as IntoIterator>::IntoIter {
|
|
let mut args = vec![
|
|
"monero-wallet-rpc".to_string(),
|
|
format!("--wallet-dir={}", self.wallet_dir),
|
|
format!("--daemon-address={}", self.daemon_address),
|
|
format!("--rpc-bind-port={}", RPC_PORT),
|
|
"--log-level=4".to_string(),
|
|
"--allow-mismatched-daemon-version".to_string(), /* https://github.com/monero-project/monero/issues/8600 */
|
|
];
|
|
|
|
if self.disable_rpc_login {
|
|
args.push("--disable-rpc-login".to_string())
|
|
}
|
|
|
|
if self.confirm_external_bind {
|
|
args.push("--confirm-external-bind".to_string())
|
|
}
|
|
|
|
if !self.rpc_bind_ip.is_empty() {
|
|
args.push(format!("--rpc-bind-ip={}", self.rpc_bind_ip));
|
|
}
|
|
|
|
args.into_iter()
|
|
}
|
|
}
|
|
|
|
impl ImageArgs for MoneroWalletRpcArgs {
|
|
fn into_iterator(self) -> Box<dyn Iterator<Item = String>> {
|
|
Box::new(self.into_iter())
|
|
}
|
|
}
|