Fix SSHRuntime to pass abort signals to all exec() calls

Audit revealed several exec() calls in SSHRuntime that weren't respecting
abort signals even though they go through SSH:

Fixed:
- stat(): Now passes abortSignal to exec() (was ignoring it)
- syncProjectToRemote(): All exec() calls now pass abortSignal
  - git remote set-url origin
  - git remote remove origin
  - rm bundle cleanup operations
  - Bundle creation spawn() now handles abort signal
- createWorkspace(): mkdir exec() now passes abortSignal
- deleteWorkspace(): All exec() calls now pass abortSignal
  - test -d existence check
  - git diff uncommitted changes check

These operations all go through SSH and can benefit from cancellation,
especially bundle creation which can take significant time on large repos.

Author: ammar-agent

src/runtime/SSHRuntime.ts

@@ -292,13 +292,13 @@ export class SSHRuntime implements Runtime {
   /**
    * Get file statistics over SSH
    */
-  async stat(path: string, _abortSignal?: AbortSignal): Promise<FileStat> {
+  async stat(path: string, abortSignal?: AbortSignal): Promise<FileStat> {
     // Use stat with format string to get: size, mtime, type
     // %s = size, %Y = mtime (seconds since epoch), %F = file type
-    // Note: timeout is <10s so no abort signal needed per requirement
     const stream = await this.exec(`stat -c '%s %Y %F' ${shescape.quote(path)}`, {
       cwd: this.config.srcBaseDir,
-      timeout: 10, // 10 seconds - stat should be fast (no abort needed per requirement)
+      timeout: 10,
+      abortSignal,
     });
 
     const [stdout, stderr, exitCode] = await Promise.all([
@@ -519,6 +519,13 @@ export class SSHRuntime implements Runtime {
         log.debug(`Creating bundle: ${command}`);
         const proc = spawn("bash", ["-c", command]);
 
+        // Handle abort signal
+        const abortHandler = () => {
+          proc.kill();
+          reject(new Error("Bundle creation aborted"));
+        };
+        abortSignal?.addEventListener("abort", abortHandler);
+
         streamProcessToLogger(proc, initLogger, {
           logStdout: false,
           logStderr: true,
@@ -530,14 +537,18 @@ export class SSHRuntime implements Runtime {
         });
 
         proc.on("close", (code) => {
-          if (code === 0) {
+          abortSignal?.removeEventListener("abort", abortHandler);
+          if (abortSignal?.aborted) {
+            reject(new Error("Bundle creation aborted"));
+          } else if (code === 0) {
             resolve();
           } else {
             reject(new Error(`Failed to create bundle: ${stderr}`));
           }
         });
 
         proc.on("error", (err) => {
+          abortSignal?.removeEventListener("abort", abortHandler);
           reject(err);
         });
       });
@@ -588,6 +599,7 @@ export class SSHRuntime implements Runtime {
           {
             cwd: "~",
             timeout: 10,
+            abortSignal,
           }
         );
 
@@ -605,6 +617,7 @@ export class SSHRuntime implements Runtime {
           {
             cwd: "~",
             timeout: 10,
+            abortSignal,
           }
         );
         await removeOriginStream.exitCode;
@@ -615,6 +628,7 @@ export class SSHRuntime implements Runtime {
       const rmStream = await this.exec(`rm ${bundleTempPath}`, {
         cwd: "~",
         timeout: 10,
+        abortSignal,
       });
 
       const rmExitCode = await rmStream.exitCode;
@@ -629,6 +643,7 @@ export class SSHRuntime implements Runtime {
         const rmStream = await this.exec(`rm -f ${bundleTempPath}`, {
           cwd: "~",
           timeout: 10,
+          abortSignal,
         });
         await rmStream.exitCode;
       } catch {
@@ -719,7 +734,7 @@ export class SSHRuntime implements Runtime {
 
   async createWorkspace(params: WorkspaceCreationParams): Promise<WorkspaceCreationResult> {
     try {
-      const { projectPath, branchName, initLogger } = params;
+      const { projectPath, branchName, initLogger, abortSignal } = params;
       // Compute workspace path using canonical method
       const workspacePath = this.getWorkspacePath(projectPath, branchName);
 
@@ -740,6 +755,7 @@ export class SSHRuntime implements Runtime {
         const mkdirStream = await this.exec(parentDirCommand, {
           cwd: "/tmp",
           timeout: 10,
+          abortSignal,
         });
         const mkdirExitCode = await mkdirStream.exitCode;
         if (mkdirExitCode !== 0) {
@@ -923,6 +939,7 @@ export class SSHRuntime implements Runtime {
       const checkExistStream = await this.exec(`test -d ${shescape.quote(deletedPath)}`, {
         cwd: this.config.srcBaseDir,
         timeout: 10,
+        abortSignal,
       });
 
       await checkExistStream.stdin.close();
@@ -941,6 +958,7 @@ export class SSHRuntime implements Runtime {
           {
             cwd: this.config.srcBaseDir,
             timeout: 10,
+            abortSignal,
           }
         );