use crate::{
utils::{extract_endpoint, extract_value, unused_port},
NodeError, NODE_DIAL_LOOP_TIMEOUT, NODE_STARTUP_TIMEOUT,
};
use alloy_genesis::{CliqueConfig, Genesis};
use alloy_primitives::Address;
use k256::ecdsa::SigningKey;
use std::{
ffi::OsString,
fs::{create_dir, File},
io::{BufRead, BufReader},
path::PathBuf,
process::{Child, ChildStderr, Command, Stdio},
time::Instant,
};
use tempfile::tempdir;
use url::Url;
const API: &str = "eth,net,web3,txpool,admin,personal,miner,debug";
const GETH: &str = "geth";
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum NodeMode {
Dev(DevOptions),
NonDev(PrivateNetOptions),
}
impl Default for NodeMode {
fn default() -> Self {
Self::Dev(Default::default())
}
}
#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
pub struct DevOptions {
pub block_time: Option<u64>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub struct PrivateNetOptions {
pub p2p_port: Option<u16>,
pub discovery: bool,
}
impl Default for PrivateNetOptions {
fn default() -> Self {
Self { p2p_port: None, discovery: true }
}
}
#[derive(Debug)]
pub struct GethInstance {
pid: Child,
port: u16,
p2p_port: Option<u16>,
auth_port: Option<u16>,
ipc: Option<PathBuf>,
data_dir: Option<PathBuf>,
genesis: Option<Genesis>,
clique_private_key: Option<SigningKey>,
}
impl GethInstance {
pub const fn port(&self) -> u16 {
self.port
}
pub const fn p2p_port(&self) -> Option<u16> {
self.p2p_port
}
pub const fn auth_port(&self) -> Option<u16> {
self.auth_port
}
#[doc(alias = "http_endpoint")]
pub fn endpoint(&self) -> String {
format!("http://localhost:{}", self.port)
}
pub fn ws_endpoint(&self) -> String {
format!("ws://localhost:{}", self.port)
}
pub fn ipc_endpoint(&self) -> String {
self.ipc.clone().map_or_else(|| "geth.ipc".to_string(), |ipc| ipc.display().to_string())
}
#[doc(alias = "http_endpoint_url")]
pub fn endpoint_url(&self) -> Url {
Url::parse(&self.endpoint()).unwrap()
}
pub fn ws_endpoint_url(&self) -> Url {
Url::parse(&self.ws_endpoint()).unwrap()
}
pub const fn data_dir(&self) -> Option<&PathBuf> {
self.data_dir.as_ref()
}
pub const fn genesis(&self) -> Option<&Genesis> {
self.genesis.as_ref()
}
#[deprecated = "clique support was removed in geth >=1.14"]
pub const fn clique_private_key(&self) -> Option<&SigningKey> {
self.clique_private_key.as_ref()
}
pub fn stderr(&mut self) -> Result<ChildStderr, NodeError> {
self.pid.stderr.take().ok_or(NodeError::NoStderr)
}
pub fn wait_to_add_peer(&mut self, id: &str) -> Result<(), NodeError> {
let mut stderr = self.pid.stderr.as_mut().ok_or(NodeError::NoStderr)?;
let mut err_reader = BufReader::new(&mut stderr);
let mut line = String::new();
let start = Instant::now();
while start.elapsed() < NODE_DIAL_LOOP_TIMEOUT {
line.clear();
err_reader.read_line(&mut line).map_err(NodeError::ReadLineError)?;
let truncated_id = if id.len() > 16 { &id[..16] } else { id };
if line.contains("Adding p2p peer") && line.contains(truncated_id) {
return Ok(());
}
}
Err(NodeError::Timeout)
}
}
impl Drop for GethInstance {
fn drop(&mut self) {
self.pid.kill().expect("could not kill geth");
}
}
#[derive(Clone, Debug, Default)]
#[must_use = "This Builder struct does nothing unless it is `spawn`ed"]
pub struct Geth {
program: Option<PathBuf>,
port: Option<u16>,
authrpc_port: Option<u16>,
ipc_path: Option<PathBuf>,
ipc_enabled: bool,
data_dir: Option<PathBuf>,
chain_id: Option<u64>,
insecure_unlock: bool,
genesis: Option<Genesis>,
mode: NodeMode,
clique_private_key: Option<SigningKey>,
args: Vec<OsString>,
}
impl Geth {
pub fn new() -> Self {
Self::default()
}
pub fn at(path: impl Into<PathBuf>) -> Self {
Self::new().path(path)
}
pub fn path<T: Into<PathBuf>>(mut self, path: T) -> Self {
self.program = Some(path.into());
self
}
pub fn dev(mut self) -> Self {
self.mode = NodeMode::Dev(Default::default());
self
}
pub const fn is_clique(&self) -> bool {
self.clique_private_key.is_some()
}
pub fn clique_address(&self) -> Option<Address> {
self.clique_private_key.as_ref().map(|pk| Address::from_public_key(pk.verifying_key()))
}
#[deprecated = "clique support was removed in geth >=1.14"]
pub fn set_clique_private_key<T: Into<SigningKey>>(mut self, private_key: T) -> Self {
self.clique_private_key = Some(private_key.into());
self
}
pub fn port<T: Into<u16>>(mut self, port: T) -> Self {
self.port = Some(port.into());
self
}
pub fn p2p_port(mut self, port: u16) -> Self {
match &mut self.mode {
NodeMode::Dev(_) => {
self.mode = NodeMode::NonDev(PrivateNetOptions {
p2p_port: Some(port),
..Default::default()
})
}
NodeMode::NonDev(opts) => opts.p2p_port = Some(port),
}
self
}
pub const fn block_time(mut self, block_time: u64) -> Self {
self.mode = NodeMode::Dev(DevOptions { block_time: Some(block_time) });
self
}
pub const fn chain_id(mut self, chain_id: u64) -> Self {
self.chain_id = Some(chain_id);
self
}
pub const fn insecure_unlock(mut self) -> Self {
self.insecure_unlock = true;
self
}
pub const fn enable_ipc(mut self) -> Self {
self.ipc_enabled = true;
self
}
pub fn disable_discovery(mut self) -> Self {
self.inner_disable_discovery();
self
}
fn inner_disable_discovery(&mut self) {
match &mut self.mode {
NodeMode::Dev(_) => {
self.mode =
NodeMode::NonDev(PrivateNetOptions { discovery: false, ..Default::default() })
}
NodeMode::NonDev(opts) => opts.discovery = false,
}
}
pub fn ipc_path<T: Into<PathBuf>>(mut self, path: T) -> Self {
self.ipc_path = Some(path.into());
self
}
pub fn data_dir<T: Into<PathBuf>>(mut self, path: T) -> Self {
self.data_dir = Some(path.into());
self
}
pub fn genesis(mut self, genesis: Genesis) -> Self {
self.genesis = Some(genesis);
self
}
pub const fn authrpc_port(mut self, port: u16) -> Self {
self.authrpc_port = Some(port);
self
}
pub fn arg<T: Into<OsString>>(mut self, arg: T) -> Self {
self.args.push(arg.into());
self
}
pub fn args<I, S>(mut self, args: I) -> Self
where
I: IntoIterator<Item = S>,
S: Into<OsString>,
{
for arg in args {
self = self.arg(arg);
}
self
}
#[track_caller]
pub fn spawn(self) -> GethInstance {
self.try_spawn().unwrap()
}
pub fn try_spawn(mut self) -> Result<GethInstance, NodeError> {
let bin_path = self
.program
.as_ref()
.map_or_else(|| GETH.as_ref(), |bin| bin.as_os_str())
.to_os_string();
let mut cmd = Command::new(&bin_path);
cmd.stderr(Stdio::piped());
let mut port = self.port.unwrap_or(0);
let port_s = port.to_string();
if !self.ipc_enabled {
cmd.arg("--ipcdisable");
}
cmd.arg("--http");
cmd.arg("--http.port").arg(&port_s);
cmd.arg("--http.api").arg(API);
cmd.arg("--ws");
cmd.arg("--ws.port").arg(port_s);
cmd.arg("--ws.api").arg(API);
let is_clique = self.is_clique();
if self.insecure_unlock || is_clique {
cmd.arg("--allow-insecure-unlock");
}
if is_clique {
self.inner_disable_discovery();
}
let authrpc_port = self.authrpc_port.unwrap_or_else(&mut unused_port);
cmd.arg("--authrpc.port").arg(authrpc_port.to_string());
if is_clique {
let clique_addr = self.clique_address();
if let Some(genesis) = &mut self.genesis {
let clique_config = CliqueConfig { period: Some(0), epoch: Some(8) };
genesis.config.clique = Some(clique_config);
let clique_addr = clique_addr.ok_or_else(|| {
NodeError::CliqueAddressError(
"could not calculates the address of the Clique consensus address."
.to_string(),
)
})?;
let extra_data_bytes =
[&[0u8; 32][..], clique_addr.as_ref(), &[0u8; 65][..]].concat();
genesis.extra_data = extra_data_bytes.into();
cmd.arg("--miner.etherbase").arg(format!("{clique_addr:?}"));
}
let clique_addr = self.clique_address().ok_or_else(|| {
NodeError::CliqueAddressError(
"could not calculates the address of the Clique consensus address.".to_string(),
)
})?;
self.genesis = Some(Genesis::clique_genesis(
self.chain_id.ok_or(NodeError::ChainIdNotSet)?,
clique_addr,
));
cmd.arg("--miner.etherbase").arg(format!("{clique_addr:?}"));
}
if let Some(genesis) = &self.genesis {
let temp_genesis_dir_path = tempdir().map_err(NodeError::CreateDirError)?.into_path();
let temp_genesis_path = temp_genesis_dir_path.join("genesis.json");
let mut file = File::create(&temp_genesis_path).map_err(|_| {
NodeError::GenesisError("could not create genesis file".to_string())
})?;
serde_json::to_writer_pretty(&mut file, &genesis).map_err(|_| {
NodeError::GenesisError("could not write genesis to file".to_string())
})?;
let mut init_cmd = Command::new(bin_path);
if let Some(data_dir) = &self.data_dir {
init_cmd.arg("--datadir").arg(data_dir);
}
init_cmd.stderr(Stdio::null());
init_cmd.arg("init").arg(temp_genesis_path);
let res = init_cmd
.spawn()
.map_err(NodeError::SpawnError)?
.wait()
.map_err(NodeError::WaitError)?;
if !res.success() {
return Err(NodeError::InitError);
}
std::fs::remove_dir_all(temp_genesis_dir_path).map_err(|_| {
NodeError::GenesisError("could not remove genesis temp dir".to_string())
})?;
}
if let Some(data_dir) = &self.data_dir {
cmd.arg("--datadir").arg(data_dir);
if !data_dir.exists() {
create_dir(data_dir).map_err(NodeError::CreateDirError)?;
}
}
let mut p2p_port = match self.mode {
NodeMode::Dev(DevOptions { block_time }) => {
cmd.arg("--dev");
if let Some(block_time) = block_time {
cmd.arg("--dev.period").arg(block_time.to_string());
}
None
}
NodeMode::NonDev(PrivateNetOptions { p2p_port, discovery }) => {
let port = p2p_port.unwrap_or(0);
cmd.arg("--port").arg(port.to_string());
if !discovery {
cmd.arg("--nodiscover");
}
Some(port)
}
};
if let Some(chain_id) = self.chain_id {
cmd.arg("--networkid").arg(chain_id.to_string());
}
cmd.arg("--verbosity").arg("4");
if let Some(ipc) = &self.ipc_path {
cmd.arg("--ipcpath").arg(ipc);
}
cmd.args(self.args);
let mut child = cmd.spawn().map_err(NodeError::SpawnError)?;
let stderr = child.stderr.take().ok_or(NodeError::NoStderr)?;
let start = Instant::now();
let mut reader = BufReader::new(stderr);
let mut p2p_started = matches!(self.mode, NodeMode::Dev(_));
let mut ports_started = false;
loop {
if start + NODE_STARTUP_TIMEOUT <= Instant::now() {
let _ = child.kill();
return Err(NodeError::Timeout);
}
let mut line = String::with_capacity(120);
reader.read_line(&mut line).map_err(NodeError::ReadLineError)?;
if matches!(self.mode, NodeMode::NonDev(_)) && line.contains("Started P2P networking") {
p2p_started = true;
}
if !matches!(self.mode, NodeMode::Dev(_)) {
if line.contains("New local node record") {
if let Some(port) = extract_value("tcp=", &line) {
p2p_port = port.parse::<u16>().ok();
}
}
}
if line.contains("HTTP endpoint opened")
|| (line.contains("HTTP server started") && !line.contains("auth=true"))
{
if let Some(addr) = extract_endpoint("endpoint=", &line) {
port = addr.port();
}
ports_started = true;
}
if line.contains("Fatal:") {
let _ = child.kill();
return Err(NodeError::Fatal(line));
}
if ports_started && p2p_started {
break;
}
}
child.stderr = Some(reader.into_inner());
Ok(GethInstance {
pid: child,
port,
ipc: self.ipc_path,
data_dir: self.data_dir,
p2p_port,
auth_port: self.authrpc_port,
genesis: self.genesis,
clique_private_key: self.clique_private_key,
})
}
}