fuel-core-bin 0.47.4

Fuel client binary.
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

use fuel_core_types::fuel_types::Bytes32;

#[derive(Debug, Clone, clap::Args)]
pub struct Args {
    /// If set to true, new blocks will be posted to the shared sequencer chain.
    #[clap(long = "enable-ss", action)]
    enable: bool,
    /// The frequency at which to post blocks to the shared sequencer.
    #[clap(long = "ss-block-posting-frequency", env, default_value = "12s")]
    block_posting_frequency: humantime::Duration,
    /// The RPC address of the sequencer chain
    /// (e.g. "http://127.0.0.1:26657")
    #[clap(long = "ss-tendermint-api", env)]
    tendermint_api: Option<String>,
    /// The REST address of the sequencer chain
    /// (e.g. "http://127.0.0.1:1317")
    #[clap(long = "ss-blockchain-api", env)]
    blockchain_api: Option<String>,
    /// Topic to post blocks to
    /// (e.g. "1111111111111111111111111111111111111111111111111111111111111111")
    #[clap(
        long = "ss-topic",
        env,
        default_value = "0000000000000000000000000000000000000000000000000000000000000000"
    )]
    topic: Bytes32,
}

#[cfg(feature = "shared-sequencer")]
impl TryFrom<Args> for fuel_core_shared_sequencer::Config {
    type Error = anyhow::Error;

    fn try_from(val: Args) -> anyhow::Result<fuel_core_shared_sequencer::Config> {
        let endpoints = match (val.tendermint_api, val.blockchain_api) {
            (Some(tendermint_api), Some(blockchain_api)) => {
                Some(fuel_core_shared_sequencer::Endpoints {
                    tendermint_rpc_api: tendermint_api,
                    blockchain_rest_api: blockchain_api,
                })
            }
            (None, None) => None,
            _ => {
                return Err(anyhow::anyhow!(
                    "Both tendermint and blockchain API must be set or unset"
                ))
            }
        };

        Ok(fuel_core_shared_sequencer::Config {
            enabled: val.enable,
            block_posting_frequency: val.block_posting_frequency.into(),
            endpoints,
            topic: *val.topic,
        })
    }
}