tycho_executor/tx/
ticktock.rs1use anyhow::Context;
2use tycho_types::models::{AccountStatus, ComputePhase, TickTock, TickTockTxInfo};
3
4use crate::error::{TxError, TxResult};
5use crate::phase::{
6 ActionPhaseContext, ComputePhaseContext, ComputePhaseFull, StoragePhaseContext,
7 TransactionInput,
8};
9use crate::{ExecutorInspector, ExecutorState};
10
11impl ExecutorState<'_> {
12 pub fn run_tick_tock_transaction(
13 &mut self,
14 kind: TickTock,
15 mut inspector: Option<&mut ExecutorInspector<'_>>,
16 ) -> TxResult<TickTockTxInfo> {
17 if self.state.status() != AccountStatus::Active {
18 return Err(TxError::Skipped);
20 }
21
22 let storage_phase = self
24 .storage_phase(StoragePhaseContext {
25 adjust_msg_balance: false,
26 received_message: None,
27 })
28 .context("storage phase failed")?;
29
30 let ComputePhaseFull {
32 compute_phase,
33 original_balance,
34 new_state,
35 actions,
36 ..
37 } = self
38 .compute_phase(ComputePhaseContext {
39 input: TransactionInput::TickTock(kind),
40 storage_fee: storage_phase.storage_fees_collected,
41 force_accept: false,
42 inspector: inspector.as_deref_mut(),
43 })
44 .context("compute phase failed")?;
45
46 let mut aborted = true;
48 let mut destroyed = false;
49 let mut action_phase = None;
50 if let ComputePhase::Executed(compute_phase) = &compute_phase {
51 if compute_phase.success {
52 let res = self
53 .action_phase(ActionPhaseContext {
54 received_message: None,
55 original_balance,
56 new_state,
57 actions,
58 compute_phase,
59 inspector,
60 })
61 .context("action phase failed")?;
62
63 aborted = !res.action_phase.success;
64 destroyed = self.end_status == AccountStatus::NotExists;
65 action_phase = Some(res.action_phase);
66 }
67 }
68
69 Ok(TickTockTxInfo {
71 kind,
72 storage_phase,
73 compute_phase,
74 action_phase,
75 aborted,
76 destroyed,
77 })
78 }
79}