Support cross workspace amend

Change: ws-amend

Author: christian-schilling

Cargo.lock

@@ -37,7 +37,7 @@ tempfile = "3.10.1"
 
 [workspace.dependencies.git2]
 default-features = false
-version = "0.19"
+version = "0.18.3"
 
 [workspace.dependencies.juniper]
 version = "0.15.11"

Cargo.toml

@@ -9,7 +9,7 @@ history, taking a filter specification as argument.
 
 It can be installed with the following Cargo command, assuming Rust is installed:
 ```shell
-cargo install josh-filter --git https://github.com/josh-project/josh.git
+cargo install josh --git https://github.com/josh-project/josh.git
 ```
 
 git-sync

docs/src/reference/cli.md

@@ -1,7 +1,7 @@
 use super::*;
 use std::collections::HashMap;
 
-const CACHE_VERSION: u64 = 20;
+const CACHE_VERSION: u64 = 19;
 
 lazy_static! {
     static ref DB: std::sync::Mutex<Option<sled::Db>> = std::sync::Mutex::new(None);

josh-core/src/cache.rs

@@ -441,7 +441,22 @@ pub fn unapply_filter(
         let tree = module_commit.tree()?;
         let commit_message = module_commit.summary().unwrap_or("NO COMMIT MESSAGE");
 
-        let new_trees: JoshResult<Vec<_>> = {
+        let mut nt = None;
+        if let Some(change_ids) = change_ids {
+            for c in change_ids.iter() {
+                let cid = get_change_id(&module_commit, ret);
+
+                if c.id == cid.id {
+                    let x = transaction.repo().find_commit(c.commit)?;
+                    nt = Some(filter::unapply(transaction, filter, tree.clone(), x.tree()?)?.id());
+                    break;
+                }
+            }
+        }
+
+        let new_trees: JoshResult<Vec<_>> = if let Some(nt) = nt {
+            Ok(vec![nt])
+        } else {
             let span = tracing::span!(
                 tracing::Level::TRACE,
                 "unapply filter",

josh-core/src/history.rs

@@ -38,7 +38,7 @@ pub struct Change {
 }
 
 impl Change {
-    fn new(commit: git2::Oid) -> Self {
+    pub fn new(commit: git2::Oid) -> Self {
         Self {
             author: Default::default(),
             id: Default::default(),

josh-core/src/lib.rs

@@ -1185,9 +1185,7 @@ async fn call_service(
         while path.contains("//") {
             path = path.replace("//", "/");
         }
-        percent_encoding::percent_decode_str(&path)
-            .decode_utf8_lossy()
-            .to_string()
+        path
     };
 
     if let Some(resource_path) = path.strip_prefix("/~/ui") {

josh-proxy/src/bin/josh-proxy.rs

@@ -259,6 +259,14 @@ pub fn process_repo_update(repo_update: RepoUpdate) -> josh::JoshResult<String>
                 None
             };
 
+        if changes.is_some() && push_mode == PushMode::Review {
+            changes = Some(refs_to_changes(
+                &transaction_mirror,
+                &baseref.replacen("refs/heads/", "", 1),
+                &author,
+            ));
+        }
+
         let filter = josh::filter::parse(&repo_update.filter_spec)?;
         let new_oid = git2::Oid::from_str(new)?;
         let backward_new_oid = {
@@ -868,6 +876,38 @@ impl Drop for TmpGitNamespace {
     }
 }
 
+fn refs_to_changes(
+    transaction: &josh::cache::Transaction,
+    baseref: &str,
+    change_author: &str,
+) -> Vec<josh::Change> {
+    let mut changes = vec![];
+    let glob = transaction.refname(&format!(
+        "refs/heads/@changes/{}/{}/*",
+        baseref, change_author
+    ));
+
+    for r in transaction.repo().references_glob(&glob).unwrap() {
+        let r = r.unwrap();
+        let mut change = josh::Change::new(r.target().unwrap());
+        change.author = change_author.to_string();
+
+        let id = r.name().unwrap().replacen(
+            &transaction.refname(&format!(
+                "refs/heads/@changes/{}/{}/",
+                baseref, change_author
+            )),
+            "",
+            1,
+        );
+        change.id = Some(id);
+
+        changes.push(change);
+    }
+
+    return changes;
+}
+
 fn changes_to_refs(
     baseref: &str,
     change_author: &str,
@@ -887,12 +927,12 @@ fn changes_to_refs(
             if id.contains('@') {
                 return Err(josh::josh_error("Change id must not contain '@'"));
             }
-            if seen.contains(&id) {
-                return Err(josh::josh_error(&format!(
-                    "rejecting to push {:?} with duplicate label",
-                    change.commit
-                )));
-            }
+            //if seen.contains(&id) {
+            //    return Err(josh::josh_error(&format!(
+            //        "rejecting to push {:?} with duplicate label",
+            //        change.commit
+            //    )));
+            //}
             seen.push(id);
         } else {
             return Err(josh::josh_error(&format!(

josh-proxy/src/lib.rs

@@ -124,7 +124,7 @@
   ]
   .
   |-- josh
-  |   `-- 20
+  |   `-- 19
   |       `-- sled
   |           |-- blobs
   |           |-- conf

tests/proxy/amend_patchset.t

@@ -124,7 +124,7 @@
   "real_repo.git" = ["::sub1/"]
   .
   |-- josh
-  |   `-- 20
+  |   `-- 19
   |       `-- sled
   |           |-- blobs
   |           |-- conf