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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151

//! Clap configuration related to TxPool service.

use fuel_core_types::{
    fuel_tx::{
        Address,
        ContractId,
        UtxoId,
    },
    fuel_types::Nonce,
};

#[derive(Debug, Clone, clap::Args)]
pub struct TxPoolArgs {
    /// The max time to live of the transaction inside of the `TxPool`.
    #[clap(long = "tx-pool-ttl", default_value = "5m", env)]
    pub tx_pool_ttl: humantime::Duration,

    /// The interval for checking the time to live of transactions.
    #[clap(long = "tx-ttl-check-interval", default_value = "1m", env)]
    pub tx_ttl_check_interval: humantime::Duration,

    /// The max number of transactions that the `TxPool` can simultaneously store.
    #[clap(long = "tx-max-number", default_value = "4064", env)]
    pub tx_max_number: usize,

    /// The max number of gas the `TxPool` can simultaneously store.
    #[clap(long = "tx-max-total-gas", default_value = "30000000000", env)]
    pub tx_max_total_gas: u64,

    /// The max number of bytes that the `TxPool` can simultaneously store.
    #[clap(long = "tx-max-total-bytes", default_value = "131072000", env)]
    pub tx_max_total_bytes: usize,

    /// The flag name is `tx-max-depth` for backward compatibility but the behavior is:
    /// The max number of tx in a chain of dependent transactions that supported by the `TxPool`.
    #[clap(long = "tx-max-depth", default_value = "32", env)]
    pub tx_max_chain_count: usize,

    /// The list of banned addresses ignored by the `TxPool`.
    #[clap(long = "tx-blacklist-addresses", value_delimiter = ',', env)]
    pub tx_blacklist_addresses: Vec<Address>,

    /// The list of banned coins ignored by the `TxPool`.
    #[clap(long = "tx-blacklist-coins", value_delimiter = ',', env)]
    pub tx_blacklist_coins: Vec<UtxoId>,

    /// The list of banned messages ignored by the `TxPool`.
    #[clap(long = "tx-blacklist-messages", value_delimiter = ',', env)]
    pub tx_blacklist_messages: Vec<Nonce>,

    /// The list of banned contracts ignored by the `TxPool`.
    #[clap(long = "tx-blacklist-contracts", value_delimiter = ',', env)]
    pub tx_blacklist_contracts: Vec<ContractId>,

    /// Number of threads for managing verifications/insertions.
    #[clap(
        long = "tx-number-threads-to-verify-transactions",
        default_value = "4",
        env
    )]
    pub tx_number_threads_to_verify_transactions: usize,

    /// Maximum number of tasks in the verifications/insertions queue.
    #[clap(long = "tx-size-of-verification-queue", default_value = "2000", env)]
    pub tx_size_of_verification_queue: usize,

    /// Number of threads for managing the p2p synchronisation.
    #[clap(long = "tx-number-threads-p2p-sync", default_value = "2", env)]
    pub tx_number_threads_p2p_sync: usize,

    /// Maximum number of tasks in the p2p synchronisation queue.
    #[clap(long = "tx-size-of-p2p-sync-queue", default_value = "20", env)]
    pub tx_size_of_p2p_sync_queue: usize,

    /// Maximum number of pending write requests in the service.
    #[clap(long = "tx-max-pending-write-requests", default_value = "10000", env)]
    pub tx_max_pending_write_requests: usize,

    /// Maximum number of pending read requests in the service.
    #[clap(long = "tx-max-pending-read-requests", default_value = "10000", env)]
    pub tx_max_pending_read_requests: usize,

    /// The max time to live of the transaction inside of the `PendingPool`.
    /// The `PendingPool` is a pool of transactions that are waiting for the `TxPool` to accept them
    /// because one of their inputs is not yet available.
    #[clap(long = "tx-pending-pool-ttl", default_value = "3s", env)]
    pub tx_pending_pool_ttl: humantime::Duration,

    /// The max percentage of the `TxPool` that can be used by the `PendingPool`.
    #[clap(long = "tx-pending-pool-size-percentage", default_value = "50", env)]
    pub tx_pending_pool_size_percentage: u16,
}

#[cfg(test)]
mod tests {
    use super::*;
    use clap::Parser;
    use fuel_core::txpool::config::BlackList;
    use test_case::test_case;

    #[derive(Debug, Clone, Parser)]
    pub struct Command {
        #[clap(flatten)]
        tx_pool: TxPoolArgs,
    }

    fn blacklist(
        a: Vec<Address>,
        c: Vec<UtxoId>,
        m: Vec<Nonce>,
        ct: Vec<ContractId>,
    ) -> BlackList {
        BlackList::new(a, c, m, ct)
    }

    #[test_case(&[""] => Ok(blacklist(vec![], vec![], vec![], vec![])); "defaults works")]
    #[test_case(&["", "--tx-blacklist-addresses=\
            0x0000000000000000000000000000000000000000000000000000000000000000,\
            0101010101010101010101010101010101010101010101010101010101010101"
        ]
        => Ok(blacklist(vec![[0; 32].into(), [1; 32].into()], vec![], vec![], vec![])); "addresses works")]
    #[test_case(&["", "--tx-blacklist-coins=\
            0x00000000000000000000000000000000000000000000000000000000000000000002,\
            01010101010101010101010101010101010101010101010101010101010101010003"
    ]
    => Ok(blacklist(vec![], vec![UtxoId::new([0; 32].into(), 2), UtxoId::new([1; 32].into(), 3)], vec![], vec![])); "coins works")]
    #[test_case(&["", "--tx-blacklist-messages=\
            0x0000000000000000000000000000000000000000000000000000000000000000,\
            0101010101010101010101010101010101010101010101010101010101010101"
    ]
    => Ok(blacklist(vec![], vec![], vec![[0; 32].into(), [1; 32].into()], vec![])); "messages works")]
    #[test_case(&["", "--tx-blacklist-contracts=\
            0x0000000000000000000000000000000000000000000000000000000000000000,\
            0101010101010101010101010101010101010101010101010101010101010101"
    ]
    => Ok(blacklist(vec![], vec![], vec![], vec![[0; 32].into(), [1; 32].into()])); "contracts works")]
    fn parse(args: &[&str]) -> Result<BlackList, String> {
        let command: Command =
            Command::try_parse_from(args).map_err(|e| e.to_string())?;
        let args = command.tx_pool;

        let blacklist = blacklist(
            args.tx_blacklist_addresses,
            args.tx_blacklist_coins,
            args.tx_blacklist_messages,
            args.tx_blacklist_contracts,
        );

        Ok(blacklist)
    }
}