summaryrefslogtreecommitdiffstats
path: root/vendor/gix-object/src/tree/ref_iter.rs
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/gix-object/src/tree/ref_iter.rs')
-rw-r--r--vendor/gix-object/src/tree/ref_iter.rs162
1 files changed, 162 insertions, 0 deletions
diff --git a/vendor/gix-object/src/tree/ref_iter.rs b/vendor/gix-object/src/tree/ref_iter.rs
new file mode 100644
index 000000000..fb3ba2dfc
--- /dev/null
+++ b/vendor/gix-object/src/tree/ref_iter.rs
@@ -0,0 +1,162 @@
+use std::convert::TryFrom;
+
+use nom::error::ParseError;
+
+use crate::{tree, tree::EntryRef, TreeRef, TreeRefIter};
+
+impl<'a> TreeRefIter<'a> {
+ /// Instantiate an iterator from the given tree data.
+ pub fn from_bytes(data: &'a [u8]) -> TreeRefIter<'a> {
+ TreeRefIter { data }
+ }
+}
+
+impl<'a> TreeRef<'a> {
+ /// Deserialize a Tree from `data`.
+ pub fn from_bytes(data: &'a [u8]) -> Result<TreeRef<'a>, crate::decode::Error> {
+ decode::tree(data).map(|(_, t)| t).map_err(crate::decode::Error::from)
+ }
+
+ /// Create an instance of the empty tree.
+ ///
+ /// It's particularly useful as static part of a program.
+ pub const fn empty() -> TreeRef<'static> {
+ TreeRef { entries: Vec::new() }
+ }
+}
+
+impl<'a> TreeRefIter<'a> {
+ /// Consume self and return all parsed entries.
+ pub fn entries(self) -> Result<Vec<EntryRef<'a>>, crate::decode::Error> {
+ self.collect()
+ }
+}
+
+impl<'a> Iterator for TreeRefIter<'a> {
+ type Item = Result<EntryRef<'a>, crate::decode::Error>;
+
+ fn next(&mut self) -> Option<Self::Item> {
+ if self.data.is_empty() {
+ return None;
+ }
+ match decode::fast_entry(self.data) {
+ Some((data_left, entry)) => {
+ self.data = data_left;
+ Some(Ok(entry))
+ }
+ None => {
+ self.data = &[];
+ #[allow(clippy::unit_arg)]
+ Some(Err(nom::Err::Error(crate::decode::ParseError::from_error_kind(
+ &[] as &[u8],
+ nom::error::ErrorKind::MapRes,
+ ))
+ .into()))
+ }
+ }
+ }
+}
+
+impl<'a> TryFrom<&'a [u8]> for tree::EntryMode {
+ type Error = &'a [u8];
+
+ fn try_from(mode: &'a [u8]) -> Result<Self, Self::Error> {
+ Ok(match mode {
+ b"40000" => tree::EntryMode::Tree,
+ b"100644" => tree::EntryMode::Blob,
+ b"100755" => tree::EntryMode::BlobExecutable,
+ b"120000" => tree::EntryMode::Link,
+ b"160000" => tree::EntryMode::Commit,
+ b"100664" => tree::EntryMode::Blob, // rare and found in the linux kernel
+ b"100640" => tree::EntryMode::Blob, // rare and found in the Rust repo
+ _ => return Err(mode),
+ })
+ }
+}
+
+impl TryFrom<u32> for tree::EntryMode {
+ type Error = u32;
+
+ fn try_from(mode: u32) -> Result<Self, Self::Error> {
+ Ok(match mode {
+ 0o40000 => tree::EntryMode::Tree,
+ 0o100644 => tree::EntryMode::Blob,
+ 0o100755 => tree::EntryMode::BlobExecutable,
+ 0o120000 => tree::EntryMode::Link,
+ 0o160000 => tree::EntryMode::Commit,
+ 0o100664 => tree::EntryMode::Blob, // rare and found in the linux kernel
+ 0o100640 => tree::EntryMode::Blob, // rare and found in the Rust repo
+ _ => return Err(mode),
+ })
+ }
+}
+
+mod decode {
+ use std::convert::TryFrom;
+
+ use bstr::ByteSlice;
+ use nom::{
+ bytes::complete::{tag, take, take_while1, take_while_m_n},
+ character::is_digit,
+ combinator::all_consuming,
+ error::ParseError,
+ multi::many0,
+ sequence::terminated,
+ IResult,
+ };
+
+ use crate::{parse::SPACE, tree, tree::EntryRef, TreeRef};
+
+ const NULL: &[u8] = b"\0";
+
+ pub fn fast_entry(i: &[u8]) -> Option<(&[u8], EntryRef<'_>)> {
+ let mut mode = 0u32;
+ let mut spacer_pos = 1;
+ for b in i.iter().take_while(|b| **b != b' ') {
+ if *b < b'0' || *b > b'7' {
+ return None;
+ }
+ mode = (mode << 3) + (b - b'0') as u32;
+ spacer_pos += 1;
+ }
+ let (_, i) = i.split_at(spacer_pos);
+ let mode = tree::EntryMode::try_from(mode).ok()?;
+ let (filename, i) = i.split_at(i.find_byte(0)?);
+ let i = &i[1..];
+ const HASH_LEN_FIXME: usize = 20; // TODO: know actual /desired length or we may overshoot
+ let (oid, i) = match i.len() {
+ len if len < HASH_LEN_FIXME => return None,
+ _ => i.split_at(20),
+ };
+ Some((
+ i,
+ EntryRef {
+ mode,
+ filename: filename.as_bstr(),
+ oid: gix_hash::oid::try_from_bytes(oid).expect("we counted exactly 20 bytes"),
+ },
+ ))
+ }
+
+ pub fn entry<'a, E: ParseError<&'a [u8]>>(i: &'a [u8]) -> IResult<&[u8], EntryRef<'_>, E> {
+ let (i, mode) = terminated(take_while_m_n(5, 6, is_digit), tag(SPACE))(i)?;
+ let mode = tree::EntryMode::try_from(mode)
+ .map_err(|invalid| nom::Err::Error(E::from_error_kind(invalid, nom::error::ErrorKind::MapRes)))?;
+ let (i, filename) = terminated(take_while1(|b| b != NULL[0]), tag(NULL))(i)?;
+ let (i, oid) = take(20u8)(i)?; // TODO: make this compatible with other hash lengths
+
+ Ok((
+ i,
+ EntryRef {
+ mode,
+ filename: filename.as_bstr(),
+ oid: gix_hash::oid::try_from_bytes(oid).expect("we counted exactly 20 bytes"),
+ },
+ ))
+ }
+
+ pub fn tree<'a, E: ParseError<&'a [u8]>>(i: &'a [u8]) -> IResult<&'a [u8], TreeRef<'a>, E> {
+ let (i, entries) = all_consuming(many0(entry))(i)?;
+ Ok((i, TreeRef { entries }))
+ }
+}