use alloc::format;
use alloc::rc::Rc;
use alloc::string::String;
use alloc::vec::Vec;
use core::fmt;
use core::hash::{Hash, Hasher};
use core::iter::Filter;
use core::ptr;
use core::str;
#[cfg(feature = "pretty-print")]
use serde::ser::SerializeStruct;
use super::flat_pairs::{self, FlatPairs};
use super::line_index::LineIndex;
use super::pair::{self, Pair};
use super::queueable_token::QueueableToken;
use super::tokens::{self, Tokens};
use crate::RuleType;
#[derive(Clone)]
pub struct Pairs<'i, R> {
queue: Rc<Vec<QueueableToken<'i, R>>>,
input: &'i str,
start: usize,
end: usize,
pairs_count: usize,
line_index: Rc<LineIndex>,
}
pub fn new<'i, R: RuleType>(
queue: Rc<Vec<QueueableToken<'i, R>>>,
input: &'i str,
line_index: Option<Rc<LineIndex>>,
start: usize,
end: usize,
) -> Pairs<'i, R> {
let line_index = match line_index {
Some(line_index) => line_index,
None => {
let last_input_pos = queue
.last()
.map(|token| match *token {
QueueableToken::Start { input_pos, .. }
| QueueableToken::End { input_pos, .. } => input_pos,
})
.unwrap_or(0);
Rc::new(LineIndex::new(&input[..last_input_pos]))
}
};
let mut pairs_count = 0;
let mut cursor = start;
while cursor < end {
cursor = match queue[cursor] {
QueueableToken::Start {
end_token_index, ..
} => end_token_index,
_ => unreachable!(),
} + 1;
pairs_count += 1;
}
Pairs {
queue,
input,
start,
end,
pairs_count,
line_index,
}
}
impl<'i, R: RuleType> Pairs<'i, R> {
#[inline]
pub fn as_str(&self) -> &'i str {
if self.start < self.end {
let start = self.pos(self.start);
let end = self.pos(self.end - 1);
&self.input[start..end]
} else {
""
}
}
pub fn get_input(&self) -> &'i str {
self.input
}
#[inline]
pub fn concat(&self) -> String {
self.clone()
.fold(String::new(), |string, pair| string + pair.as_str())
}
#[inline]
pub fn flatten(self) -> FlatPairs<'i, R> {
flat_pairs::new(
self.queue,
self.input,
self.line_index,
self.start,
self.end,
)
}
#[inline]
pub fn find_first_tagged(&self, tag: &'i str) -> Option<Pair<'i, R>> {
self.clone().find_tagged(tag).next()
}
#[inline]
pub fn find_tagged(
self,
tag: &'i str,
) -> Filter<FlatPairs<'i, R>, impl FnMut(&Pair<'i, R>) -> bool + 'i> {
self.flatten()
.filter(move |pair: &Pair<'i, R>| matches!(pair.as_node_tag(), Some(nt) if nt == tag))
}
#[inline]
pub fn tokens(self) -> Tokens<'i, R> {
tokens::new(self.queue, self.input, self.start, self.end)
}
#[inline]
pub fn peek(&self) -> Option<Pair<'i, R>> {
if self.start < self.end {
Some(pair::new(
Rc::clone(&self.queue),
self.input,
Rc::clone(&self.line_index),
self.start,
))
} else {
None
}
}
pub fn is_empty(&self) -> bool {
self.pairs_count == 0
}
#[cfg(feature = "pretty-print")]
pub fn to_json(&self) -> String {
::serde_json::to_string_pretty(self).expect("Failed to pretty-print Pairs to json.")
}
fn pair(&self) -> usize {
match self.queue[self.start] {
QueueableToken::Start {
end_token_index, ..
} => end_token_index,
_ => unreachable!(),
}
}
fn pair_from_end(&self) -> usize {
match self.queue[self.end - 1] {
QueueableToken::End {
start_token_index, ..
} => start_token_index,
_ => unreachable!(),
}
}
fn pos(&self, index: usize) -> usize {
match self.queue[index] {
QueueableToken::Start { input_pos, .. } | QueueableToken::End { input_pos, .. } => {
input_pos
}
}
}
}
impl<R: RuleType> ExactSizeIterator for Pairs<'_, R> {
#[inline]
fn len(&self) -> usize {
self.pairs_count
}
}
impl<'i, R: RuleType> Iterator for Pairs<'i, R> {
type Item = Pair<'i, R>;
fn next(&mut self) -> Option<Self::Item> {
let pair = self.peek()?;
self.start = self.pair() + 1;
self.pairs_count -= 1;
Some(pair)
}
fn size_hint(&self) -> (usize, Option<usize>) {
let len = <Self as ExactSizeIterator>::len(self);
(len, Some(len))
}
}
impl<R: RuleType> DoubleEndedIterator for Pairs<'_, R> {
fn next_back(&mut self) -> Option<Self::Item> {
if self.end <= self.start {
return None;
}
self.end = self.pair_from_end();
self.pairs_count -= 1;
let pair = pair::new(
Rc::clone(&self.queue),
self.input,
Rc::clone(&self.line_index),
self.end,
);
Some(pair)
}
}
impl<R: RuleType> fmt::Debug for Pairs<'_, R> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
f.debug_list().entries(self.clone()).finish()
}
}
impl<R: RuleType> fmt::Display for Pairs<'_, R> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let inner = self
.clone()
.map(|pair| {
if f.alternate() {
format!("{pair:#}")
} else {
format!("{pair}")
}
})
.collect::<Vec<_>>()
.join(", ");
write!(f, "[{inner}]")
}
}
impl<'i, R: PartialEq> PartialEq for Pairs<'i, R> {
fn eq(&self, other: &Pairs<'i, R>) -> bool {
Rc::ptr_eq(&self.queue, &other.queue)
&& ptr::eq(self.input, other.input)
&& self.start == other.start
&& self.end == other.end
}
}
impl<R: Eq> Eq for Pairs<'_, R> {}
impl<'i, R: Hash> Hash for Pairs<'i, R> {
fn hash<H: Hasher>(&self, state: &mut H) {
(&*self.queue as *const Vec<QueueableToken<'i, R>>).hash(state);
(self.input as *const str).hash(state);
self.start.hash(state);
self.end.hash(state);
}
}
#[cfg(feature = "pretty-print")]
impl<R: RuleType> ::serde::Serialize for Pairs<'_, R> {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: ::serde::Serializer,
{
let start = self.pos(self.start);
let end = self.pos(self.end - 1);
let pairs = self.clone().collect::<Vec<_>>();
let mut ser = serializer.serialize_struct("Pairs", 2)?;
ser.serialize_field("pos", &(start, end))?;
ser.serialize_field("pairs", &pairs)?;
ser.end()
}
}
#[cfg(test)]
mod tests {
use super::super::super::macros::tests::*;
use super::super::super::Parser;
use alloc::borrow::ToOwned;
use alloc::boxed::Box;
use alloc::format;
use alloc::vec;
use alloc::vec::Vec;
#[test]
#[cfg(feature = "pretty-print")]
fn test_pretty_print() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
let expected = r#"{
"pos": [
0,
5
],
"pairs": [
{
"pos": [
0,
3
],
"rule": "a",
"inner": {
"pos": [
1,
2
],
"pairs": [
{
"pos": [
1,
2
],
"rule": "b",
"inner": "b"
}
]
}
},
{
"pos": [
4,
5
],
"rule": "c",
"inner": "e"
}
]
}"#;
assert_eq!(expected, pairs.to_json());
}
#[test]
fn as_str() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
assert_eq!(pairs.as_str(), "abcde");
}
#[test]
fn get_input_of_pairs() {
let input = "abcde";
let pairs = AbcParser::parse(Rule::a, input).unwrap();
assert_eq!(pairs.get_input(), input);
}
#[test]
fn as_str_empty() {
let mut pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
assert_eq!(pairs.nth(1).unwrap().into_inner().as_str(), "");
}
#[test]
fn concat() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
assert_eq!(pairs.concat(), "abce");
}
#[test]
fn pairs_debug() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
#[rustfmt::skip]
assert_eq!(
format!("{:?}", pairs),
"[\
Pair { rule: a, span: Span { str: \"abc\", range: 0..3 }, inner: [\
Pair { rule: b, span: Span { str: \"b\", range: 1..2 }, inner: [] }\
] }, \
Pair { rule: c, span: Span { str: \"e\", range: 4..5 }, inner: [] }\
]"
.to_owned()
);
}
#[test]
fn pairs_display() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
assert_eq!(format!("{}", pairs), "[abc, e]".to_owned());
assert_eq!(
format!("{:#}", pairs),
"[a(0, 3, [b(1, 2)]), c(4, 5)]".to_owned()
);
}
#[test]
fn iter_for_pairs() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
assert_eq!(
pairs.map(|p| p.as_rule()).collect::<Vec<Rule>>(),
vec![Rule::a, Rule::c]
);
}
#[test]
fn double_ended_iter_for_pairs() {
let pairs = AbcParser::parse(Rule::a, "abcde").unwrap();
assert_eq!(
pairs.rev().map(|p| p.as_rule()).collect::<Vec<Rule>>(),
vec![Rule::c, Rule::a]
);
}
#[test]
fn test_line_col() {
let mut pairs = AbcParser::parse(Rule::a, "abc\nefgh").unwrap();
let pair = pairs.next().unwrap();
assert_eq!(pair.as_str(), "abc");
assert_eq!(pair.line_col(), (1, 1));
let pair = pairs.next().unwrap();
assert_eq!(pair.as_str(), "e");
assert_eq!(pair.line_col(), (2, 1));
let pair = pairs.next().unwrap();
assert_eq!(pair.as_str(), "fgh");
assert_eq!(pair.line_col(), (2, 2));
}
#[test]
fn test_rev_iter_line_col() {
let mut pairs = AbcParser::parse(Rule::a, "abc\nefgh").unwrap().rev();
let pair = pairs.next().unwrap();
assert_eq!(pair.as_str(), "fgh");
assert_eq!(pair.line_col(), (2, 2));
let pair = pairs.next().unwrap();
assert_eq!(pair.as_str(), "e");
assert_eq!(pair.line_col(), (2, 1));
let pair = pairs.next().unwrap();
assert_eq!(pair.as_str(), "abc");
assert_eq!(pair.line_col(), (1, 1));
}
#[test]
#[allow(clippy::almost_complete_range)]
fn test_tag_node_branch() {
use crate::{state, ParseResult, ParserState};
#[allow(non_camel_case_types)]
#[derive(Clone, Copy, Debug, Eq, Hash, Ord, PartialEq, PartialOrd)]
enum Rule {
number, add, mul, }
fn mark_branch(
state: Box<ParserState<'_, Rule>>,
) -> ParseResult<Box<ParserState<'_, Rule>>> {
expr(state, Rule::mul, "*")
.and_then(|state| state.tag_node("mul"))
.or_else(|state| expr(state, Rule::add, "+"))
.and_then(|state| state.tag_node("add"))
}
fn expr<'a>(
state: Box<ParserState<'a, Rule>>,
r: Rule,
o: &'static str,
) -> ParseResult<Box<ParserState<'a, Rule>>> {
state.rule(r, |state| {
state.sequence(|state| {
number(state)
.and_then(|state| state.tag_node("lhs"))
.and_then(|state| state.match_string(o))
.and_then(number)
.and_then(|state| state.tag_node("rhs"))
})
})
}
fn number(state: Box<ParserState<'_, Rule>>) -> ParseResult<Box<ParserState<'_, Rule>>> {
state.rule(Rule::number, |state| state.match_range('0'..'9'))
}
let input = "1+2";
let pairs = state(input, mark_branch).unwrap();
assert_eq!(pairs.find_first_tagged("add").unwrap().as_rule(), Rule::add);
assert_eq!(pairs.find_first_tagged("mul"), None);
let mut left_numbers = pairs.clone().find_tagged("lhs");
assert_eq!(left_numbers.next().unwrap().as_str(), "1");
assert_eq!(left_numbers.next(), None);
let mut right_numbers = pairs.find_tagged("rhs");
assert_eq!(right_numbers.next().unwrap().as_str(), "2");
assert_eq!(right_numbers.next(), None);
}
#[test]
fn exact_size_iter_for_pairs() {
let pairs = AbcParser::parse(Rule::a, "abc\nefgh").unwrap();
assert_eq!(pairs.len(), pairs.count());
let pairs = AbcParser::parse(Rule::a, "abc\nefgh").unwrap().rev();
assert_eq!(pairs.len(), pairs.count());
let mut pairs = AbcParser::parse(Rule::a, "abc\nefgh").unwrap();
let pairs_len = pairs.len();
let _ = pairs.next().unwrap();
assert_eq!(pairs.count() + 1, pairs_len);
}
}