fuel-core 0.15.3

Fuel client.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use clap::Args;
use core::time::Duration;
use fuel_core_interfaces::model::DaBlockHeight;
use fuel_relayer::{
    Config,
    H160,
};
use std::str::FromStr;

#[derive(Debug, Clone, Args)]
pub struct RelayerArgs {
    /// Uri address to ethereum client. It can be in format of `http://localhost:8545/` or `ws://localhost:8545/`.
    /// If not set relayer will not start.
    #[clap(long = "relayer")]
    pub eth_client: Option<url::Url>,

    /// Ethereum contract address. Create EthAddress into fuel_types
    #[clap(long = "relayer-v2-listening-contracts", parse(try_from_str = parse_h160))]
    pub eth_v2_listening_contracts: Vec<H160>,

    /// Number of da block after which messages/stakes/validators become finalized.
    #[clap(long = "relayer-da-finalization", default_value_t = Config::DEFAULT_DA_FINALIZATION)]
    pub da_finalization: u64,

    /// Number of da block that the contract is deployed at.
    #[clap(long = "relayer-da-deploy-height", default_value_t = Config::DEFAULT_DA_DEPLOY_HEIGHT)]
    pub da_deploy_height: u64,

    /// Number of pages or blocks containing logs that
    /// should be downloaded in a single call to the da layer
    #[clap(long = "relayer-log-page-size", default_value_t = Config::DEFAULT_LOG_PAGE_SIZE)]
    pub log_page_size: u64,

    /// The minimum number of seconds that the relayer polling loop
    /// will take before running again. If this is too low the DA layer
    /// risks being spammed.
    #[clap(long = "relayer-min-duration-s", default_value_t = Config::DEFAULT_SYNC_MINIMUM_DURATION.as_secs())]
    pub sync_minimum_duration_secs: u64,

    #[clap(long = "relayer-eth-sync-call-freq-s", default_value_t = Config::DEFAULT_SYNCING_CALL_FREQ.as_secs())]
    pub syncing_call_frequency_secs: u64,

    #[clap(long = "relayer-eth-sync-log-freq-s", default_value_t = Config::DEFAULT_SYNCING_LOG_FREQ.as_secs())]
    pub syncing_log_frequency_secs: u64,
}

pub fn parse_h160(input: &str) -> Result<H160, <H160 as FromStr>::Err> {
    H160::from_str(input)
}

impl From<RelayerArgs> for Config {
    fn from(args: RelayerArgs) -> Self {
        Config {
            da_deploy_height: DaBlockHeight(args.da_deploy_height),
            da_finalization: DaBlockHeight(args.da_finalization),
            eth_client: args.eth_client,
            eth_v2_listening_contracts: args.eth_v2_listening_contracts,
            log_page_size: args.log_page_size,
            sync_minimum_duration: Duration::from_secs(args.sync_minimum_duration_secs),
            syncing_call_frequency: Duration::from_secs(args.syncing_call_frequency_secs),
            syncing_log_frequency: Duration::from_secs(args.syncing_log_frequency_secs),
            metrics: false,
        }
    }
}