use std::convert::TryInto; use git_hash::oid; use git_pack::{data::Object, find::Entry}; use crate::{ pack, pack::{bundle::Location, Bundle}, store::{compound, linked}, }; impl linked::Store { /// Return true if the given object `id` is contained in the store. pub fn contains(&self, id: impl AsRef) -> bool { let id = id.as_ref(); for db in self.dbs.iter() { if db.internal_find_packed(id).is_some() || db.loose.contains(id) { return true; } } false } } impl crate::Find for linked::Store { type Error = compound::find::Error; fn find<'a>( &self, id: impl AsRef, buffer: &'a mut Vec, pack_cache: &mut impl pack::cache::DecodeEntry, ) -> Result>, Self::Error> { let id = id.as_ref(); for db in self.dbs.iter() { match db.internal_find_packed(id) { Some(compound::find::PackLocation { bundle_index: pack_id, entry_index, }) => { return db .internal_get_packed_object_by_index(pack_id, entry_index, buffer, pack_cache) .map(Some) .map_err(Into::into) } None => { if db.loose.contains(id) { return db.loose.find(id, buffer).map_err(Into::into); } } } } Ok(None) } fn location_by_oid(&self, id: impl AsRef, buf: &mut Vec) -> Option { let id = id.as_ref(); for db in self.dbs.iter() { if let Some(compound::find::PackLocation { bundle_index, entry_index, }) = db.internal_find_packed(id) { let bundle = &db.bundles[bundle_index]; let pack_offset = bundle.index.pack_offset_at_index(entry_index); let entry = bundle.pack.entry(pack_offset); buf.resize(entry.decompressed_size.try_into().expect("representable size"), 0); return bundle .pack .decompress_entry(&entry, buf) .ok() .map(|entry_size_past_header| pack::bundle::Location { pack_id: bundle.pack.id, pack_offset, index_file_id: entry_index, entry_size: entry.header_size() + entry_size_past_header, }); } } None } fn bundle_by_pack_id(&self, pack_id: u32) -> Option<&Bundle> { self.dbs .iter() .find_map(|db| db.bundles.iter().find(|b| b.pack.id == pack_id)) } fn entry_by_location(&self, location: &pack::bundle::Location) -> Option> { self.dbs .iter() .find_map(|db| db.bundles.iter().find(|p| p.pack.id == location.pack_id)) .map(|b| (b, location)) .and_then(|(bundle, l)| { let crc32 = bundle.index.crc32_at_index(l.index_file_id); let pack_offset = bundle.index.pack_offset_at_index(l.index_file_id); bundle.pack.entry_slice(l.entry_range(pack_offset)).map(|data| Entry { data, crc32, version: bundle.pack.version(), }) }) } } impl crate::Find for &linked::Store { type Error = compound::find::Error; fn find<'a>( &self, id: impl AsRef, buffer: &'a mut Vec, pack_cache: &mut impl pack::cache::DecodeEntry, ) -> Result>, Self::Error> { (*self).find(id, buffer, pack_cache) } fn location_by_oid(&self, id: impl AsRef, buf: &mut Vec) -> Option { (*self).location_by_oid(id, buf) } fn bundle_by_pack_id(&self, pack_id: u32) -> Option<&Bundle> { (*self).bundle_by_pack_id(pack_id) } fn entry_by_location(&self, location: &pack::bundle::Location) -> Option> { (*self).entry_by_location(location) } }