1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
pub use crate::cid::Codec as Code;
use std::io::{Read, Write};
pub trait Codec: Sized {
const CODE: Code;
type Error: std::error::Error + Send + Sync + 'static;
fn encode<T: Encode<Self> + ?Sized>(obj: &T) -> Result<Box<[u8]>, Self::Error> {
let mut buf = Vec::new();
obj.encode(&mut buf)?;
Ok(buf.into_boxed_slice())
}
fn decode<T: Decode<Self>>(mut bytes: &[u8]) -> Result<T, Self::Error> {
T::decode(&mut bytes)
}
}
pub trait Encode<C: Codec> {
fn encode<W: Write>(&self, w: &mut W) -> Result<(), C::Error>;
}
pub trait Decode<C: Codec>: Sized {
fn decode<R: Read>(r: &mut R) -> Result<Self, C::Error>;
}
#[cfg(test)]
mod tests {
use super::*;
use crate::ipld::Ipld;
use thiserror::Error;
struct CodecImpl;
#[derive(Debug, Error)]
enum CodecImplError {
#[error("can only encode null")]
NotNull,
#[error("io: {0}")]
Io(#[from] std::io::Error),
}
impl Codec for CodecImpl {
const CODE: Code = Code::Raw;
type Error = CodecImplError;
}
impl Encode<CodecImpl> for Ipld {
fn encode<W: Write>(&self, w: &mut W) -> Result<(), <CodecImpl as Codec>::Error> {
match self {
Self::Null => Ok(w.write_all(&[0])?),
_ => Err(CodecImplError::NotNull),
}
}
}
impl Decode<CodecImpl> for Ipld {
fn decode<R: Read>(r: &mut R) -> Result<Self, <CodecImpl as Codec>::Error> {
let mut buf = [0; 1];
r.read_exact(&mut buf)?;
if buf[0] == 0 {
Ok(Ipld::Null)
} else {
Err(CodecImplError::NotNull)
}
}
}
#[test]
fn test_codec() {
let bytes = CodecImpl::encode(&Ipld::Null).unwrap();
let ipld: Ipld = CodecImpl::decode(&bytes).unwrap();
assert_eq!(ipld, Ipld::Null);
}
}