migrate hashing API users to fallible versions

Author: emilazy

gix-commitgraph/src/file/verify.rs

@@ -156,7 +156,7 @@ impl File {
         let data_len_without_trailer = self.data.len() - self.hash_len;
         let mut hasher = gix_hash::hasher(self.object_hash());
         hasher.update(&self.data[..data_len_without_trailer]);
-        let actual = hasher.finalize();
+        let actual = hasher.try_finalize()?;
         actual.verify(self.checksum())?;
         Ok(actual)
     }

gix-diff/tests/diff/blob/pipeline.rs

@@ -72,7 +72,7 @@ pub(crate) mod convert_to_diffable {
 
             let mut db = ObjectDb::default();
             let b_content = "b-content";
-            let id = db.insert(b_content);
+            let id = db.insert(b_content)?;
 
             let out = filter.convert_to_diffable(
                 &id,
@@ -129,7 +129,7 @@ pub(crate) mod convert_to_diffable {
         assert_eq!(buf.len(), 0, "it should avoid querying that data in the first place");
 
         let mut db = ObjectDb::default();
-        let id = db.insert(large_content);
+        let id = db.insert(large_content)?;
         let out = filter.convert_to_diffable(
             &id,
             EntryKind::Blob,
@@ -211,7 +211,7 @@ pub(crate) mod convert_to_diffable {
         drop(tmp);
 
         let mut db = ObjectDb::default();
-        let id = db.insert(large_content);
+        let id = db.insert(large_content)?;
 
         let out = filter.convert_to_diffable(
             &id,
@@ -397,7 +397,7 @@ pub(crate) mod convert_to_diffable {
 
         let mut db = ObjectDb::default();
         let b_content = "b-content\n";
-        let id = db.insert(b_content);
+        let id = db.insert(b_content)?;
 
         let out = filter.convert_to_diffable(
             &id,
@@ -416,7 +416,7 @@ pub(crate) mod convert_to_diffable {
 
         let mut db = ObjectDb::default();
         let b_content = "b\n";
-        let id = db.insert(b_content);
+        let id = db.insert(b_content)?;
         let out = filter.convert_to_diffable(
             &id,
             EntryKind::Blob,
@@ -490,7 +490,7 @@ pub(crate) mod convert_to_diffable {
 
         let mut db = ObjectDb::default();
         let b_content = "b-co\0ntent\n";
-        let id = db.insert(b_content);
+        let id = db.insert(b_content)?;
 
         let out = filter.convert_to_diffable(
             &id,
@@ -509,7 +509,7 @@ pub(crate) mod convert_to_diffable {
 
         let platform = attributes.at_entry("c", None, &gix_object::find::Never)?;
 
-        let id = db.insert("b");
+        let id = db.insert("b")?;
         let out = filter.convert_to_diffable(
             &id,
             EntryKind::Blob,
@@ -638,7 +638,7 @@ pub(crate) mod convert_to_diffable {
         assert_eq!(out.data, Some(pipeline::Data::Buffer { is_derived: false }));
         assert_eq!(buf.as_bstr(), "a\n", "unconditionally use git according to mode");
 
-        let id = db.insert("a\n");
+        let id = db.insert("a\n")?;
         for mode in worktree_modes {
             let out = filter.convert_to_diffable(
                 &id,
@@ -714,7 +714,7 @@ pub(crate) mod convert_to_diffable {
             assert_eq!(buf.len(), 0, "always cleared");
 
             buf.push(1);
-            let id = db.insert("link-target");
+            let id = db.insert("link-target")?;
             let out = filter.convert_to_diffable(
                 &id,
                 EntryKind::Link,
@@ -761,7 +761,7 @@ pub(crate) mod convert_to_diffable {
             assert_eq!(buf.len(), 0, "it's always cleared before any potential use");
         }
 
-        let id = db.insert("b\n");
+        let id = db.insert("b\n")?;
         for mode in all_modes {
             buf.push(1);
             let out = filter.convert_to_diffable(
@@ -814,7 +814,7 @@ pub(crate) mod convert_to_diffable {
             );
         }
 
-        let id = db.insert("c\n");
+        let id = db.insert("c\n")?;
         for mode in worktree_modes {
             let out = filter.convert_to_diffable(
                 &id,
@@ -863,7 +863,7 @@ pub(crate) mod convert_to_diffable {
             assert_eq!(buf.len(), 0);
         }
 
-        let id = db.insert("unset\n");
+        let id = db.insert("unset\n")?;
         for mode in all_modes {
             let out = filter.convert_to_diffable(
                 &id,
@@ -890,7 +890,7 @@ pub(crate) mod convert_to_diffable {
         }
 
         let platform = attributes.at_entry("d", None, &gix_object::find::Never)?;
-        let id = db.insert("d-in-db");
+        let id = db.insert("d-in-db")?;
         for mode in worktree_modes {
             let out = filter.convert_to_diffable(
                 &null,
@@ -959,7 +959,7 @@ pub(crate) mod convert_to_diffable {
             "no text filter, so git conversion was applied for worktree source"
         );
 
-        let id = db.insert("e-in-db");
+        let id = db.insert("e-in-db")?;
         let out = filter.convert_to_diffable(
             &id,
             EntryKind::Blob,

gix-diff/tests/diff/blob/platform.rs

@@ -30,7 +30,7 @@ fn resources_of_worktree_and_odb_and_check_link() -> crate::Result {
 
     let mut db = ObjectDb::default();
     let a_content = "a-content";
-    let id = db.insert(a_content);
+    let id = db.insert(a_content)?;
     platform.set_resource(
         id,
         EntryKind::BlobExecutable,
@@ -194,7 +194,7 @@ fn diff_binary() -> crate::Result {
 
     let mut db = ObjectDb::default();
     let a_content = "b";
-    let id = db.insert(a_content);
+    let id = db.insert(a_content)?;
     platform.set_resource(id, EntryKind::Blob, "b".into(), ResourceKind::NewOrDestination, &db)?;
 
     let out = platform.prepare_diff()?;
@@ -235,7 +235,7 @@ fn diff_performed_despite_external_command() -> crate::Result {
 
     let mut db = ObjectDb::default();
     let a_content = "b";
-    let id = db.insert(a_content);
+    let id = db.insert(a_content)?;
     platform.set_resource(id, EntryKind::Blob, "b".into(), ResourceKind::NewOrDestination, &db)?;
 
     let out = platform.prepare_diff()?;
@@ -277,7 +277,7 @@ fn diff_skipped_due_to_external_command_and_enabled_option() -> crate::Result {
 
     let mut db = ObjectDb::default();
     let a_content = "b";
-    let id = db.insert(a_content);
+    let id = db.insert(a_content)?;
     platform.set_resource(id, EntryKind::Blob, "b".into(), ResourceKind::NewOrDestination, &db)?;
 
     let out = platform.prepare_diff()?;

gix-diff/tests/diff/main.rs

@@ -51,10 +51,10 @@ mod util {
 
     impl ObjectDb {
         /// Insert `data` and return its hash. That can be used to find it again.
-        pub fn insert(&mut self, data: &str) -> gix_hash::ObjectId {
-            let id = gix_object::compute_hash(gix_hash::Kind::Sha1, gix_object::Kind::Blob, data.as_bytes());
+        pub fn insert(&mut self, data: &str) -> Result<gix_hash::ObjectId, Error> {
+            let id = gix_object::try_compute_hash(gix_hash::Kind::Sha1, gix_object::Kind::Blob, data.as_bytes())?;
             self.data_by_id.insert(id, data.into());
-            id
+            Ok(id)
         }
     }
 }

gix-diff/tests/diff/rewrites/tracker.rs

@@ -92,7 +92,7 @@ fn copy_by_similarity_reports_limit_if_encountered() -> crate::Result {
             (Change::addition(), "a-cpy-2", "a"),
             (Change::modification(), "d", "ab"),
         ],
-    );
+    )?;
 
     let mut calls = 0;
     let out = util::assert_emit_with_objects(
@@ -145,7 +145,7 @@ fn copy_by_id() -> crate::Result {
                 (Change::addition(), "a-cpy-2", "a"),
                 (Change::modification(), "d", "a"),
             ],
-        );
+        )?;
 
         let mut calls = 0;
         let out = util::assert_emit_with_objects(
@@ -218,7 +218,7 @@ fn copy_by_id_search_in_all_sources() -> crate::Result {
                 (Change::addition(), "a-cpy-1", "a"),
                 (Change::addition(), "a-cpy-2", "a"),
             ],
-        );
+        )?;
 
         let mut calls = 0;
         let content_id = hex_to_id("2e65efe2a145dda7ee51d1741299f848e5bf752e");
@@ -299,7 +299,7 @@ fn copy_by_50_percent_similarity() -> crate::Result {
             (Change::addition(), "a-cpy-2", "a\nc"),
             (Change::modification(), "d", "a"),
         ],
-    );
+    )?;
 
     let mut calls = 0;
     let out = util::assert_emit_with_objects(
@@ -377,7 +377,7 @@ fn copy_by_id_in_additions_only() -> crate::Result {
             (Change::modification(), "a", "a"),
             (Change::modification(), "a-cpy-1", "a"),
         ],
-    );
+    )?;
 
     let mut calls = 0;
     let out = util::assert_emit_with_objects(
@@ -429,7 +429,7 @@ fn rename_by_similarity_reports_limit_if_encountered() -> crate::Result {
             (Change::addition(), "b", "firt\nsecond\n"),
             (Change::addition(), "c", "second\nunrelated\n"),
         ],
-    );
+    )?;
 
     let mut calls = 0;
     let out = util::assert_emit_with_objects(
@@ -475,7 +475,7 @@ fn rename_by_50_percent_similarity() -> crate::Result {
             (Change::addition(), "b", "firt\nsecond\n"),
             (Change::addition(), "c", "second\nunrelated\n"),
         ],
-    );
+    )?;
 
     let mut calls = 0;
     let out = util::assert_emit_with_objects(
@@ -596,7 +596,7 @@ fn directory_renames_by_id_can_fail_gracefully() -> crate::Result {
             (Change::deletion(), "a", "first\nsecond\n"),
             (Change::addition(), "b", "firt\nsecond\n"),
         ],
-    );
+    )?;
 
     let mut calls = 0;
     let out = util::assert_emit_with_objects(
@@ -803,16 +803,16 @@ mod util {
     pub fn add_retained_blobs<'a>(
         tracker: &mut rewrites::Tracker<Change>,
         blobs: impl IntoIterator<Item = (Change, &'a str, &'a str)>,
-    ) -> ObjectDb {
+    ) -> crate::Result<ObjectDb> {
         let mut db = ObjectDb::default();
         for (mut change, location, data) in blobs {
-            change.id = db.insert(data);
+            change.id = db.insert(data)?;
             assert!(
                 tracker.try_push_change(change, location.into()).is_none(),
                 "input changes must be tracked"
             );
         }
-        db
+        Ok(db)
     }
 
     pub fn assert_emit(

gix-filter/src/ident.rs

@@ -68,7 +68,7 @@ pub fn apply(src: &[u8], object_hash: gix_hash::Kind, buf: &mut Vec<u8>) -> Resu
     while let Some(pos) = src[ofs..].find(b"$Id$") {
         let id = match id {
             None => {
-                let new_id = gix_object::compute_hash(object_hash, gix_object::Kind::Blob, src);
+                let new_id = gix_object::try_compute_hash(object_hash, gix_object::Kind::Blob, src)?;
                 id = new_id.into();
                 clear_and_set_capacity(buf, src.len() + HASH_LEN)?; // pre-allocate for one ID
                 new_id

gix-hash/src/hasher/io.rs

@@ -76,7 +76,7 @@ pub fn bytes_with_hasher(
         }
     }
 
-    let id = hasher.finalize();
+    let id = hasher.try_finalize()?;
     progress.show_throughput(start);
     Ok(id)
 }

gix-index/src/extension/end_of_index_entry/decode.rs

@@ -44,7 +44,7 @@ pub fn decode(data: &[u8], object_hash: gix_hash::Kind) -> Result<Option<usize>,
         last_chunk = Some(chunk);
     }
 
-    if hasher.finalize().verify(checksum).is_err() {
+    if hasher.try_finalize()?.verify(checksum).is_err() {
         return Ok(None);
     }
     // The last-to-this chunk ends where ours starts

gix-index/src/extension/end_of_index_entry/write.rs

@@ -23,7 +23,7 @@ pub fn write_to(
         hasher.update(&signature);
         hasher.update(&size.to_be_bytes());
     }
-    out.write_all(hasher.finalize().as_slice())?;
+    out.write_all(hasher.try_finalize()?.as_slice())?;
 
     Ok(())
 }

gix-index/src/file/write.rs

@@ -31,7 +31,7 @@ impl File {
             let mut hasher = hasher::io::Write::new(&mut out, self.state.object_hash);
             let out: &mut dyn std::io::Write = &mut hasher;
             let version = self.state.write_to(out, options)?;
-            (version, hasher.hash.finalize())
+            (version, hasher.hash.try_finalize()?)
         };
         out.write_all(hash.as_slice())?;
         Ok((version, hash))