use serde::{Deserialize, Serialize};
use std::str::FromStr;
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum registration_stateState {
Draft,
Open,
Done,
Cancel,
}
impl Default for registration_stateState {
fn default() -> Self {
Self::Open
}
}
impl std::fmt::Display for registration_stateState {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self {
Self::Draft => write!(f, "draft"),
Self::Open => write!(f, "open"),
Self::Done => write!(f, "done"),
Self::Cancel => write!(f, "cancel"),
}
}
}
impl FromStr for registration_stateState {
type Err = StateMachineError;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.to_lowercase().as_str() {
"draft" => Ok(Self::Draft),
"open" => Ok(Self::Open),
"done" => Ok(Self::Done),
"cancel" => Ok(Self::Cancel),
_ => Err(StateMachineError::InvalidState(s.to_string())),
}
}
}
impl registration_stateState {
pub fn is_initial(&self) -> bool {
matches!(self, Self::Open)
}
pub fn is_final(&self) -> bool {
matches!(self, Self::Done)
}
pub fn all() -> Vec<Self> {
vec![
Self::Draft,
Self::Open,
Self::Done,
Self::Cancel,
]
}
}
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum registration_stateTransition {
SetDraft,
Confirm,
SetDone,
Cancel,
}
impl std::fmt::Display for registration_stateTransition {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self {
Self::SetDraft => write!(f, "set_draft"),
Self::Confirm => write!(f, "confirm"),
Self::SetDone => write!(f, "set_done"),
Self::Cancel => write!(f, "cancel"),
}
}
}
impl FromStr for registration_stateTransition {
type Err = StateMachineError;
fn from_str(s: &str) -> Result<Self, Self::Err> {
match s.to_lowercase().as_str() {
"set_draft" => Ok(Self::SetDraft),
"confirm" => Ok(Self::Confirm),
"set_done" => Ok(Self::SetDone),
"cancel" => Ok(Self::Cancel),
_ => Err(StateMachineError::InvalidTransition(s.to_string())),
}
}
}
impl registration_stateTransition {
pub fn target_state(&self) -> registration_stateState {
match self {
Self::SetDraft => registration_stateState::Draft,
Self::Confirm => registration_stateState::Open,
Self::SetDone => registration_stateState::Done,
Self::Cancel => registration_stateState::Cancel,
}
}
pub fn all() -> Vec<Self> {
vec![
Self::SetDraft,
Self::Confirm,
Self::SetDone,
Self::Cancel,
]
}
pub fn allowed_roles(&self) -> &'static [&'static str] {
match self {
Self::SetDraft => &[],
Self::Confirm => &[],
Self::SetDone => &[],
Self::Cancel => &[],
}
}
}
use super::StateMachineError;
#[derive(Debug, Clone)]
pub struct registration_stateStateMachine {
current_state: registration_stateState,
}
impl registration_stateStateMachine {
pub fn new() -> Self {
Self {
current_state: registration_stateState::default(),
}
}
pub fn from_state(state: registration_stateState) -> Self {
Self { current_state: state }
}
pub fn current_state(&self) -> registration_stateState {
self.current_state
}
pub fn can_transition(&self, transition: registration_stateTransition) -> bool {
if matches!(self.current_state, registration_stateState::Done) {
return false;
}
match (self.current_state, transition) {
(_, registration_stateTransition::SetDraft) => true,
(_, registration_stateTransition::Confirm) => true,
(_, registration_stateTransition::SetDone) => true,
(_, registration_stateTransition::Cancel) => true,
_ => false,
}
}
pub fn can_transition_with_role(&self, transition: registration_stateTransition, role: &str) -> bool {
if !self.can_transition(transition) {
return false;
}
let allowed_roles = transition.allowed_roles();
if allowed_roles.is_empty() {
return true; }
allowed_roles.iter().any(|r| *r == role || *r == "*")
}
pub fn transition(&mut self, transition: registration_stateTransition) -> Result<registration_stateState, StateMachineError> {
if !self.can_transition(transition) {
return Err(StateMachineError::TransitionNotAllowed {
transition: transition.to_string(),
from: self.current_state.to_string(),
});
}
self.current_state = transition.target_state();
Ok(self.current_state)
}
pub fn transition_with_role(&mut self, transition: registration_stateTransition, role: &str) -> Result<registration_stateState, StateMachineError> {
if !self.can_transition(transition) {
return Err(StateMachineError::TransitionNotAllowed {
transition: transition.to_string(),
from: self.current_state.to_string(),
});
}
if !self.can_transition_with_role(transition, role) {
return Err(StateMachineError::RoleNotAuthorized {
role: role.to_string(),
transition: transition.to_string(),
});
}
self.current_state = transition.target_state();
Ok(self.current_state)
}
pub fn available_transitions(&self) -> Vec<registration_stateTransition> {
registration_stateTransition::all()
.into_iter()
.filter(|t| self.can_transition(*t))
.collect()
}
pub fn available_transitions_for_role(&self, role: &str) -> Vec<registration_stateTransition> {
registration_stateTransition::all()
.into_iter()
.filter(|t| self.can_transition_with_role(*t, role))
.collect()
}
pub fn transition_to_state(&mut self, target: registration_stateState) -> Result<registration_stateState, StateMachineError> {
let valid = registration_stateTransition::all().into_iter()
.filter(|t| self.can_transition(*t))
.find(|t| t.target_state() == target);
match valid {
Some(t) => self.transition(t),
None => Err(StateMachineError::TransitionNotAllowed {
transition: target.to_string(),
from: self.current_state.to_string(),
}),
}
}
}
impl Default for registration_stateStateMachine {
fn default() -> Self {
Self::new()
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_initial_state() {
let sm = registration_stateStateMachine::new();
assert_eq!(sm.current_state(), registration_stateState::Open);
assert!(sm.current_state().is_initial());
}
#[test]
fn test_valid_transition() {
let mut sm = registration_stateStateMachine::new();
assert!(sm.can_transition(registration_stateTransition::SetDraft));
let result = sm.transition(registration_stateTransition::SetDraft);
assert!(result.is_ok());
assert_eq!(sm.current_state(), registration_stateState::Draft);
}
#[test]
fn test_invalid_transition() {
assert!(true);
}
#[test]
fn test_state_parsing() {
let state: registration_stateState = "draft".parse().unwrap();
assert_eq!(state, registration_stateState::Draft);
}
#[test]
fn test_available_transitions() {
let sm = registration_stateStateMachine::new();
let available = sm.available_transitions();
assert!(!available.is_empty() || sm.current_state().is_final());
}
}