use crate::coords::Coords;
use std::borrow::Cow;
use std::cell::{Cell, RefCell};
use std::collections::HashMap;
use std::fmt::Debug;
use std::fs::File;
use std::io::BufReader;
use std::io::{BufRead, Read};
use std::path::Path;
use std::rc::Rc;
use crate::coords::Span;
use crate::errors::{Details, Error, ParserResult, Stage};
use crate::lexer::{Lexer, Token};
use crate::parser_error;
use crate::JsonValue;
#[derive(Default)]
pub struct Parser {}
impl Parser {
pub fn parse_file<PathLike: AsRef<Path>>(&self, path: PathLike) -> ParserResult<JsonValue> {
match File::open(&path) {
Ok(f) => {
let reader = BufReader::new(f);
self.parse(reader)
}
Err(_) => {
parser_error!(Details::InvalidFile, Coords::default())
}
}
}
pub fn parse_bytes(&self, bytes: &[u8]) -> ParserResult<JsonValue> {
let reader = BufReader::new(bytes);
self.parse(reader)
}
pub fn parse_str(&self, str: &str) -> ParserResult<JsonValue> {
let reader = BufReader::new(str.as_bytes());
self.parse(reader)
}
fn parse<Buffer: BufRead>(&self, input: Buffer) -> ParserResult<JsonValue> {
let mut lexer = Lexer::new(input);
match lexer.consume()? {
(Token::StartObject, _) => self.parse_object(&mut lexer),
(Token::StartArray, _) => self.parse_array(&mut lexer),
(_, span) => {
parser_error!(Details::InvalidRootObject, span.start)
}
}
}
fn parse_value<Buffer: BufRead>(&self, lexer: &mut Lexer<Buffer>) -> ParserResult<JsonValue> {
match lexer.consume()? {
(Token::StartObject, _) => self.parse_object(lexer),
(Token::StartArray, _) => self.parse_array(lexer),
(Token::Str(str), _) => Ok(JsonValue::String(Cow::Owned(str))),
(Token::Float(value), _) => Ok(JsonValue::Float(value)),
(Token::Integer(value), _) => Ok(JsonValue::Integer(value)),
(Token::Boolean(value), _) => Ok(JsonValue::Boolean(value)),
(Token::Null, _) => Ok(JsonValue::Null),
(token, span) => {
parser_error!(Details::UnexpectedToken(token), span.start)
}
}
}
fn parse_object<Buffer: BufRead>(&self, lexer: &mut Lexer<Buffer>) -> ParserResult<JsonValue> {
let mut pairs = vec![];
loop {
match lexer.consume()? {
(Token::Str(str), _) => {
let should_be_colon = lexer.consume()?;
match should_be_colon {
(Token::Colon, _) => pairs.push((str, self.parse_value(lexer)?)),
(_, _) => {
return parser_error!(Details::PairExpected, should_be_colon.1.start)
}
}
}
(Token::Comma, _) => (),
(Token::EndObject, _) => return Ok(JsonValue::Object(pairs)),
(_token, span) => {
return parser_error!(Details::InvalidObject, span.start);
}
}
}
}
fn parse_array<Buffer: BufRead>(&self, lexer: &mut Lexer<Buffer>) -> ParserResult<JsonValue> {
let mut values: Vec<JsonValue> = vec![];
loop {
match lexer.consume()? {
(Token::StartArray, _) => values.push(self.parse_array(lexer)?),
(Token::EndArray, _) => return Ok(JsonValue::Array(values)),
(Token::StartObject, _) => values.push(self.parse_object(lexer)?),
(Token::Str(str), _) => values.push(JsonValue::String(Cow::Owned(str))),
(Token::Float(value), _) => values.push(JsonValue::Float(value)),
(Token::Integer(value), _) => values.push(JsonValue::Integer(value)),
(Token::Boolean(value), _) => values.push(JsonValue::Boolean(value)),
(Token::Null, _) => values.push(JsonValue::Null),
(Token::Comma, _) => (),
(_token, span) => {
return parser_error!(Details::InvalidArray, span.start);
}
}
}
}
}
#[cfg(test)]
mod tests {
#![allow(unused_macros)]
use crate::dom::Parser;
use crate::errors::Details;
use crate::{reader_from_file, reader_from_relative_file};
use bytesize::ByteSize;
use std::fs::File;
use std::io::BufReader;
use std::path::PathBuf;
use std::time::Instant;
use std::{env, fs};
#[test]
fn should_parse_lengthy_arrays() {
let reader = reader_from_relative_file!("fixtures/json/valid/bc_block.json");
let parser = Parser::default();
let parsed = parser.parse(reader);
println!("{parsed:?}");
assert!(parsed.is_ok());
}
#[test]
fn should_parse_simple_schema() {
let reader = reader_from_relative_file!("fixtures/json/valid/simple_schema.json");
let parser = Parser::default();
let parsed = parser.parse(reader);
println!("{parsed:?}");
assert!(parsed.is_ok());
}
#[test]
fn should_successfully_bail() {
let reader = reader_from_file!("fixtures/json/invalid/invalid_1.json");
let parser = Parser::default();
let parsed = parser.parse(reader);
println!("Parse result = {:?}", parsed);
assert!(parsed.is_err());
assert!(parsed.err().unwrap().details == Details::InvalidRootObject);
}
#[test]
fn should_parse_basic_test_files() {
for f in fs::read_dir("fixtures/json/valid").unwrap() {
let path = f.unwrap().path();
println!("Parsing {:?}", &path);
if path.is_file() {
let len = fs::metadata(&path).unwrap().len();
let start = Instant::now();
let reader = reader_from_file!(path.to_str().unwrap());
let parser = Parser::default();
let parsed = parser.parse(reader);
if parsed.is_err() {
println!("Parse of {:?} failed!", &path);
println!("Parse failed with errors: {:?}", &parsed)
}
assert!(parsed.is_ok());
println!(
"Parsed {} in {:?} [{:?}]",
ByteSize(len),
start.elapsed(),
path,
);
}
}
}
}