use std::io::Write;
use std::{collections::BTreeMap, iter};
use serde::ser::Serialize;
use serde_json::value::{to_value, Map, Value};
use crate::errors::{Error, Result as TeraResult};
#[derive(Debug, Clone, PartialEq)]
pub struct Context {
data: BTreeMap<String, Value>,
}
impl Context {
pub fn new() -> Self {
Context { data: BTreeMap::new() }
}
pub fn insert<T: Serialize + ?Sized, S: Into<String>>(&mut self, key: S, val: &T) {
self.data.insert(key.into(), to_value(val).unwrap());
}
pub fn try_insert<T: Serialize + ?Sized, S: Into<String>>(
&mut self,
key: S,
val: &T,
) -> TeraResult<()> {
self.data.insert(key.into(), to_value(val)?);
Ok(())
}
pub fn extend(&mut self, mut source: Context) {
self.data.append(&mut source.data);
}
pub fn into_json(self) -> Value {
let mut m = Map::new();
for (key, value) in self.data {
m.insert(key, value);
}
Value::Object(m)
}
pub fn from_value(obj: Value) -> TeraResult<Self> {
match obj {
Value::Object(m) => {
let mut data = BTreeMap::new();
for (key, value) in m {
data.insert(key, value);
}
Ok(Context { data })
}
_ => Err(Error::msg(
"Creating a Context from a Value/Serialize requires it being a JSON object",
)),
}
}
pub fn from_serialize(value: impl Serialize) -> TeraResult<Self> {
let obj = to_value(value).map_err(Error::json)?;
Context::from_value(obj)
}
pub fn get(&self, index: &str) -> Option<&Value> {
self.data.get(index)
}
pub fn remove(&mut self, index: &str) -> Option<Value> {
self.data.remove(index)
}
pub fn contains_key(&self, index: &str) -> bool {
self.data.contains_key(index)
}
}
impl Default for Context {
fn default() -> Context {
Context::new()
}
}
pub trait ValueRender {
fn render(&self, write: &mut impl Write) -> std::io::Result<()>;
}
impl ValueRender for Value {
fn render(&self, write: &mut impl Write) -> std::io::Result<()> {
match *self {
Value::String(ref s) => write!(write, "{}", s),
Value::Number(ref i) => {
if let Some(v) = i.as_i64() {
write!(write, "{}", v)
} else if let Some(v) = i.as_u64() {
write!(write, "{}", v)
} else if let Some(v) = i.as_f64() {
write!(write, "{}", v)
} else {
unreachable!()
}
}
Value::Bool(i) => write!(write, "{}", i),
Value::Null => Ok(()),
Value::Array(ref a) => {
let mut first = true;
write!(write, "[")?;
for i in a.iter() {
if !first {
write!(write, ", ")?;
}
first = false;
i.render(write)?;
}
write!(write, "]")?;
Ok(())
}
Value::Object(_) => write!(write, "[object]"),
}
}
}
pub trait ValueNumber {
fn to_number(&self) -> Result<f64, ()>;
}
impl ValueNumber for Value {
fn to_number(&self) -> Result<f64, ()> {
match *self {
Value::Number(ref i) => Ok(i.as_f64().unwrap()),
_ => Err(()),
}
}
}
pub trait ValueTruthy {
fn is_truthy(&self) -> bool;
}
impl ValueTruthy for Value {
fn is_truthy(&self) -> bool {
match *self {
Value::Number(ref i) => {
if i.is_i64() {
return i.as_i64().unwrap() != 0;
}
if i.is_u64() {
return i.as_u64().unwrap() != 0;
}
let f = i.as_f64().unwrap();
f != 0.0 && !f.is_nan()
}
Value::Bool(ref i) => *i,
Value::Null => false,
Value::String(ref i) => !i.is_empty(),
Value::Array(ref i) => !i.is_empty(),
Value::Object(ref i) => !i.is_empty(),
}
}
}
#[inline]
pub fn get_json_pointer(key: &str) -> String {
lazy_static::lazy_static! {
static ref JSON_POINTER_REGEX: regex::Regex = regex::Regex::new(r#""[^"]*"|[^.]+"#).unwrap();
}
if key.find('"').is_some() {
let segments: Vec<&str> = iter::once("")
.chain(JSON_POINTER_REGEX.find_iter(key).map(|mat| mat.as_str().trim_matches('"')))
.collect();
segments.join("/")
} else {
["/", &key.replace(".", "/")].join("")
}
}
#[cfg(test)]
mod tests {
use super::*;
use serde_json::json;
use std::collections::HashMap;
#[test]
fn test_get_json_pointer() {
assert_eq!(get_json_pointer(""), "/");
assert_eq!(get_json_pointer("foo"), "/foo");
assert_eq!(get_json_pointer("foo.bar.baz"), "/foo/bar/baz");
assert_eq!(get_json_pointer(r#"foo["bar"].baz"#), r#"/foo["bar"]/baz"#);
assert_eq!(
get_json_pointer(r#"foo["bar"].baz["qux"].blub"#),
r#"/foo["bar"]/baz["qux"]/blub"#
);
}
#[test]
fn can_extend_context() {
let mut target = Context::new();
target.insert("a", &1);
target.insert("b", &2);
let mut source = Context::new();
source.insert("b", &3);
source.insert("c", &4);
target.extend(source);
assert_eq!(*target.data.get("a").unwrap(), to_value(1).unwrap());
assert_eq!(*target.data.get("b").unwrap(), to_value(3).unwrap());
assert_eq!(*target.data.get("c").unwrap(), to_value(4).unwrap());
}
#[test]
fn can_create_context_from_value() {
let obj = json!({
"name": "bob",
"age": 25
});
let context_from_value = Context::from_value(obj).unwrap();
let mut context = Context::new();
context.insert("name", "bob");
context.insert("age", &25);
assert_eq!(context_from_value, context);
}
#[test]
fn can_create_context_from_impl_serialize() {
let mut map = HashMap::new();
map.insert("name", "bob");
map.insert("last_name", "something");
let context_from_serialize = Context::from_serialize(&map).unwrap();
let mut context = Context::new();
context.insert("name", "bob");
context.insert("last_name", "something");
assert_eq!(context_from_serialize, context);
}
#[test]
fn can_remove_a_key() {
let mut context = Context::new();
context.insert("name", "foo");
context.insert("bio", "Hi, I'm foo.");
let mut expected = Context::new();
expected.insert("name", "foo");
assert_eq!(context.remove("bio"), Some(to_value("Hi, I'm foo.").unwrap()));
assert_eq!(context.get("bio"), None);
assert_eq!(context, expected);
}
#[test]
fn remove_return_none_with_unknown_index() {
let mut context = Context::new();
assert_eq!(context.remove("unknown"), None);
}
}