adding current state

Author: gnunicorn

src/cli.rs

@@ -61,6 +61,14 @@ pub struct PackageSelectOptions {
     /// regardless, set this flag.
     #[structopt(long = "ignore-publish")]
     ignore_publish: bool,
+    /// Automatically detect the packages, which changed compared to the given git commit.
+    ///
+    /// Compares the current git `head` to the reference given, identifies which files changed
+    /// and attempts to identify the packages and its dependents through that mechanism. You
+    /// can use any `tag`, `branch` or `commit`, but you must be sure it is available
+    /// (and up to date) locally.
+    #[structopt(short = "c", long="changed-since")]
+    pub changed_since: String,
 }
 
 #[derive(StructOpt, Debug)]
@@ -348,6 +356,7 @@ fn make_pkg_predicate(args: PackageSelectOptions) -> Result<Box<dyn Fn(&Package)
         skip,
         ignore_pre_version,
         ignore_publish,
+        changed_since,
     } = args;
 
     if !packages.is_empty() {
@@ -357,8 +366,24 @@ fn make_pkg_predicate(args: PackageSelectOptions) -> Result<Box<dyn Fn(&Package)
                     .into(),
             );
         }
+        if changed_since.len() != 0 {
+            return Err(
+                "-p/--packages is mutually exlusive to using -c/--changed-since"
+                    .into(),
+            );
+        }
     }
 
+    if changed_since.len() != 0 {
+        if !skip.is_empty() || !ignore_pre_version.is_empty() {
+            return Err(
+                "-c/--changed-since is mutually exlusive to using -s/--skip and -i/--ignore-version-pre"
+                    .into(),
+            );
+        }
+    }
+
+
     let publish = move |p: &Package| {
         let publ = if ignore_publish {
             true
@@ -371,6 +396,8 @@ fn make_pkg_predicate(args: PackageSelectOptions) -> Result<Box<dyn Fn(&Package)
         publ
     };
 
+
+
     if !packages.is_empty() {
         trace!("going for matching against {:?}", packages);
         return Ok(Box::new(move |p: &Package| {

src/util.rs

@@ -8,7 +8,48 @@ use serde::Deserialize;
 use std::{collections::HashMap, error::Error, fs, time::Duration};
 use tokio::runtime::Runtime;
 use toml_edit::{Document, InlineTable, Item, Table, Value};
+use petgraph::Graph;
+use git2::{Repository};
 
+pub fn changed_packages<'a>(ws: &'a Workspace, reference: &str) -> Vec<Package> {
+    let path = ws.root();
+    let repo = Repository::open(&path).expect("Workspace isn't a git repo");
+    let current_head = repo.head()
+        .and_then(|b| b.peel_to_commit())
+        .and_then(|c| c.tree())
+        .expect("Could not determine current git HEAD");
+    let main = repo
+        .find_reference(reference)
+        .and_then(|d| d.peel_to_commit())
+        .and_then(|c| c.tree())
+        .expect(format!("Reference {:?} not found in git repository", reference));
+
+    let diff = repo
+        .diff_tree_to_tree(Some(&current_head), Some(&main), None)
+        .expect("Diffing failed");
+
+    let files = diff
+        .deltas()
+        .filter_map(|d| d.new_file().path().clone())
+        .filter_map(|d| if d.is_file() { d.parent() } else { Some(d) })
+        .map(|l| path.join(l))
+        .collect::<Vec<_>>();
+
+    let cfg = git2::Config::default().unwrap();
+
+    for m in members_deep(ws) {
+        let root = m.root();
+        for f in files.iter() {
+            if f.starts_with(root) {
+                println!("{:?}: {:}", f, m.name());
+                break;
+            }
+        }
+    }
+
+}
+
+// Find all members of the workspace, into the total depth
 pub fn members_deep<'a>(ws: &'a Workspace) -> Vec<Package> {
     let mut total_list = Vec::new();
     for m in ws.members() {