Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -15,5 +15,3 @@ edition = "2021"
num = "0.4"
byteorder = "1"
libflate = "2"
ordered-float = "3"
thiserror = "1"
100 changes: 86 additions & 14 deletions src/codec.rs
Original file line number Diff line number Diff line change
Expand Up @@ -11,46 +11,118 @@ use std::io::Write;
use std::str;

/// Errors which can occur when decoding a term
#[derive(Debug, thiserror::Error)]
#[derive(Debug)]
pub enum DecodeError {
#[error("I/O error")]
Io(#[from] io::Error),
/// I/O error.
Io(io::Error),

#[error("the format version {version} is unsupported")]
/// Unsupported format version.
UnsupportedVersion { version: u8 },

#[error("unknown tag {tag}")]
/// Unknown tag.
UnknownTag { tag: u8 },

#[error("{value} is not a {expected}")]
/// Unexpected type.
UnexpectedType { value: Term, expected: String },

#[error("{value} is out of range {range:?}")]
/// Out of range.
OutOfRange {
value: i32,
range: std::ops::Range<i32>,
},

#[error("tried to convert non-finite float")]
/// Non-finite float.
NonFiniteFloat,
}

impl std::fmt::Display for DecodeError {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
Self::Io(error) => write!(f, "I/O error: {error}"),
Self::UnsupportedVersion { version } => {
write!(f, "the format version {version} is unsupported")
}
Self::UnknownTag { tag } => write!(f, "unknown tag {tag}"),
Self::UnexpectedType { value, expected } => write!(f, "{value} is not a {expected}"),
Self::OutOfRange { value, range } => write!(f, "{value} is out of range {range:?}"),
Self::NonFiniteFloat => write!(f, "tried to convert non-finite float"),
}
}
}

impl std::error::Error for DecodeError {
fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
if let Self::Io(error) = self {
Some(error)
} else {
None
}
}
}

impl From<std::io::Error> for DecodeError {
fn from(value: std::io::Error) -> Self {
Self::Io(value)
}
}

/// Errors which can occur when encoding a term
#[derive(Debug, thiserror::Error)]
#[derive(Debug)]
pub enum EncodeError {
#[error("I/O error")]
Io(#[from] io::Error),
/// I/O error.
Io(io::Error),

#[error("too long atom name: {} bytes", .0.name.len())]
/// Too long atom name.
TooLongAtomName(Atom),

#[error("too large integer value: {} bytes required to encode", .0.value.to_bytes_le().1.len())]
/// Too large integer value.
TooLargeInteger(BigInteger),

#[error("too large reference ID: {} bytes required to encode", .0.id.len() * 4)]
/// Too large reference ID.
TooLargeReferenceId(Reference),
}

impl std::fmt::Display for EncodeError {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
Self::Io(error) => write!(f, "I/O error: {error}"),
Self::TooLongAtomName(atom) => {
write!(f, "too long atom name: {} bytes", atom.name.len())
}
Self::TooLargeInteger(integer) => {
write!(
f,
"too large integer value: {} bytes required to encode",
integer.value.to_bytes_le().1.len()
)
}
Self::TooLargeReferenceId(reference) => {
write!(
f,
"too large reference ID: {} bytes required to encode",
reference.id.len() * 4
)
}
}
}
}

impl std::error::Error for EncodeError {
fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
if let Self::Io(error) = self {
Some(error)
} else {
None
}
}
}

impl From<std::io::Error> for EncodeError {
fn from(value: std::io::Error) -> Self {
Self::Io(value)
}
}

pub type DecodeResult = Result<Term, DecodeError>;
pub type EncodeResult = Result<(), EncodeError>;

Expand Down
16 changes: 9 additions & 7 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -354,7 +354,7 @@ impl From<&FixInteger> for BigInteger {
}

/// Floating point number
#[derive(Debug, Clone)]
#[derive(Debug, Clone, PartialEq)]
pub struct Float {
/// The value of the number
pub value: f64,
Expand Down Expand Up @@ -388,15 +388,17 @@ impl TryFrom<f64> for Float {
}
}
}
impl PartialEq for Float {
fn eq(&self, other: &Self) -> bool {
ordered_float::OrderedFloat(self.value) == ordered_float::OrderedFloat(other.value)
}
}
impl Eq for Float {}
impl std::hash::Hash for Float {
fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
ordered_float::OrderedFloat(self.value).hash(state);
if self.value.is_nan() {
f64::NAN.to_bits().hash(state);
} else if self.value == 0.0 {
// Positive or negative zero
0.0f64.to_bits().hash(state);
} else {
self.value.to_bits().hash(state);
}
}
}

Expand Down