// Copyright 2020-2024 The Jujutsu Authors // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // https://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. #![allow(missing_docs)] pub trait ObjectId { fn object_type(&self) -> String; fn as_bytes(&self) -> &[u8]; fn to_bytes(&self) -> Vec; fn hex(&self) -> String; } // Defines a new struct type with visibility `vis` and name `ident` containing // a single Vec used to store an identifier (typically the output of a hash // function) as bytes. Types defined using this macro automatically implement // the `ObjectId` and `ContentHash` traits. // Documentation comments written inside the macro definition and will be // captured and associated with the type defined by the macro. // // Example: // ```no_run // id_type!( // /// My favorite id type. // pub MyId // ); // ``` macro_rules! id_type { ( $(#[$attr:meta])* $vis:vis $name:ident ) => { $(#[$attr])* #[derive(ContentHash, PartialEq, Eq, PartialOrd, Ord, Clone, Hash)] $vis struct $name(Vec); $crate::object_id::impl_id_type!($name); }; } macro_rules! impl_id_type { ($name:ident) => { impl $name { pub fn new(value: Vec) -> Self { Self(value) } pub fn from_bytes(bytes: &[u8]) -> Self { Self(bytes.to_vec()) } /// Parses the given hex string into an ObjectId. /// /// The given string must be valid. A static str is required to /// prevent API misuse. pub fn from_hex(hex: &'static str) -> Self { Self::try_from_hex(hex).unwrap() } /// Parses the given hex string into an ObjectId. pub fn try_from_hex(hex: &str) -> Result { hex::decode(hex).map(Self) } } impl std::fmt::Debug for $name { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> Result<(), std::fmt::Error> { f.debug_tuple(stringify!($name)).field(&self.hex()).finish() } } impl crate::object_id::ObjectId for $name { fn object_type(&self) -> String { stringify!($name) .strip_suffix("Id") .unwrap() .to_ascii_lowercase() .to_string() } fn as_bytes(&self) -> &[u8] { &self.0 } fn to_bytes(&self) -> Vec { self.0.clone() } fn hex(&self) -> String { hex::encode(&self.0) } } }; } pub(crate) use {id_type, impl_id_type}; /// An identifier prefix (typically from a type implementing the [`ObjectId`] /// trait) with facilities for converting between bytes and a hex string. #[derive(Debug, Clone, PartialEq, Eq)] pub struct HexPrefix { // For odd-length prefixes, the lower 4 bits of the last byte are // zero-filled (e.g. the prefix "abc" is stored in two bytes as "abc0"). min_prefix_bytes: Vec, has_odd_byte: bool, } impl HexPrefix { /// Returns a new `HexPrefix` or `None` if `prefix` cannot be decoded from /// hex to bytes. pub fn new(prefix: &str) -> Option { let has_odd_byte = prefix.len() & 1 != 0; let min_prefix_bytes = if has_odd_byte { hex::decode(prefix.to_owned() + "0").ok()? } else { hex::decode(prefix).ok()? }; Some(HexPrefix { min_prefix_bytes, has_odd_byte, }) } pub fn from_bytes(bytes: &[u8]) -> Self { HexPrefix { min_prefix_bytes: bytes.to_owned(), has_odd_byte: false, } } pub fn hex(&self) -> String { let mut hex_string = hex::encode(&self.min_prefix_bytes); if self.has_odd_byte { hex_string.pop().unwrap(); } hex_string } /// Minimum bytes that would match this prefix. (e.g. "abc0" for "abc") /// /// Use this to partition a sorted slice, and test `matches(id)` from there. pub fn min_prefix_bytes(&self) -> &[u8] { &self.min_prefix_bytes } /// Returns the bytes representation if this prefix can be a full id. pub fn as_full_bytes(&self) -> Option<&[u8]> { (!self.has_odd_byte).then_some(&self.min_prefix_bytes) } fn split_odd_byte(&self) -> (Option, &[u8]) { if self.has_odd_byte { let (&odd, prefix) = self.min_prefix_bytes.split_last().unwrap(); (Some(odd), prefix) } else { (None, &self.min_prefix_bytes) } } /// Returns whether the stored prefix matches the prefix of `id`. pub fn matches(&self, id: &Q) -> bool { let id_bytes = id.as_bytes(); let (maybe_odd, prefix) = self.split_odd_byte(); if id_bytes.starts_with(prefix) { if let Some(odd) = maybe_odd { matches!(id_bytes.get(prefix.len()), Some(v) if v & 0xf0 == odd) } else { true } } else { false } } } /// The result of a prefix search. #[derive(Debug, Clone, PartialEq, Eq)] pub enum PrefixResolution { NoMatch, SingleMatch(T), AmbiguousMatch, } impl PrefixResolution { pub fn map(self, f: impl FnOnce(T) -> U) -> PrefixResolution { match self { PrefixResolution::NoMatch => PrefixResolution::NoMatch, PrefixResolution::SingleMatch(x) => PrefixResolution::SingleMatch(f(x)), PrefixResolution::AmbiguousMatch => PrefixResolution::AmbiguousMatch, } } } impl PrefixResolution { pub fn plus(&self, other: &PrefixResolution) -> PrefixResolution { match (self, other) { (PrefixResolution::NoMatch, other) => other.clone(), (local, PrefixResolution::NoMatch) => local.clone(), (PrefixResolution::AmbiguousMatch, _) => PrefixResolution::AmbiguousMatch, (_, PrefixResolution::AmbiguousMatch) => PrefixResolution::AmbiguousMatch, (PrefixResolution::SingleMatch(_), PrefixResolution::SingleMatch(_)) => { PrefixResolution::AmbiguousMatch } } } } #[cfg(test)] mod tests { use super::*; use crate::backend::CommitId; #[test] fn test_hex_prefix_prefixes() { let prefix = HexPrefix::new("").unwrap(); assert_eq!(prefix.min_prefix_bytes(), b""); let prefix = HexPrefix::new("1").unwrap(); assert_eq!(prefix.min_prefix_bytes(), b"\x10"); let prefix = HexPrefix::new("12").unwrap(); assert_eq!(prefix.min_prefix_bytes(), b"\x12"); let prefix = HexPrefix::new("123").unwrap(); assert_eq!(prefix.min_prefix_bytes(), b"\x12\x30"); let bad_prefix = HexPrefix::new("0x123"); assert_eq!(bad_prefix, None); let bad_prefix = HexPrefix::new("foobar"); assert_eq!(bad_prefix, None); } #[test] fn test_hex_prefix_matches() { let id = CommitId::from_hex("1234"); assert!(HexPrefix::new("").unwrap().matches(&id)); assert!(HexPrefix::new("1").unwrap().matches(&id)); assert!(HexPrefix::new("12").unwrap().matches(&id)); assert!(HexPrefix::new("123").unwrap().matches(&id)); assert!(HexPrefix::new("1234").unwrap().matches(&id)); assert!(!HexPrefix::new("12345").unwrap().matches(&id)); assert!(!HexPrefix::new("a").unwrap().matches(&id)); assert!(!HexPrefix::new("1a").unwrap().matches(&id)); assert!(!HexPrefix::new("12a").unwrap().matches(&id)); assert!(!HexPrefix::new("123a").unwrap().matches(&id)); } }