wip poc for fetching all branches

Author: Stephan Dilly

Cargo.lock

@@ -13,8 +13,8 @@ keywords = ["git"]
 
 [dependencies]
 scopetime = { path = "../scopetime", version = "0.1" }
-git2 = "0.13"
-# git2 = { path = "../../extern/git2-rs", features = ["vendored-openssl"]}
+# git2 = "0.13"
+git2 = { path = "../../extern/git2-rs", features = ["vendored-openssl"]}
 # git2 = { git="https://github.com/extrawurst/git2-rs.git", rev="fc13dcc", features = ["vendored-openssl"]}
 # pinning to vendored openssl, using the git2 feature this gets lost with new resolver
 openssl-sys = { version = '0.9', features= ["vendored"] }

asyncgit/Cargo.toml

@@ -2,7 +2,7 @@ use crate::{
 	error::{Error, Result},
 	sync::{
 		cred::BasicAuthCredential,
-		remotes::{fetch, push::ProgressNotification},
+		remotes::{fetch, fetch_all, push::ProgressNotification},
 	},
 	AsyncGitNotification, RemoteProgress, CWD,
 };
@@ -90,6 +90,14 @@ impl AsyncFetch {
 				arc_progress,
 			);
 
+			fetch_all(
+				CWD,
+				"origin",
+				params.basic_credential.clone(),
+				Some(progress_sender.clone()),
+			)
+			.expect("");
+
 			let res = fetch(
 				CWD,
 				&params.branch,

asyncgit/src/fetch.rs

@@ -75,14 +75,39 @@ pub(crate) fn get_default_remote_in_repo(
 	Err(Error::NoDefaultRemoteFound)
 }
 
+///
+pub fn fetch_all(
+	repo_path: &str,
+	remote: &str,
+	basic_credential: Option<BasicAuthCredential>,
+	progress_sender: Option<Sender<ProgressNotification>>,
+) -> Result<()> {
+	scope_time!("fetch_all");
+
+	let repo = utils::repo(repo_path)?;
+
+	let mut remote = repo.find_remote(remote)?;
+
+	let mut options = FetchOptions::new();
+	let callbacks = Callbacks::new(
+		progress_sender.clone(),
+		basic_credential.clone(),
+	);
+	options.prune(git2::FetchPrune::On);
+	options.remote_callbacks(callbacks.callbacks());
+	remote.fetch_all(Some(&mut options), None)?;
+
+	Ok(())
+}
+
 /// fetches from upstream/remote for `branch`
 pub(crate) fn fetch(
 	repo_path: &str,
 	branch: &str,
 	basic_credential: Option<BasicAuthCredential>,
 	progress_sender: Option<Sender<ProgressNotification>>,
 ) -> Result<usize> {
-	scope_time!("fetch_origin");
+	scope_time!("fetch");
 
 	let repo = utils::repo(repo_path)?;
 	let branch_ref = repo
@@ -97,6 +122,8 @@ pub(crate) fn fetch(
 	let callbacks = Callbacks::new(progress_sender, basic_credential);
 	options.remote_callbacks(callbacks.callbacks());
 
+	log::debug!("fetch: {}", branch);
+
 	remote.fetch(&[branch], Some(&mut options), None)?;
 
 	Ok(remote.stats().received_bytes())