feat: process repositories in parallel

Author: marcfrederick

CHANGELOG.md

@@ -2,7 +2,7 @@
 
 ## Unreleased
 
-Nothing Yet!
+- Process repositories in parallel
 
 ## Version 0.1.1
 

Cargo.lock

@@ -14,6 +14,7 @@ lto = "thin"
 [dependencies]
 clap = { version = "4.5.4", features = ["derive", "cargo"] }
 ignore = "0.4.22"
+rayon = "1.10.0"
 
 [workspace.metadata.dist]
 cargo-dist-version = "0.15.1"

Cargo.toml

@@ -1,18 +1,32 @@
 # git-foreach
 
-`git-foreach` is a lightweight utility designed to execute a command in each Git repository within a directory and its
+git-foreach is a lightweight utility designed to execute a command in each Git repository within a directory and its
 subdirectories. It's particularly useful for performing bulk operations, such as `git pull` or `git status`, across
 multiple repositories simultaneously.
 
 ## Usage
 
-The specified `<command>` will be executed in each Git repository found in the current directory and all its
-subdirectories.
+To use `git-foreach`, simply prepend your desired command with `git-foreach`. The command will be executed in each Git
+repository found in the current directory and all its subdirectories.
 
 ```shell
 git-foreach <command>
 ```
 
+For instance, if you want to execute git pull in each repository, you would use:
+
+```shell
+git-foreach "git pull"
+```
+
+By default, git-foreach will stop executing if the command fails in one of the repositories. If you want the execution
+to continue despite failures, you can append `|| :` to the command. This will mask the error and allows git-foreach to
+continue processing the remaining repositories.
+
+```shell
+git-foreach "git pull || :"
+```
+
 ## Installation
 
 Pre-built binaries are available for Windows, Linux, and macOS. You can download them from

README.md

@@ -5,7 +5,8 @@ use std::env;
 use std::path::PathBuf;
 
 use clap::Parser;
-use ignore::Walk;
+use ignore::{DirEntry, Walk};
+use rayon::prelude::*;
 
 use crate::error::Error;
 
@@ -41,12 +42,10 @@ fn main() {
 /// subdirectories.
 fn repository_foreach<T: Iterator<Item = String>>(args: T) -> Result<(), Error> {
     let options = parse_options(args)?;
-
-    for repository in find_repositories(&options.directory)? {
-        run_command_in_directory(&options, &repository)?;
-    }
-
-    Ok(())
+    find_repositories(&options.directory)
+        .par_iter()
+        .map(|repository| run_command_in_directory(&options, repository))
+        .collect()
 }
 
 /// Parse the command line options.
@@ -55,17 +54,11 @@ fn parse_options<T: Iterator<Item = String>>(args: T) -> Result<Options, Error>
 }
 
 /// Find all git repositories in a directory and its subdirectories.
-fn find_repositories(path: &PathBuf) -> Result<HashSet<PathBuf>, Error> {
+fn find_repositories(path: &PathBuf) -> HashSet<PathBuf> {
     Walk::new(path)
-        .filter_map(|entry| {
-            let entry = entry.ok()?;
-            let path = entry.path();
-            if path.is_dir() && path.join(".git").exists() {
-                Some(Ok(path.to_path_buf()))
-            } else {
-                None
-            }
-        })
+        .flatten()
+        .map(DirEntry::into_path)
+        .filter(|path| path.is_dir() && path.join(".git").exists())
         .collect()
 }