eth-valkyoth-verify 0.20.2

no_std Ethereum verification boundaries.
Documentation
use core::fmt;

use serde::de::{Error as _, MapAccess, SeqAccess, Visitor};
use serde::{Deserialize, Deserializer};
use std::collections::BTreeSet;
use std::string::{String, ToString};
use std::vec::Vec;

use super::Eip712JsonError;

const MAX_JSON_OBJECT_KEYS: usize = 512;

pub(super) enum Json {
    Null,
    Bool(bool),
    Number(serde_json::Number),
    String(String),
    Array(Vec<Json>),
    Object(Object),
}

pub(super) struct Object(Vec<(String, Json)>);

impl Object {
    pub(super) fn get(&self, name: &str) -> Result<&Json, Eip712JsonError> {
        self.get_optional(name).ok_or(Eip712JsonError::Shape)
    }

    pub(super) fn get_optional(&self, name: &str) -> Option<&Json> {
        self.0
            .iter()
            .find(|(candidate, _)| candidate == name)
            .map(|(_, value)| value)
    }

    pub(super) fn entries(&self) -> impl Iterator<Item = (&str, &Json)> {
        self.0.iter().map(|(name, value)| (name.as_str(), value))
    }
}

impl Json {
    pub(super) fn as_object(&self) -> Result<&Object, Eip712JsonError> {
        match self {
            Self::Object(object) => Ok(object),
            _ => Err(Eip712JsonError::Shape),
        }
    }

    pub(super) fn as_array(&self) -> Result<&[Json], Eip712JsonError> {
        match self {
            Self::Array(values) => Ok(values),
            _ => Err(Eip712JsonError::Shape),
        }
    }

    pub(super) fn as_str(&self) -> Result<&str, Eip712JsonError> {
        match self {
            Self::String(value) => Ok(value),
            _ => Err(Eip712JsonError::Shape),
        }
    }

    pub(super) fn as_bool(&self) -> Result<bool, Eip712JsonError> {
        match self {
            Self::Bool(value) => Ok(*value),
            _ => Err(Eip712JsonError::Shape),
        }
    }
}

impl<'de> Deserialize<'de> for Json {
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        deserializer.deserialize_any(JsonVisitor)
    }
}

struct JsonVisitor;

impl<'de> Visitor<'de> for JsonVisitor {
    type Value = Json;

    fn expecting(&self, formatter: &mut fmt::Formatter<'_>) -> fmt::Result {
        formatter.write_str("JSON value without duplicate object keys")
    }

    fn visit_bool<E>(self, value: bool) -> Result<Self::Value, E> {
        Ok(Json::Bool(value))
    }

    fn visit_i64<E>(self, value: i64) -> Result<Self::Value, E> {
        Ok(Json::Number(serde_json::Number::from(value)))
    }

    fn visit_u64<E>(self, value: u64) -> Result<Self::Value, E> {
        Ok(Json::Number(serde_json::Number::from(value)))
    }

    fn visit_f64<E>(self, _value: f64) -> Result<Self::Value, E>
    where
        E: serde::de::Error,
    {
        Err(E::custom("floating point values are not admitted"))
    }

    fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
    where
        E: serde::de::Error,
    {
        Ok(Json::String(value.to_string()))
    }

    fn visit_string<E>(self, value: String) -> Result<Self::Value, E> {
        Ok(Json::String(value))
    }

    fn visit_none<E>(self) -> Result<Self::Value, E> {
        Ok(Json::Null)
    }

    fn visit_unit<E>(self) -> Result<Self::Value, E> {
        Ok(Json::Null)
    }

    fn visit_seq<A>(self, mut seq: A) -> Result<Self::Value, A::Error>
    where
        A: SeqAccess<'de>,
    {
        let mut values = Vec::new();
        while let Some(value) = seq.next_element()? {
            values.push(value);
        }
        Ok(Json::Array(values))
    }

    fn visit_map<A>(self, mut map: A) -> Result<Self::Value, A::Error>
    where
        A: MapAccess<'de>,
    {
        let mut entries = Vec::<(String, Json)>::new();
        let mut seen = BTreeSet::<String>::new();
        while let Some((key, value)) = map.next_entry::<String, Json>()? {
            if entries.len() >= MAX_JSON_OBJECT_KEYS {
                return Err(A::Error::custom("object has too many keys"));
            }
            if !seen.insert(key.clone()) {
                return Err(A::Error::custom("duplicate object key"));
            }
            entries.push((key, value));
        }
        Ok(Json::Object(Object(entries)))
    }
}