Use trait object for progress in PrepareFetch::fetch_only

Signed-off-by: Jiahao XU <[email protected]>

Author: NobodyXu

Cargo.lock

@@ -168,7 +168,7 @@ gix = { version = "^0.53.1", path = "gix", default-features = false }
 time = "0.3.23"
 
 clap = { version = "4.1.1", features = ["derive", "cargo"] }
-prodash = { version = "26.2.0", optional = true, default-features = false }
+prodash = { workspace = true, optional = true }
 is-terminal = { version = "0.4.0", optional = true }
 env_logger = { version = "0.10.0", default-features = false }
 crosstermion = { version = "0.11.0", optional = true, default-features = false }
@@ -292,6 +292,9 @@ members = [
     "gix-traverse/tests",
 ]
 
+[workspace.dependencies]
+prodash = { version = "26.2.0", path = "../prodash", default-features = false }
+
 [package.metadata.docs.rs]
 features = ["document-features", "max"]
 rustdoc-args = ["--cfg", "docsrs"]

Cargo.toml

@@ -129,7 +129,7 @@ crc32fast = { version = "1.2.1", optional = true }
 sha1 = { version = "0.10.0", optional = true }
 
 # progress
-prodash = { version = "26.2.0", optional = true, default-features = false }
+prodash = { workspace = true, optional = true }
 bytesize = { version = "1.0.1", optional = true }
 
 # pipe

gix-features/Cargo.toml

@@ -9,7 +9,8 @@ pub use prodash::{
     progress::{
         AtomicStep, Discard, DoOrDiscard, Either, Id, Step, StepShared, Task, ThroughputOnDrop, Value, UNKNOWN,
     },
-    unit, Count, DynNestedProgress, NestedProgress, Progress, Unit,
+    unit, BoxedDynNestedProgress, Count, DynNestedProgress, DynNestedProgressToNestedProgress, NestedProgress,
+    Progress, Unit,
 };
 /// A stub for the portions of the `bytesize` crate that we use internally in `gitoxide`.
 #[cfg(not(feature = "progress-unit-bytes"))]

gix-features/src/progress.rs

@@ -243,7 +243,7 @@ gix-protocol = { version = "^0.39.0", path = "../gix-protocol", optional = true
 gix-transport = { version = "^0.36.0", path = "../gix-transport", optional = true }
 
 # Just to get the progress-tree feature
-prodash = { version = "26.2", optional = true, default-features = false, features = ["progress-tree"] }
+prodash = { workspace = true, optional = true, features = ["progress-tree"] }
 once_cell = "1.14.0"
 signal-hook = { version = "0.3.9", default-features = false, optional = true }
 thiserror = "1.0.26"

gix/Cargo.toml

@@ -1,4 +1,4 @@
-use crate::clone::PrepareFetch;
+use crate::{clone::PrepareFetch, features::progress::DynNestedProgressToNestedProgress};
 
 /// The error returned by [`PrepareFetch::fetch_only()`].
 #[derive(Debug, thiserror::Error)]
@@ -58,6 +58,15 @@ impl PrepareFetch {
         P: crate::NestedProgress,
         P::SubProgress: 'static,
     {
+        self.fetch_only_inner(&mut progress, should_interrupt)
+    }
+
+    #[gix_protocol::maybe_async::maybe_async]
+    async fn fetch_only_inner(
+        &mut self,
+        progress: &mut dyn crate::DynNestedProgress,
+        should_interrupt: &std::sync::atomic::AtomicBool,
+    ) -> Result<(crate::Repository, crate::remote::fetch::Outcome), Error> {
         use crate::{bstr::ByteVec, remote, remote::fetch::RefLogMessage};
 
         let repo = self
@@ -134,7 +143,7 @@ impl PrepareFetch {
                 message: reflog_message.clone(),
             })
             .with_shallow(self.shallow.clone())
-            .receive(progress, should_interrupt)
+            .receive(DynNestedProgressToNestedProgress(progress), should_interrupt)
             .await?;
 
         util::append_config_to_repo_config(repo, config);

gix/src/clone/fetch/mod.rs

@@ -87,7 +87,7 @@ pub use gix_features as features;
 use gix_features::threading::OwnShared;
 pub use gix_features::{
     parallel,
-    progress::{Count, NestedProgress, Progress},
+    progress::{Count, DynNestedProgress, NestedProgress, Progress},
     threading,
 };
 pub use gix_fs as fs;