hash.rs 100.0%

86 of 86 lines run, 28 of 29 functions · run #417 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,
    /// An author's grant to a certified subject (§14.7).
    Grant,
    /// A tree of files as one immutable thing: an image, a package, an
    /// archive (Cylinder, docs/cylinder.md §4.1).
    Artifact,
}

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

    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",
            ObjectType::Grant => "grant",
            ObjectType::Artifact => "artifact",
        }
    }

    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	36075×	pub fn is_zero(&self) -> bool {
19	36075×	*self == Self::ZERO
20	36075×	}
21	140077×	pub fn to_hex(&self) -> String {
22	140077×	hex::encode(self.0)
23	140077×	}
24	38468×	pub fn from_hex(s: &str) -> Option<ObjectRef> {
25	38468×	let v = hex::decode(s).ok()?;
26	38464×	let a: [u8; 32] = v.try_into().ok()?;
27	38464×	Some(ObjectRef(a))
28	38468×	}
29	184906×	pub fn from_slice(b: &[u8]) -> Option<ObjectRef> {
30	184906×	let a: [u8; 32] = b.try_into().ok()?;
31	184906×	Some(ObjectRef(a))
32	184906×	}
33		/// First `n` hex characters.
34	3714×	pub fn short(&self, n: usize) -> String {
35	3714×	let h = self.to_hex();
36	3714×	h[..n.min(h.len())].to_string()
37	3714×	}
38	122×	pub fn starts_with_hex(&self, prefix: &str) -> bool {
39	122×	self.to_hex().starts_with(prefix)
40	122×	}
41		}
42
43		impl fmt::Display for ObjectRef {
44	123×	fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
45	123×	f.write_str(&self.to_hex())
46	123×	}
47		}
48
49		impl fmt::Debug for ObjectRef {
50	2926×	fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
51	2926×	write!(f, "#{}", self.short(12))
52	2926×	}
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		/// An author's grant to a certified subject (§14.7).
70		Grant,
71		/// A tree of files as one immutable thing: an image, a package, an
72		/// archive (Cylinder, docs/cylinder.md §4.1).
73		Artifact,
74		}
75
76		impl ObjectType {
77		pub const ALL: [ObjectType; 13] = [
78		ObjectType::Chunk,
79		ObjectType::Blob,
80		ObjectType::Change,
81		ObjectType::Checkpoint,
82		ObjectType::Op,
83		ObjectType::Attest,
84		ObjectType::Identity,
85		ObjectType::Policy,
86		ObjectType::State,
87		ObjectType::Receipt,
88		ObjectType::Certificate,
89		ObjectType::Grant,
90		ObjectType::Artifact,
91		];
92
93	406038×	pub fn name(self) -> &'static str {
94	406038×	match self {
95	97920×	ObjectType::Chunk => "chunk",
96	58948×	ObjectType::Blob => "blob",
97	92858×	ObjectType::Change => "change",
98	31948×	ObjectType::Checkpoint => "checkpoint",
99	65717×	ObjectType::Op => "op",
100	13571×	ObjectType::Attest => "attest",
101	13690×	ObjectType::Identity => "identity",
102	9042×	ObjectType::Policy => "policy",
103	21392×	ObjectType::State => "state",
104	244×	ObjectType::Receipt => "receipt",
105	649×	ObjectType::Certificate => "certificate",
106	25×	ObjectType::Grant => "grant",
107	34×	ObjectType::Artifact => "artifact",
108		}
109	406038×	}
110
111	58340×	pub fn from_name(s: &str) -> Option<ObjectType> {
112	262142×	Self::ALL.iter().copied().find(\|t\| t.name() == s)
113	58340×	}
114		}
115
116		/// `ObjectRef = BLAKE3-256("oxy1 " \|\| type \|\| " " \|\| decimal(len) \|\| 0x00 \|\| body)`.
117	129488×	pub fn hash_object(ty: ObjectType, body: &[u8]) -> ObjectRef {
118	129488×	let mut h = blake3::Hasher::new();
119	129488×	h.update(&header(ty, body.len()));
120	129488×	h.update(body);
121	129488×	ObjectRef(*h.finalize().as_bytes())
122	129488×	}
123
124	143670×	pub fn header(ty: ObjectType, len: usize) -> Vec<u8> {
125	143670×	let mut v = Vec::with_capacity(32);
126	143670×	v.extend_from_slice(b"oxy1 ");
127	143670×	v.extend_from_slice(ty.name().as_bytes());
128	143670×	v.push(b' ');
129	143670×	v.extend_from_slice(len.to_string().as_bytes());
130	143670×	v.push(0);
131	143670×	v
132	143670×	}
133
134		#[cfg(test)]
135		mod tests {
136		use super::*;
137
138		#[test]
139	1×	fn header_matches_spec() {
140	1×	assert_eq!(header(ObjectType::Chunk, 5), b"oxy1 chunk 5\0");
141	1×	assert_eq!(header(ObjectType::Change, 1234), b"oxy1 change 1234\0");
142	1×	}
143
144		#[test]
145	1×	fn types_are_domain_separated() {
146	1×	let body = b"same bytes";
147	1×	let a = hash_object(ObjectType::Chunk, body);
148	1×	let b = hash_object(ObjectType::Blob, body);
149	1×	assert_ne!(a, b);
150	1×	assert_eq!(a, hash_object(ObjectType::Chunk, body));
151		// Reference vector: pin so the format cannot drift silently.
152	1×	assert_eq!(
153	1×	hash_object(ObjectType::Chunk, b"").to_hex(),
154	1×	blake3::hash(b"oxy1 chunk 0\0").to_hex().as_str()
155		);
156	1×	}
157
158		#[test]
159	1×	fn hex_round_trip() {
160	1×	let r = hash_object(ObjectType::Chunk, b"x");
161	1×	assert_eq!(ObjectRef::from_hex(&r.to_hex()), Some(r));
162	1×	assert_eq!(ObjectRef::from_hex("zz"), None);
163	1×	assert!(r.starts_with_hex(&r.short(7)));
164	1×	assert!(ObjectRef::ZERO.is_zero());
165	13×	for t in ObjectType::ALL {
166	13×	assert_eq!(ObjectType::from_name(t.name()), Some(t));
167		}
168	1×	}
169		}

`/`	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