1
/*
2
 * Hurl (https://hurl.dev)
3
 * Copyright (C) 2025 Orange
4
 *
5
 * Licensed under the Apache License, Version 2.0 (the "License");
6
 * you may not use this file except in compliance with the License.
7
 * You may obtain a copy of the License at
8
 *
9
 *          http://www.apache.org/licenses/LICENSE-2.0
10
 *
11
 * Unless required by applicable law or agreed to in writing, software
12
 * distributed under the License is distributed on an "AS IS" BASIS,
13
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14
 * See the License for the specific language governing permissions and
15
 * limitations under the License.
16
 *
17
 */
18
use crate::reader::Reader;
19

            
20
/// Represent a parser error. This type of error ca be recoverable or not and
21
/// implements conversion to recoverable / non-recoverable instance.
22
pub trait ParseError {
23
    /// Is this error recoverable or not?
24
    fn is_recoverable(&self) -> bool;
25

            
26
    /// Transforms this error to a recoverable one.
27
    fn to_recoverable(self) -> Self;
28

            
29
    /// Transforms this error to a non-recoverable one.
30
    fn to_non_recoverable(self) -> Self;
31
}
32

            
33
/// A parser func.
34
pub type ParseFunc<T, E> = fn(&mut Reader) -> Result<T, E>;
35

            
36
/// Try to consume one instances of the provided parser.
37
334440
pub fn optional<T, E>(f: ParseFunc<T, E>, reader: &mut Reader) -> Result<Option<T>, E>
38
334440
where
39
334440
    E: ParseError,
40
334440
{
41
334440
    let start = reader.cursor();
42
334440
    match f(reader) {
43
30370
        Ok(r) => Ok(Some(r)),
44
304070
        Err(e) => {
45
304070
            if e.is_recoverable() {
46
303930
                reader.seek(start);
47
303930
                Ok(None)
48
            } else {
49
140
                Err(e)
50
            }
51
        }
52
    }
53
}
54

            
55
/// Makes an error recoverable but does not reset cursor.
56
273670
pub fn recover<T, E>(f: ParseFunc<T, E>, reader: &mut Reader) -> Result<T, E>
57
273670
where
58
273670
    E: ParseError,
59
273670
{
60
273670
    match f(reader) {
61
91460
        Ok(r) => Ok(r),
62
182210
        Err(e) => Err(e.to_recoverable()),
63
    }
64
}
65

            
66
/// Makes an error non recoverable.
67
2560
pub fn non_recover<T, E>(f: ParseFunc<T, E>, reader: &mut Reader) -> Result<T, E>
68
2560
where
69
2560
    E: ParseError,
70
2560
{
71
2560
    match f(reader) {
72
2445
        Ok(r) => Ok(r),
73
115
        Err(e) => Err(e.to_non_recoverable()),
74
    }
75
}
76

            
77
/// Consumes zero or more instances of the provided parser.
78
781400
pub fn zero_or_more<T, E>(f: ParseFunc<T, E>, reader: &mut Reader) -> Result<Vec<T>, E>
79
781400
where
80
781400
    E: ParseError,
81
781400
{
82
781400
    let mut v = Vec::new();
83
    loop {
84
1001052
        let initial_state = reader.cursor();
85
1001052
        if reader.is_eof() {
86
26180
            return Ok(v);
87
        }
88
974872

            
89
974872
        match f(reader) {
90
219652
            Ok(r) => {
91
219652
                v.push(r);
92
            }
93
755220
            Err(e) => {
94
755220
                return if e.is_recoverable() {
95
754757
                    reader.seek(initial_state);
96
754757
                    Ok(v)
97
                } else {
98
463
                    Err(e)
99
                };
100
            }
101
        }
102
    }
103
}
104

            
105
/// Consumes one or more instances of the provided parser.
106
65065
pub fn one_or_more<T, E>(f: ParseFunc<T, E>, reader: &mut Reader) -> Result<Vec<T>, E>
107
65065
where
108
65065
    E: ParseError,
109
65065
{
110
65065
    match f(reader) {
111
65045
        Ok(first) => {
112
65045
            let mut v = vec![first];
113
            loop {
114
65575
                let initial_state = reader.cursor();
115
65575
                match f(reader) {
116
530
                    Ok(r) => {
117
530
                        v.push(r);
118
                    }
119
65045
                    Err(e) => {
120
65045
                        return if e.is_recoverable() {
121
65045
                            reader.seek(initial_state);
122
65045
                            Ok(v)
123
                        } else {
124
                            Err(e)
125
                        };
126
                    }
127
                }
128
            }
129
        }
130
        // if zero occurrence => should fail?
131
20
        Err(e) => Err(e.to_non_recoverable()),
132
    }
133
}
134

            
135
/// Tries to apply the list of parser until one of them succeeds.
136
/// Typically, this should be recoverable
137
152610
pub fn choice<T, E>(fs: &[ParseFunc<T, E>], reader: &mut Reader) -> Result<T, E>
138
152610
where
139
152610
    E: ParseError,
140
152610
{
141
1401103
    for (pos, f) in fs.iter().enumerate() {
142
1401103
        let start = reader.cursor();
143
1401103
        if pos == fs.len() - 1 {
144
82362
            return f(reader);
145
        }
146
1318741
        match f(reader) {
147
1248642
            Err(err) if err.is_recoverable() => {
148
1248493
                reader.seek(start);
149
1248493
                continue;
150
            }
151
70248
            x => return x,
152
        }
153
    }
154
    unreachable!("You can't call choice with an empty vector of choice")
155
}