use std::{ collections::HashSet, hash::{DefaultHasher, Hash, Hasher}, }; pub trait Stage: Clone + std::fmt::Debug + std::hash::Hash + Eq { type Consume: Clone + std::fmt::Debug + std::hash::Hash + Eq; } #[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash, Debug)] pub struct Epsilon; impl Stage for Epsilon { type Consume = Option; } #[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Hash, Debug)] pub struct Resolved; impl Stage for Resolved { type Consume = ByteRange; } use crate::parse::regex::{LookDirection, LookPolarity}; use super::Pattern; use super::byte_range::ByteRange; /// NFA with epsilon transitions #[derive(Clone)] #[allow(clippy::upper_case_acronyms)] pub struct ENFA { pub states: Vec>, } #[derive(Clone)] pub struct MultiState<'a> { nfa: &'a ENFA, states: Vec, accept: bool, hash: u64, } impl<'a> PartialEq for MultiState<'a> { fn eq(&self, other: &Self) -> bool { (self.nfa as *const ENFA as u64) == (other.nfa as *const ENFA as u64) && self.states == other.states && self.accept == other.accept && self.hash == other.hash } } impl<'a> Eq for MultiState<'a> {} impl<'a> MultiState<'a> { pub fn new(nfa: &'a ENFA, mut states: Vec) -> Self { states.sort(); states.dedup(); states.shrink_to_fit(); let accept = states .iter() .any(|&x| nfa.states[x].accept == Acceptance::Accept); let mut hasher = DefaultHasher::new(); states.hash(&mut hasher); let hash = hasher.finish(); Self { nfa, states, accept, hash, } } /// all the chars that will make an interesting transition pub fn possible_transitions(&self) -> Vec { let mut vec: Vec<_> = self .states .iter() .flat_map(|&i| self.nfa.states[i].trans.iter().map(|x| x.consumes)) .collect(); vec = ByteRange::non_overlapping(vec); vec.sort(); vec.dedup(); vec.shrink_to_fit(); vec } pub fn transition(&self, ch: ByteRange) -> Self { let new_states = self .states .iter() .flat_map(|&s| { self.nfa.states[s].trans.iter().filter_map(|t| { if t.consumes.overlaps(ch) { Some(t.to) } else { None } }) }) .collect(); Self::new(self.nfa, new_states) } pub fn accept(&self) -> bool { self.accept } } impl<'a> Hash for MultiState<'a> { fn hash(&self, state: &mut H) { self.hash.hash(state) } } macro_rules! set { () => { std::collections::HashSet::new() }; ( $( $x:expr ),* ) => {{ let mut set = std::collections::HashSet::new(); $( set.insert($x); )* set }}; } impl ENFA { fn shift(self, amt: usize) -> Vec> { let mut s = self.states; for state in s.iter_mut() { state.remap(|i| i + amt); if state.accept == Acceptance::Accept { state.accept = Acceptance::NotYet; } } s } pub fn remove_unreachable(&mut self) { let mut used = vec![false; self.states.len()]; used[0] = true; for s in self.states.iter() { for i in s.reachable_states() { used[i] = true; } } let mut remap = vec![0; self.states.len()]; let mut shift = 0; for i in 0..self.states.len() { if used[i] { remap[i] = i - shift; } else { shift += 1; } } for i in (0..self.states.len()).rev() { if !used[i] { self.states.remove(i); } } for s in self.states.iter_mut() { s.remap(|i| remap[i]); } } } impl ENFA { fn epsilon_dfs(&self, i: StateId, visited: &mut [Option>], path: Vec) { if visited[i].is_some() { return; } visited[i] = Some(path.clone()); for t in self.states[i].trans.iter() { if t.is_epsilon() { let mut path = path.clone(); path.append(&mut t.assert.clone()); self.epsilon_dfs(t.to, visited, path); } } } pub fn resolve_epsilon(self) -> ENFA { // state X --> { state Y, Z, W which get inlined into X } let includes: Vec)>> = (0..self.states.len()) .map(|i| { let mut reach = vec![None; self.states.len()]; self.epsilon_dfs(i, &mut reach, Vec::new()); reach .into_iter() .enumerate() .filter_map(|(x, r)| r.map(|r| (x, r))) .collect() }) .collect(); // states without epsilon transitions let mut states: Vec> = self .states .into_iter() .map(EState::remove_epsilon) .collect(); // inline real transitions for i in 0..states.len() { for (k, assertions) in includes[i].iter() { let new: Vec> = states[*k] .trans .iter() .cloned() .map(|t| t.with_assertions(assertions.clone())) .collect(); states[i].trans.extend(new); if states[*k].accept != Acceptance::NotYet { states[i].accept = states[*k].accept; } } } ENFA { states } } fn looping(self) -> Self { let mut states = vec![EState::start()]; states.append(&mut self.shift(1)); let len = states.len(); states[0].set_epsilon_transitions([Transition::epsilon(1), Transition::epsilon(len)]); states[len - 1].set_epsilon_transitions([Transition::epsilon(0), Transition::epsilon(len)]); states.push(EState::terminal()); Self { states } } fn repeat(self, times: usize) -> Self { let reps = vec![self; times]; Self::concat(reps) } /// between 0 and x repetitions fn optx(self, x: usize) -> Self { let len = self.states.len(); let mut repped = self.repeat(x); assert_eq!(repped.states.len(), x * len); for i in 1..=x { repped.states[0] .trans .insert(Transition::epsilon(i * len - 1)); } repped } fn concat(nfas: Vec) -> Self { if nfas.is_empty() { return Self { states: vec![EState::terminal()], }; } let mut states: Vec> = Vec::new(); for nfa in nfas.into_iter() { let len = states.len(); let mut ns = nfa.shift(len); if let Some(n) = states.last_mut() { n.trans.retain(|t| t.consumes.is_some()); n.trans.insert(Transition::epsilon(len)); } states.append(&mut ns); } let len = states.len(); states[len - 1].accept = Acceptance::Accept; Self { states } } } impl ENFA { pub fn start_multi_state<'a>(&'a self) -> MultiState<'a> { MultiState::new(self, vec![0]) } pub fn void_multi_state<'a>(&'a self) -> MultiState<'a> { MultiState::new(self, vec![]) } pub fn all_multi_states<'a>(&'a self) -> HashSet> { let mut states = set![self.start_multi_state()]; let mut q = vec![self.start_multi_state()]; while let Some(state) = q.pop() { let chars = state.possible_transitions(); for chr in chars { let new = state.transition(chr); if !states.contains(&new) { states.insert(new.clone()); q.push(new); } } } states } } impl std::fmt::Debug for ENFA { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { writeln!(f, "NFA {{")?; for (i, s) in self.states.iter().enumerate() { write!(f, " {i}: ")?; for t in s.trans.iter() { let k = t.to; if let Some(c) = t.consumes { write!(f, "{c:?}=>{k} ")?; } else { write!(f, "~>{k} ")?; } } match s.accept { Acceptance::Accept => write!(f, "accept")?, Acceptance::Assertion => write!(f, "assert")?, Acceptance::NotYet => {} } writeln!(f)?; } write!(f, "}}") } } pub type StateId = usize; #[derive(Debug, Clone, Hash, PartialEq, Eq)] pub struct Assertion { to: StateId, polarity: LookPolarity, } #[derive(Debug, Clone, Hash, PartialEq, Eq)] pub struct Transition { to: StateId, assert: Vec, consumes: S::Consume, } impl Transition { fn new(consumes: ByteRange, to: StateId) -> Self { Self { to, consumes: Some(consumes), assert: Vec::new(), } } fn epsilon(to: StateId) -> Self { Self { to, consumes: None, assert: Vec::new(), } } pub fn is_epsilon(&self) -> bool { self.consumes.is_none() } fn non_epsilon(self) -> Option> { let Self { to, assert, consumes, } = self; let consumes = consumes?; Some(Transition { consumes, to, assert, }) } } impl Transition { fn remap(&mut self, mut f: impl FnMut(StateId) -> StateId) { self.to = f(self.to); } fn reachable_states(&self) -> impl Iterator { [self.to].into_iter() } fn with_assertions(mut self, mut more: Vec) -> Self { self.assert.append(&mut more); self } } #[derive(Debug, Copy, Clone, PartialEq)] pub enum Acceptance { Accept, Assertion, NotYet, } #[derive(Debug, Clone)] pub struct EState { pub trans: HashSet>, pub accept: Acceptance, } impl EState { fn remove_epsilon(self) -> EState { let trans = self .trans .into_iter() .filter_map(Transition::non_epsilon) .collect(); let accept = self.accept; EState { trans, accept } } fn set_epsilon_transitions(&mut self, trans: impl IntoIterator>) { self.trans.retain(|t| t.consumes.is_some()); for transition in trans.into_iter() { assert!(transition.consumes.is_none()); self.trans.insert(transition); } } } impl EState { fn start() -> Self { Self { trans: HashSet::new(), accept: Acceptance::NotYet, } } fn terminal() -> Self { Self { trans: HashSet::new(), accept: Acceptance::Accept, } } fn remap(&mut self, mut f: impl FnMut(StateId) -> StateId) { self.trans = self .trans .iter() .cloned() .map(|mut t| { t.remap(&mut f); t }) .collect(); } fn reachable_states(&self) -> impl Iterator { self.trans.iter().flat_map(|t| t.reachable_states()) } } #[derive(Debug)] pub enum EnfaTranslationError { AssertionsNotSupported, } impl TryFrom for ENFA { type Error = EnfaTranslationError; fn try_from(value: Pattern) -> Result { Ok(match value { Pattern::Byte(c) => Self::try_from(Pattern::Range(c, c))?, Pattern::Range(c1, c2) => Self { states: vec![ EState { trans: set![Transition::new(ByteRange::new_range(c1, c2), 1)], accept: Acceptance::NotYet, }, EState::terminal(), ], }, Pattern::Alt(alts) => { let nfas: Vec> = alts .into_iter() .map(Self::try_from) .collect::>()?; let mut states = vec![EState::start()]; let mut ends = vec![]; for nfa in nfas.into_iter() { let len = states.len(); states[0].trans.insert(Transition::epsilon(len)); states.append(&mut (nfa.shift(len))); ends.push(states.len() - 1); } states.push(EState::terminal()); for end in ends.into_iter() { let last = states.len() - 1; states[end].trans.insert(Transition::epsilon(last)); } Self { states } } Pattern::Concat(seq) => { let nfas: Vec = seq .into_iter() .map(Self::try_from) .collect::>()?; Self::concat(nfas) } Pattern::Rep(regex, min, None) => { let nfa = ENFA::try_from(*regex)?; let base = nfa.clone().repeat(min as usize); let tail = nfa.looping(); Self::concat(vec![base, tail]) } Pattern::Rep(regex, min, Some(max)) => { assert!(min < max); let nfa = Self::try_from(*regex)?; let base = nfa.clone().repeat(min as usize); let tail = nfa.optx((max - min) as usize); Self::concat(vec![base, tail]) } Pattern::Nothing => Self { states: vec![EState::terminal()], }, Pattern::Assertion(dir, polarity, pat) => { if dir == LookDirection::Behind { return Err(EnfaTranslationError::AssertionsNotSupported); } let mut regex = Self::try_from(*pat)?; for s in regex.states.iter_mut() { if s.accept == Acceptance::Accept { s.accept = Acceptance::Assertion; } } let mut regex = regex.shift(1); let mut states = Vec::with_capacity(regex.len() + 2); states.push(EState { trans: set![Transition { to: regex.len() + 1, assert: vec![Assertion { to: 1, polarity }], consumes: None }], accept: Acceptance::NotYet, }); states.append(&mut regex); states.push(EState::terminal()); Self { states } } }) } }