tycho-executor 0.3.7

TON-compatible transaction executor for the Tycho node.
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

use anyhow::Context;
use tycho_types::models::{AccountStatus, ComputePhase, TickTock, TickTockTxInfo};

use crate::error::{TxError, TxResult};
use crate::phase::{
    ActionPhaseContext, ComputePhaseContext, ComputePhaseFull, StoragePhaseContext,
    TransactionInput,
};
use crate::{ExecutorInspector, ExecutorState};

impl ExecutorState<'_> {
    pub fn run_tick_tock_transaction(
        &mut self,
        kind: TickTock,
        mut inspector: Option<&mut ExecutorInspector<'_>>,
    ) -> TxResult<TickTockTxInfo> {
        if self.state.status() != AccountStatus::Active {
            // Skip ticktock transactions for inactive accounts.
            return Err(TxError::Skipped);
        }

        // Run storage phase.
        let storage_phase = self
            .storage_phase(StoragePhaseContext {
                adjust_msg_balance: false,
                received_message: None,
                inspector: inspector.as_deref_mut(),
            })
            .context("storage phase failed")?;

        // Run compute phase.
        let ComputePhaseFull {
            compute_phase,
            original_balance,
            new_state,
            actions,
            ..
        } = self
            .compute_phase(ComputePhaseContext {
                input: TransactionInput::TickTock(kind),
                storage_fee: storage_phase.storage_fees_collected,
                force_accept: false,
                stop_on_accept: false,
                inspector: inspector.as_deref_mut(),
            })
            .context("compute phase failed")?;

        // Run action phase only if compute phase succeeded.
        let mut aborted = true;
        let mut destroyed = false;
        let mut action_phase = None;
        if let ComputePhase::Executed(compute_phase) = &compute_phase
            && compute_phase.success
        {
            let res = self
                .action_phase(ActionPhaseContext {
                    received_message: None,
                    original_balance,
                    new_state,
                    actions,
                    compute_phase,
                    inspector,
                })
                .context("action phase failed")?;

            aborted = !res.action_phase.success;
            destroyed = self.end_status == AccountStatus::NotExists;
            action_phase = Some(res.action_phase);
        }

        // Build transaction info.
        Ok(TickTockTxInfo {
            kind,
            storage_phase,
            compute_phase,
            action_phase,
            aborted,
            destroyed,
        })
    }
}