hash.rs 100.0%

84 of 84 lines run, 28 of 29 functions · run #311 on main · run missed

//! Object references: BLAKE3-256 over a domain-separating header and the body
//! (spec §5.2).

use std::fmt;

#[derive(Clone, Copy, PartialEq, Eq, Hash, PartialOrd, Ord)]
pub struct ObjectRef(pub [u8; 32]);

/// A change is referenced by the ObjectRef of its encoding.
pub type ChangeHash = ObjectRef;
/// An identity is referenced by the ObjectRef of its encoding.
pub type KeyId = ObjectRef;

impl ObjectRef {
    /// Reserved: means "this change" inside a change (spec §5.2, §7.4).
    pub const ZERO: ObjectRef = ObjectRef([0; 32]);

    pub fn is_zero(&self) -> bool {
        *self == Self::ZERO
    }
    pub fn to_hex(&self) -> String {
        hex::encode(self.0)
    }
    pub fn from_hex(s: &str) -> Option<ObjectRef> {
        let v = hex::decode(s).ok()?;
        let a: [u8; 32] = v.try_into().ok()?;
        Some(ObjectRef(a))
    }
    pub fn from_slice(b: &[u8]) -> Option<ObjectRef> {
        let a: [u8; 32] = b.try_into().ok()?;
        Some(ObjectRef(a))
    }
    /// First `n` hex characters.
    pub fn short(&self, n: usize) -> String {
        let h = self.to_hex();
        h[..n.min(h.len())].to_string()
    }
    pub fn starts_with_hex(&self, prefix: &str) -> bool {
        self.to_hex().starts_with(prefix)
    }
}

impl fmt::Display for ObjectRef {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(&self.to_hex())
    }
}

impl fmt::Debug for ObjectRef {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "#{}", self.short(12))
    }
}

#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
pub enum ObjectType {
    Chunk,
    Blob,
    Change,
    Checkpoint,
    Op,
    Attest,
    Identity,
    Policy,
    State,
    Receipt,
    /// A short-lived key's certificate (oxygenhub#241).
    Certificate,
}

impl ObjectType {
    pub const ALL: [ObjectType; 11] = [
        ObjectType::Chunk,
        ObjectType::Blob,
        ObjectType::Change,
        ObjectType::Checkpoint,
        ObjectType::Op,
        ObjectType::Attest,
        ObjectType::Identity,
        ObjectType::Policy,
        ObjectType::State,
        ObjectType::Receipt,
        ObjectType::Certificate,
    ];

    pub fn name(self) -> &'static str {
        match self {
            ObjectType::Chunk => "chunk",
            ObjectType::Blob => "blob",
            ObjectType::Change => "change",
            ObjectType::Checkpoint => "checkpoint",
            ObjectType::Op => "op",
            ObjectType::Attest => "attest",
            ObjectType::Identity => "identity",
            ObjectType::Policy => "policy",
            ObjectType::State => "state",
            ObjectType::Receipt => "receipt",
            ObjectType::Certificate => "certificate",
        }
    }

    pub fn from_name(s: &str) -> Option<ObjectType> {
        Self::ALL.iter().copied().find(|t| t.name() == s)
    }
}

/// `ObjectRef = BLAKE3-256("oxy1 " || type || " " || decimal(len) || 0x00 || body)`.
pub fn hash_object(ty: ObjectType, body: &[u8]) -> ObjectRef {
    let mut h = blake3::Hasher::new();
    h.update(&header(ty, body.len()));
    h.update(body);
    ObjectRef(*h.finalize().as_bytes())
}

pub fn header(ty: ObjectType, len: usize) -> Vec<u8> {
    let mut v = Vec::with_capacity(32);
    v.extend_from_slice(b"oxy1 ");
    v.extend_from_slice(ty.name().as_bytes());
    v.push(b' ');
    v.extend_from_slice(len.to_string().as_bytes());
    v.push(0);
    v
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn header_matches_spec() {
        assert_eq!(header(ObjectType::Chunk, 5), b"oxy1 chunk 5\0");
        assert_eq!(header(ObjectType::Change, 1234), b"oxy1 change 1234\0");
    }

    #[test]
    fn types_are_domain_separated() {
        let body = b"same bytes";
        let a = hash_object(ObjectType::Chunk, body);
        let b = hash_object(ObjectType::Blob, body);
        assert_ne!(a, b);
        assert_eq!(a, hash_object(ObjectType::Chunk, body));
        // Reference vector: pin so the format cannot drift silently.
        assert_eq!(
            hash_object(ObjectType::Chunk, b"").to_hex(),
            blake3::hash(b"oxy1 chunk 0\0").to_hex().as_str()
        );
    }

    #[test]
    fn hex_round_trip() {
        let r = hash_object(ObjectType::Chunk, b"x");
        assert_eq!(ObjectRef::from_hex(&r.to_hex()), Some(r));
        assert_eq!(ObjectRef::from_hex("zz"), None);
        assert!(r.starts_with_hex(&r.short(7)));
        assert!(ObjectRef::ZERO.is_zero());
        for t in ObjectType::ALL {
            assert_eq!(ObjectType::from_name(t.name()), Some(t));
        }
    }
}

1		//! Object references: BLAKE3-256 over a domain-separating header and the body
2		//! (spec §5.2).
3
4		use std::fmt;
5
6		#[derive(Clone, Copy, PartialEq, Eq, Hash, PartialOrd, Ord)]
7		pub struct ObjectRef(pub [u8; 32]);
8
9		/// A change is referenced by the ObjectRef of its encoding.
10		pub type ChangeHash = ObjectRef;
11		/// An identity is referenced by the ObjectRef of its encoding.
12		pub type KeyId = ObjectRef;
13
14		impl ObjectRef {
15		/// Reserved: means "this change" inside a change (spec §5.2, §7.4).
16		pub const ZERO: ObjectRef = ObjectRef([0; 32]);
17
18	30873×	pub fn is_zero(&self) -> bool {
19	30873×	*self == Self::ZERO
20	30873×	}
21	109551×	pub fn to_hex(&self) -> String {
22	109551×	hex::encode(self.0)
23	109551×	}
24	34909×	pub fn from_hex(s: &str) -> Option<ObjectRef> {
25	34909×	let v = hex::decode(s).ok()?;
26	34905×	let a: [u8; 32] = v.try_into().ok()?;
27	34905×	Some(ObjectRef(a))
28	34909×	}
29	158046×	pub fn from_slice(b: &[u8]) -> Option<ObjectRef> {
30	158046×	let a: [u8; 32] = b.try_into().ok()?;
31	158046×	Some(ObjectRef(a))
32	158046×	}
33		/// First `n` hex characters.
34	3379×	pub fn short(&self, n: usize) -> String {
35	3379×	let h = self.to_hex();
36	3379×	h[..n.min(h.len())].to_string()
37	3379×	}
38	119×	pub fn starts_with_hex(&self, prefix: &str) -> bool {
39	119×	self.to_hex().starts_with(prefix)
40	119×	}
41		}
42
43		impl fmt::Display for ObjectRef {
44	121×	fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
45	121×	f.write_str(&self.to_hex())
46	121×	}
47		}
48
49		impl fmt::Debug for ObjectRef {
50	2642×	fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
51	2642×	write!(f, "#{}", self.short(12))
52	2642×	}
53		}
54
55		#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)]
56		pub enum ObjectType {
57		Chunk,
58		Blob,
59		Change,
60		Checkpoint,
61		Op,
62		Attest,
63		Identity,
64		Policy,
65		State,
66		Receipt,
67		/// A short-lived key's certificate (oxygenhub#241).
68		Certificate,
69		}
70
71		impl ObjectType {
72		pub const ALL: [ObjectType; 11] = [
73		ObjectType::Chunk,
74		ObjectType::Blob,
75		ObjectType::Change,
76		ObjectType::Checkpoint,
77		ObjectType::Op,
78		ObjectType::Attest,
79		ObjectType::Identity,
80		ObjectType::Policy,
81		ObjectType::State,
82		ObjectType::Receipt,
83		ObjectType::Certificate,
84		];
85
86	328811×	pub fn name(self) -> &'static str {
87	328811×	match self {
88	81326×	ObjectType::Chunk => "chunk",
89	48423×	ObjectType::Blob => "blob",
90	77542×	ObjectType::Change => "change",
91	25320×	ObjectType::Checkpoint => "checkpoint",
92	53025×	ObjectType::Op => "op",
93	9386×	ObjectType::Attest => "attest",
94	9142×	ObjectType::Identity => "identity",
95	6607×	ObjectType::Policy => "policy",
96	17924×	ObjectType::State => "state",
97	81×	ObjectType::Receipt => "receipt",
98	35×	ObjectType::Certificate => "certificate",
99		}
100	328811×	}
101
102	47558×	pub fn from_name(s: &str) -> Option<ObjectType> {
103	210266×	Self::ALL.iter().copied().find(\|t\| t.name() == s)
104	47558×	}
105		}
106
107		/// `ObjectRef = BLAKE3-256("oxy1 " \|\| type \|\| " " \|\| decimal(len) \|\| 0x00 \|\| body)`.
108	106738×	pub fn hash_object(ty: ObjectType, body: &[u8]) -> ObjectRef {
109	106738×	let mut h = blake3::Hasher::new();
110	106738×	h.update(&header(ty, body.len()));
111	106738×	h.update(body);
112	106738×	ObjectRef(*h.finalize().as_bytes())
113	106738×	}
114
115	118450×	pub fn header(ty: ObjectType, len: usize) -> Vec<u8> {
116	118450×	let mut v = Vec::with_capacity(32);
117	118450×	v.extend_from_slice(b"oxy1 ");
118	118450×	v.extend_from_slice(ty.name().as_bytes());
119	118450×	v.push(b' ');
120	118450×	v.extend_from_slice(len.to_string().as_bytes());
121	118450×	v.push(0);
122	118450×	v
123	118450×	}
124
125		#[cfg(test)]
126		mod tests {
127		use super::*;
128
129		#[test]
130	1×	fn header_matches_spec() {
131	1×	assert_eq!(header(ObjectType::Chunk, 5), b"oxy1 chunk 5\0");
132	1×	assert_eq!(header(ObjectType::Change, 1234), b"oxy1 change 1234\0");
133	1×	}
134
135		#[test]
136	1×	fn types_are_domain_separated() {
137	1×	let body = b"same bytes";
138	1×	let a = hash_object(ObjectType::Chunk, body);
139	1×	let b = hash_object(ObjectType::Blob, body);
140	1×	assert_ne!(a, b);
141	1×	assert_eq!(a, hash_object(ObjectType::Chunk, body));
142		// Reference vector: pin so the format cannot drift silently.
143	1×	assert_eq!(
144	1×	hash_object(ObjectType::Chunk, b"").to_hex(),
145	1×	blake3::hash(b"oxy1 chunk 0\0").to_hex().as_str()
146		);
147	1×	}
148
149		#[test]
150	1×	fn hex_round_trip() {
151	1×	let r = hash_object(ObjectType::Chunk, b"x");
152	1×	assert_eq!(ObjectRef::from_hex(&r.to_hex()), Some(r));
153	1×	assert_eq!(ObjectRef::from_hex("zz"), None);
154	1×	assert!(r.starts_with_hex(&r.short(7)));
155	1×	assert!(ObjectRef::ZERO.is_zero());
156	11×	for t in ObjectType::ALL {
157	11×	assert_eq!(ObjectType::from_name(t.name()), Some(t));
158		}
159	1×	}
160		}

`/`	Search
`g` `c`	Code
`g` `h`	History
`g` `b`	Bookmarks
`g` `t`	Trust
`y`	Permalink to this state (files and trees)
`?`	This sheet

Coverage / crates/oxy-core/src/hash.rs 100.0%

Keyboard