tonlib-client 0.23.1

Thin wrapper for tonlibjson
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

use std::sync::atomic::AtomicI32;
use std::sync::Arc;
use std::time::Duration;

use super::{BlockchainLibraryProvider, LibraryProvider};
use crate::client::TonClient;
use crate::contract::{TonContractError, TonContractFactory};

pub struct TonContractFactoryBuilder {
    client: TonClient,
    with_cache: bool,
    account_state_cache_capacity: u64,
    account_state_cache_time_to_live: Duration,
    txid_cache_capacity: u64,
    txid_cache_time_to_live: Duration,
    presync_blocks: i32,
    library_provider: Arc<dyn LibraryProvider>,
    current_seqno: Arc<AtomicI32>,
}

impl TonContractFactoryBuilder {
    const DEFAULT_ACCOUNT_STATE_CACHE_CAPACITY: u64 = 100_000;
    const DEFAULT_ACCOUNT_STATE_CACHE_TTL: Duration = Duration::from_secs(60 * 60);

    const DEFAULT_TXID_CACHE_CAPACITY: u64 = 100_000;
    const DEFAULT_TXID_STATE_CACHE_TTL: Duration = Duration::from_secs(30 * 60);

    const DEFAULT_PRESYNC_BLOCKS: i32 = 50;

    pub(crate) fn new(client: &TonClient) -> Self {
        let current_seqno_counter: Arc<AtomicI32> = Arc::new(0.into());

        let library_provider = Arc::new(BlockchainLibraryProvider::new(client, None));
        TonContractFactoryBuilder {
            client: client.clone(),
            with_cache: false,
            account_state_cache_capacity: 0,
            account_state_cache_time_to_live: Duration::default(),
            txid_cache_capacity: 0,
            txid_cache_time_to_live: Duration::default(),
            presync_blocks: Self::DEFAULT_PRESYNC_BLOCKS,
            library_provider,
            current_seqno: current_seqno_counter,
        }
    }

    pub fn with_cache(
        &mut self,
        txid_cache_capacity: u64,
        txid_cache_time_to_live: Duration,
        account_state_cache_capacity: u64,
        account_state_cache_time_to_live: Duration,
    ) -> &mut Self {
        self.with_cache = true;
        self.txid_cache_capacity = txid_cache_capacity;
        self.txid_cache_time_to_live = txid_cache_time_to_live;
        self.account_state_cache_capacity = account_state_cache_capacity;
        self.account_state_cache_time_to_live = account_state_cache_time_to_live;
        self
    }

    pub fn with_default_cache(&mut self) -> &mut Self {
        self.with_cache = true;
        self.account_state_cache_capacity = Self::DEFAULT_ACCOUNT_STATE_CACHE_CAPACITY;
        self.account_state_cache_time_to_live = Self::DEFAULT_ACCOUNT_STATE_CACHE_TTL;
        self.txid_cache_capacity = Self::DEFAULT_TXID_CACHE_CAPACITY;
        self.txid_cache_time_to_live = Self::DEFAULT_TXID_STATE_CACHE_TTL;
        self
    }

    pub fn with_presync_blocks(&mut self, presync_blocks: i32) -> &mut Self {
        self.presync_blocks = presync_blocks;
        self
    }

    pub async fn build(&self) -> Result<TonContractFactory, TonContractError> {
        TonContractFactory::new(
            &self.client,
            self.with_cache,
            self.account_state_cache_capacity,
            self.account_state_cache_time_to_live,
            self.txid_cache_capacity,
            self.txid_cache_time_to_live,
            self.presync_blocks,
            self.library_provider.clone(),
            self.current_seqno.clone(),
        )
        .await
    }

    pub fn with_library_provider(
        &mut self,
        library_provider: Arc<dyn LibraryProvider>,
    ) -> &mut Self {
        self.library_provider = library_provider.clone();
        self
    }
}