ethrex_l2_common/
sequencer_state.rs

1use std::sync::{Arc, Mutex};
2
3use serde::{Deserialize, Serialize};
4
5#[derive(Debug, Clone)]
6pub struct SequencerState(Arc<Mutex<SequencerStatus>>);
7
8impl SequencerState {
9    pub fn status(&self) -> SequencerStatus {
10        *self.0.lock().unwrap_or_else(|e| e.into_inner())
11    }
12
13    pub fn new_status(&self, status: SequencerStatus) {
14        *self.0.lock().unwrap_or_else(|e| e.into_inner()) = status;
15    }
16}
17
18impl From<SequencerStatus> for SequencerState {
19    fn from(status: SequencerStatus) -> Self {
20        Self(Arc::new(Mutex::new(status)))
21    }
22}
23
24#[derive(Debug, Default, Clone, PartialEq, Eq, Serialize, Deserialize, Copy)]
25pub enum SequencerStatus {
26    Sequencing,
27    #[default]
28    Syncing,
29    Following,
30}
31
32impl std::fmt::Display for SequencerStatus {
33    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
34        match self {
35            SequencerStatus::Sequencing => write!(f, "Sequencing"),
36            SequencerStatus::Syncing => write!(f, "Syncing"),
37            SequencerStatus::Following => write!(f, "Following"),
38        }
39    }
40}
ethrex_l2_common/sequencer_state.rs

ethrex_l2_common/
sequencer_state.rs
