Lines
96.5 %
Functions
100 %
Branches
/*
* Hurl (https://hurl.dev)
* Copyright (C) 2026 Orange
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* http://www.apache.org/licenses/LICENSE-2.0
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
use crate::ast::VersionValue::VersionAny;
use crate::ast::{
Body, Entry, HurlFile, Method, Request, Response, Section, SourceInfo, Status, StatusValue,
Version, VersionValue,
};
use crate::combinator::{optional, zero_or_more};
use crate::reader::Reader;
use super::ParseResult;
use super::bytes::bytes;
use super::error::{ParseError, ParseErrorKind};
use super::primitives::{
eof, key_value, line_terminator, one_or_more_spaces, optional_line_terminators, try_literal,
zero_or_more_spaces,
use super::sections::{request_sections, response_sections};
use super::string::unquoted_template;
pub fn hurl_file(reader: &mut Reader) -> ParseResult<HurlFile> {
let entries = zero_or_more(entry, reader)?;
let line_terminators = optional_line_terminators(reader)?;
eof(reader)?;
Ok(HurlFile {
entries,
line_terminators,
})
}
fn entry(reader: &mut Reader) -> ParseResult<Entry> {
let req = request(reader)?;
let resp = optional(response, reader)?;
Ok(Entry {
request: req,
response: resp,
fn request(reader: &mut Reader) -> ParseResult<Request> {
let start = reader.cursor();
let space0 = zero_or_more_spaces(reader)?;
let method = method(reader)?;
let space1 = one_or_more_spaces(reader)?;
let url = unquoted_template(reader)?;
let line_terminator0 = line_terminator(reader)?;
let headers = zero_or_more(key_value, reader)?;
let sections = request_sections(reader)?;
let body = optional(body, reader)?;
let source_info = SourceInfo::new(start.pos, reader.cursor().pos);
check_duplicated_sections(§ions)?;
Ok(Request {
space0,
method,
space1,
url,
line_terminator0,
headers,
sections,
body,
source_info,
fn response(reader: &mut Reader) -> ParseResult<Response> {
let version = version(reader)?;
let status = status(reader)?;
let sections = response_sections(reader)?;
Ok(Response {
version,
status,
fn check_duplicated_sections(sections: &[Section]) -> Result<(), ParseError> {
let mut section_names = vec![];
for section in sections {
if section_names.contains(§ion.identifier()) {
return Err(ParseError::new(
section.source_info.start,
false,
ParseErrorKind::DuplicateSection,
));
} else {
section_names.push(section.identifier());
Ok(())
fn method(reader: &mut Reader) -> ParseResult<Method> {
if reader.is_eof() {
let kind = ParseErrorKind::Method {
name: "<EOF>".to_string(),
return Err(ParseError::new(reader.cursor().pos, true, kind));
let name = reader.read_while(|c| c.is_ascii_alphabetic());
if name.is_empty() || name.to_uppercase() != name {
let kind = ParseErrorKind::Method { name };
Err(ParseError::new(start.pos, false, kind))
Ok(Method::new(&name))
fn version(reader: &mut Reader) -> ParseResult<Version> {
try_literal("HTTP", reader)?;
let next_c = reader.peek();
match next_c {
Some('/') => {
let available_version = [
("/1.0", VersionValue::Version1),
("/1.1", VersionValue::Version11),
("/2", VersionValue::Version2),
("/3", VersionValue::Version3),
];
for (s, value) in available_version.iter() {
if try_literal(s, reader).is_ok() {
return Ok(Version {
value: *value,
source_info: SourceInfo::new(start.pos, reader.cursor().pos),
});
Err(ParseError::new(start.pos, false, ParseErrorKind::Version))
Some(' ') | Some('\t') => Ok(Version {
value: VersionAny,
}),
_ => Err(ParseError::new(start.pos, false, ParseErrorKind::Version)),
fn status(reader: &mut Reader) -> ParseResult<Status> {
let value = match try_literal("*", reader) {
Ok(_) => StatusValue::Any,
Err(_) => {
let kind = ParseErrorKind::Status;
return Err(ParseError::new(start.pos, false, kind));
let s = reader.read_while(|c| c.is_ascii_digit());
if s.is_empty() {
match s.to_string().parse() {
Ok(value) => StatusValue::Specific(value),
let end = reader.cursor();
Ok(Status {
value,
source_info: SourceInfo::new(start.pos, end.pos),
fn body(reader: &mut Reader) -> ParseResult<Body> {
// let start = reader.state.clone();
let value = bytes(reader)?;
Ok(Body {
#[cfg(test)]
mod tests {
use super::*;
Bytes, Comment, JsonListElement, JsonValue, JsonValueKind, LineTerminator, MultilineString,
MultilineStringKind, Template, TemplateElement, Whitespace,
use crate::reader::{CharPos, Pos};
use crate::types::ToSource;
#[test]
fn test_hurl_file() {
let mut reader = Reader::new("GET http://google.fr");
let hurl_file = hurl_file(&mut reader).unwrap();
assert_eq!(hurl_file.entries.len(), 1);
fn test_entry() {
let e = entry(&mut reader).unwrap();
assert_eq!(e.request.method, Method::new("GET"));
assert_eq!(reader.cursor().index, CharPos(20));
fn test_several_entry() {
let mut reader = Reader::new("GET http://google.fr\nGET http://google.fr");
assert_eq!(reader.cursor().index, CharPos(21));
assert_eq!(reader.cursor().pos.line, 2);
assert_eq!(reader.cursor().index, CharPos(41));
let mut reader =
Reader::new("GET http://google.fr # comment1\nGET http://google.fr # comment2");
assert_eq!(reader.cursor().index, CharPos(32));
assert_eq!(reader.cursor().index, CharPos(63));
fn test_entry_with_response() {
let mut reader = Reader::new("GET http://google.fr\nHTTP/1.1 200");
assert_eq!(e.response.unwrap().status.value, StatusValue::Specific(200));
fn test_request() {
let default_request = Request {
line_terminators: vec![],
space0: Whitespace {
value: String::new(),
source_info: SourceInfo::new(Pos::new(1, 1), Pos::new(1, 1)),
},
method: Method::new("GET"),
space1: Whitespace {
value: " ".to_string(),
source_info: SourceInfo::new(Pos::new(1, 4), Pos::new(1, 5)),
url: Template::new(
None,
vec![TemplateElement::String {
value: "http://google.fr".to_string(),
source: "http://google.fr".to_source(),
}],
SourceInfo::new(Pos::new(1, 5), Pos::new(1, 21)),
),
line_terminator0: LineTerminator {
source_info: SourceInfo::new(Pos::new(1, 21), Pos::new(1, 21)),
comment: None,
newline: Whitespace {
headers: vec![],
sections: vec![],
body: None,
source_info: SourceInfo::new(Pos::new(1, 1), Pos::new(1, 21)),
assert_eq!(request(&mut reader).unwrap(), default_request);
let mut reader = Reader::new("GET http://google.fr # comment");
source_info: SourceInfo::new(Pos::new(1, 4), Pos::new(1, 6)),
SourceInfo::new(Pos::new(1, 6), Pos::new(1, 22)),
source_info: SourceInfo::new(Pos::new(1, 22), Pos::new(1, 23)),
comment: Some(Comment {
value: " comment".to_string(),
source_info: SourceInfo::new(Pos::new(1, 24), Pos::new(1, 32)),
source_info: SourceInfo::new(Pos::new(1, 32), Pos::new(1, 32)),
source_info: SourceInfo::new(Pos::new(1, 1), Pos::new(1, 32)),
assert_eq!(reader.cursor().index, CharPos(31));
let r = request(&mut reader).unwrap();
assert_eq!(r.method, Method::new("GET"));
fn test_request_multilines() {
// GET http://google.fr
// ```
// Hello World!
let mut reader = Reader::new("GET http://google.fr\n```\nHello World!\n```");
let req = request(&mut reader).unwrap();
assert_eq!(
req.body.unwrap(),
Body {
source_info: SourceInfo::new(Pos::new(2, 1), Pos::new(2, 1)),
value: Bytes::MultilineString(MultilineString {
space: Whitespace {
source_info: SourceInfo::new(Pos::new(2, 4), Pos::new(2, 4)),
source_info: SourceInfo::new(Pos::new(2, 4), Pos::new(3, 1)),
value: "\n".to_string(),
kind: MultilineStringKind::Text(Template::new(
value: "Hello World!\n".to_string(),
source: "Hello World!\n".to_source(),
SourceInfo::new(Pos::new(3, 1), Pos::new(4, 1)),
)),
source_info: SourceInfo::new(Pos::new(4, 4), Pos::new(4, 4)),
);
fn test_request_post_json() {
let mut reader = Reader::new("POST http://localhost:8000/post-json-array\n[1,2,3]");
assert_eq!(r.method, Method::new("POST"));
r.body.unwrap().value,
Bytes::Json(JsonValue::new(
SourceInfo::new(Pos::new(2, 1), Pos::new(2, 8)),
JsonValueKind::List {
space0: String::new(),
elements: vec![
JsonListElement {
value: JsonValue::new(
SourceInfo::new(Pos::new(2, 2), Pos::new(2, 3)),
JsonValueKind::Number("1".to_string()),
space1: String::new(),
SourceInfo::new(Pos::new(2, 4), Pos::new(2, 5)),
JsonValueKind::Number("2".to_string()),
SourceInfo::new(Pos::new(2, 6), Pos::new(2, 7)),
JsonValueKind::Number("3".to_string()),
],
))
let mut reader = Reader::new("POST http://localhost:8000/post-json-string\n\"Hello\"");
JsonValueKind::String(Template::new(
Some('"'),
value: "Hello".to_string(),
source: "Hello".to_source(),
SourceInfo::new(Pos::new(2, 2), Pos::new(2, 7)),
let mut reader = Reader::new("POST http://localhost:8000/post-json-number\n100");
SourceInfo::new(Pos::new(2, 1), Pos::new(2, 4)),
JsonValueKind::Number("100".to_string()),
fn test_request_error() {
let mut reader = Reader::new("xxx");
let error = request(&mut reader).err().unwrap();
assert_eq!(error.pos, Pos { line: 1, column: 1 });
fn test_response() {
let mut reader = Reader::new("HTTP/1.1 200");
//println!("{:?}", response(&mut reader));
let r = response(&mut reader).unwrap();
assert_eq!(r.version.value, VersionValue::Version11);
assert_eq!(r.status.value, StatusValue::Specific(200));
fn test_method() {
let mut reader = Reader::new("xxx ");
let error = method(&mut reader).err().unwrap();
assert_eq!(reader.cursor().index, CharPos(3));
let mut reader = Reader::new("");
assert_eq!(reader.cursor().index, CharPos(0));
let mut reader = Reader::new("GET ");
assert_eq!(method(&mut reader).unwrap(), Method::new("GET"));
let mut reader = Reader::new("CUSTOM");
assert_eq!(method(&mut reader).unwrap(), Method::new("CUSTOM"));
assert_eq!(reader.cursor().index, CharPos(6));
fn test_version() {
let mut reader = Reader::new("HTTP 200");
assert_eq!(version(&mut reader).unwrap().value, VersionAny);
assert_eq!(reader.cursor().index, CharPos(4));
let mut reader = Reader::new("HTTP\t200");
assert_eq!(version(&mut reader).unwrap().value, VersionValue::Version11);
let mut reader = Reader::new("HTTP/1. 200");
let error = version(&mut reader).err().unwrap();
fn test_status() {
let mut reader = Reader::new("*");
let s = status(&mut reader).unwrap();
assert_eq!(s.value, StatusValue::Any);
let mut reader = Reader::new("200");
assert_eq!(s.value, StatusValue::Specific(200));
let result = status(&mut reader);
assert!(result.is_err());
fn test_body_json() {
let mut reader = Reader::new("[1,2,3] ");
let b = body(&mut reader).unwrap();
assert_eq!(b.line_terminators.len(), 0);
b.value,
SourceInfo::new(Pos::new(1, 1), Pos::new(1, 8)),
SourceInfo::new(Pos::new(1, 2), Pos::new(1, 3)),
SourceInfo::new(Pos::new(1, 4), Pos::new(1, 5)),
SourceInfo::new(Pos::new(1, 6), Pos::new(1, 7)),
assert_eq!(reader.cursor().index, CharPos(8));
let mut reader = Reader::new("{}");
SourceInfo::new(Pos::new(1, 1), Pos::new(1, 3)),
JsonValueKind::Object {
elements: vec![],
assert_eq!(reader.cursor().index, CharPos(2));
let mut reader = Reader::new("# comment\n {} # comment\nxxx");
assert_eq!(b.line_terminators.len(), 1);
SourceInfo::new(Pos::new(2, 2), Pos::new(2, 4)),
assert_eq!(reader.cursor().index, CharPos(24));
let mut reader = Reader::new("{x");
let error = body(&mut reader).err().unwrap();
assert_eq!(error.pos, Pos { line: 1, column: 2 });
assert!(!error.recoverable);