Run remote Topgrades in Tmux

src/executor.rs

@@ -37,7 +37,6 @@ impl RunType {
         }
     }
 
-    #[cfg(feature = "self-update")]
     /// Tells whether we're performing a dry run.
     pub fn dry(self) -> bool {
         match self {

src/main.rs

@@ -136,7 +136,7 @@ fn run() -> Result<(), Error> {
             execute(
                 &mut report,
                 remote_topgrade,
-                || generic::run_remote_topgrade(run_type, remote_topgrade),
+                || generic::run_remote_topgrade(run_type, remote_topgrade, config.run_in_tmux()),
                 config.no_retry(),
             )?;
         }

src/steps/generic.rs

@@ -137,9 +137,18 @@ pub fn run_composer_update(base_dirs: &BaseDirs, run_type: RunType) -> Result<()
     Ok(())
 }
 
-pub fn run_remote_topgrade(run_type: RunType, hostname: &str) -> Result<(), Error> {
+pub fn run_remote_topgrade(run_type: RunType, hostname: &str, run_in_tmux: bool) -> Result<(), Error> {
     let ssh = utils::require("ssh")?;
 
+    if run_in_tmux && !run_type.dry() {
+        #[cfg(unix)]
+        {
+            crate::tmux::run_remote_topgrade(hostname, &ssh)?;
+            Err(ErrorKind::SkipStep)?
+        }
+
+        unreachable!("Tmux execution is only implemented in Unix");
+    } else {
         run_type
             .execute(&ssh)
             .args(&[
@@ -151,3 +160,4 @@ pub fn run_remote_topgrade(run_type: RunType, hostname: &str) -> Result<(), Erro
             ])
             .check_run()
     }
+}

src/steps/tmux.rs

@@ -82,3 +82,19 @@ pub fn run_in_tmux() -> ! {
         exit(0);
     }
 }
+
+pub fn run_remote_topgrade(hostname: &str, ssh: &Path) -> Result<(), Error> {
+    let command = format!(
+        "{ssh} -t {hostname} env TOPGRADE_PREFIX={hostname} topgrade",
+        ssh = ssh.display(),
+        hostname = hostname
+    );
+    Command::new(which("tmux").unwrap())
+        .args(&["new-window", "-a", "-t", "topgrade:1", "-n", hostname, &command])
+        .env_remove("TMUX")
+        .spawn()
+        .context(ErrorKind::ProcessExecution)?
+        .wait()
+        .context(ErrorKind::ProcessExecution)?
+        .check()
+}