use alloc::string::String;
use alloc::vec::Vec;
use core::fmt;
use core::result::Result;
use serde::{de, Deserializer, Serializer};
static CHARS: &[u8] = b"0123456789abcdef";
pub fn to_hex(bytes: &[u8], skip_leading_zero: bool) -> String {
let bytes = if skip_leading_zero {
let non_zero = bytes.iter().take_while(|b| **b == 0).count();
let bytes = &bytes[non_zero..];
if bytes.is_empty() {
return "0x0".into();
} else {
bytes
}
} else if bytes.is_empty() {
return "0x".into();
} else {
bytes
};
let mut slice = vec![0u8; (bytes.len() + 1) * 2];
to_hex_raw(&mut slice, bytes, skip_leading_zero).into()
}
fn to_hex_raw<'a>(v: &'a mut [u8], bytes: &[u8], skip_leading_zero: bool) -> &'a str {
assert!(v.len() > 1 + bytes.len() * 2);
v[0] = b'0';
v[1] = b'x';
let mut idx = 2;
let first_nibble = bytes[0] >> 4;
if first_nibble != 0 || !skip_leading_zero {
v[idx] = CHARS[first_nibble as usize];
idx += 1;
}
v[idx] = CHARS[(bytes[0] & 0xf) as usize];
idx += 1;
for &byte in bytes.iter().skip(1) {
v[idx] = CHARS[(byte >> 4) as usize];
v[idx + 1] = CHARS[(byte & 0xf) as usize];
idx += 2;
}
unsafe { core::str::from_utf8_unchecked(&v[0..idx]) }
}
#[derive(Debug, PartialEq, Eq)]
pub enum FromHexError {
MissingPrefix,
InvalidHex {
character: char,
index: usize,
},
}
#[cfg(feature = "std")]
impl std::error::Error for FromHexError {}
impl fmt::Display for FromHexError {
fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
match *self {
Self::MissingPrefix => write!(fmt, "0x prefix is missing"),
Self::InvalidHex { character, index } => write!(fmt, "invalid hex character: {}, at {}", character, index),
}
}
}
pub fn from_hex(v: &str) -> Result<Vec<u8>, FromHexError> {
if !v.starts_with("0x") {
return Err(FromHexError::MissingPrefix);
}
let mut bytes = vec![0u8; (v.len() - 1) / 2];
from_hex_raw(v, &mut bytes)?;
Ok(bytes)
}
fn from_hex_raw<'a>(v: &str, bytes: &mut [u8]) -> Result<usize, FromHexError> {
let bytes_len = v.len() - 2;
let mut modulus = bytes_len % 2;
let mut buf = 0;
let mut pos = 0;
for (index, byte) in v.bytes().enumerate().skip(2) {
buf <<= 4;
match byte {
b'A'..=b'F' => buf |= byte - b'A' + 10,
b'a'..=b'f' => buf |= byte - b'a' + 10,
b'0'..=b'9' => buf |= byte - b'0',
b' ' | b'\r' | b'\n' | b'\t' => {
buf >>= 4;
continue;
}
b => {
let character = char::from(b);
return Err(FromHexError::InvalidHex { character, index });
}
}
modulus += 1;
if modulus == 2 {
modulus = 0;
bytes[pos] = buf;
pos += 1;
}
}
Ok(pos)
}
pub fn serialize_raw<S>(slice: &mut [u8], bytes: &[u8], serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
if bytes.is_empty() {
serializer.serialize_str("0x")
} else {
serializer.serialize_str(to_hex_raw(slice, bytes, false))
}
}
pub fn serialize<S>(bytes: &[u8], serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
let mut slice = vec![0u8; (bytes.len() + 1) * 2];
serialize_raw(&mut slice, bytes, serializer)
}
pub fn serialize_uint<S>(slice: &mut [u8], bytes: &[u8], serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
let non_zero = bytes.iter().take_while(|b| **b == 0).count();
let bytes = &bytes[non_zero..];
if bytes.is_empty() {
serializer.serialize_str("0x0")
} else {
serializer.serialize_str(to_hex_raw(slice, bytes, true))
}
}
#[derive(Debug, PartialEq, Eq)]
pub enum ExpectedLen<'a> {
Exact(&'a mut [u8]),
Between(usize, &'a mut [u8]),
}
impl<'a> fmt::Display for ExpectedLen<'a> {
fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
match *self {
ExpectedLen::Exact(ref v) => write!(fmt, "length of {}", v.len() * 2),
ExpectedLen::Between(min, ref v) => write!(fmt, "length between ({}; {}]", min * 2, v.len() * 2),
}
}
}
pub fn deserialize<'de, D>(deserializer: D) -> Result<Vec<u8>, D::Error>
where
D: Deserializer<'de>,
{
struct Visitor;
impl<'b> de::Visitor<'b> for Visitor {
type Value = Vec<u8>;
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
write!(formatter, "a 0x-prefixed hex string")
}
fn visit_str<E: de::Error>(self, v: &str) -> Result<Self::Value, E> {
from_hex(v).map_err(E::custom)
}
fn visit_string<E: de::Error>(self, v: String) -> Result<Self::Value, E> {
self.visit_str(&v)
}
}
deserializer.deserialize_str(Visitor)
}
pub fn deserialize_check_len<'a, 'de, D>(deserializer: D, len: ExpectedLen<'a>) -> Result<usize, D::Error>
where
D: Deserializer<'de>,
{
struct Visitor<'a> {
len: ExpectedLen<'a>,
}
impl<'a, 'b> de::Visitor<'b> for Visitor<'a> {
type Value = usize;
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
write!(formatter, "a 0x-prefixed hex string with {}", self.len)
}
fn visit_str<E: de::Error>(self, v: &str) -> Result<Self::Value, E> {
if !v.starts_with("0x") {
return Err(E::custom(FromHexError::MissingPrefix));
}
let len = v.len();
let is_len_valid = match self.len {
ExpectedLen::Exact(ref slice) => len == 2 * slice.len() + 2,
ExpectedLen::Between(min, ref slice) => len <= 2 * slice.len() + 2 && len > 2 * min + 2,
};
if !is_len_valid {
return Err(E::invalid_length(v.len() - 2, &self));
}
let bytes = match self.len {
ExpectedLen::Exact(slice) => slice,
ExpectedLen::Between(_, slice) => slice,
};
from_hex_raw(v, bytes).map_err(E::custom)
}
fn visit_string<E: de::Error>(self, v: String) -> Result<Self::Value, E> {
self.visit_str(&v)
}
}
deserializer.deserialize_str(Visitor { len })
}
#[cfg(test)]
mod tests {
use super::*;
use serde_derive::{Deserialize, Serialize};
#[derive(Serialize, Deserialize)]
struct Bytes(#[serde(with = "super")] Vec<u8>);
#[test]
fn should_not_fail_on_short_string() {
let a: Bytes = serde_json::from_str("\"0x\"").unwrap();
let b: Bytes = serde_json::from_str("\"0x1\"").unwrap();
let c: Bytes = serde_json::from_str("\"0x12\"").unwrap();
let d: Bytes = serde_json::from_str("\"0x123\"").unwrap();
let e: Bytes = serde_json::from_str("\"0x1234\"").unwrap();
let f: Bytes = serde_json::from_str("\"0x12345\"").unwrap();
assert!(a.0.is_empty());
assert_eq!(b.0, vec![1]);
assert_eq!(c.0, vec![0x12]);
assert_eq!(d.0, vec![0x1, 0x23]);
assert_eq!(e.0, vec![0x12, 0x34]);
assert_eq!(f.0, vec![0x1, 0x23, 0x45]);
}
#[test]
fn should_not_fail_on_other_strings() {
let a: Bytes =
serde_json::from_str("\"0x7f864e18e3dd8b58386310d2fe0919eef27c6e558564b7f67f22d99d20f587\"").unwrap();
let b: Bytes =
serde_json::from_str("\"0x7f864e18e3dd8b58386310d2fe0919eef27c6e558564b7f67f22d99d20f587b\"").unwrap();
let c: Bytes =
serde_json::from_str("\"0x7f864e18e3dd8b58386310d2fe0919eef27c6e558564b7f67f22d99d20f587b4\"").unwrap();
assert_eq!(a.0.len(), 31);
assert_eq!(b.0.len(), 32);
assert_eq!(c.0.len(), 32);
}
#[test]
fn should_serialize_and_deserialize_empty_bytes() {
let bytes = Bytes(Vec::new());
let data = serde_json::to_string(&bytes).unwrap();
assert_eq!("\"0x\"", &data);
let deserialized: Bytes = serde_json::from_str(&data).unwrap();
assert!(deserialized.0.is_empty())
}
#[test]
fn should_encode_to_and_from_hex() {
assert_eq!(to_hex(&[0, 1, 2], true), "0x102");
assert_eq!(to_hex(&[0, 1, 2], false), "0x000102");
assert_eq!(to_hex(&[0], true), "0x0");
assert_eq!(to_hex(&[], true), "0x0");
assert_eq!(to_hex(&[], false), "0x");
assert_eq!(to_hex(&[0], false), "0x00");
assert_eq!(from_hex("0x0102"), Ok(vec![1, 2]));
assert_eq!(from_hex("0x102"), Ok(vec![1, 2]));
assert_eq!(from_hex("0xf"), Ok(vec![0xf]));
}
}