Support cmd.Cancel

.github/workflows/ci.yml

@@ -10,39 +10,33 @@ jobs:
   linux:
     name: Test on Linux
     runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        go_version: [1.17]
     steps:
-      - name: Set up Go ${{ matrix.go_version }}
-        uses: actions/setup-go@v2
-        with:
-          go-version: ${{ matrix.go_version }}
-
       - name: Check out source code
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version-file: go.mod
 
       - name: Run tests
         run: make ci
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Run octocov
-        uses: k1LoW/octocov-action@v0
+        uses: k1LoW/octocov-action@v1
   windows:
     name: Test on Windows
     runs-on: windows-latest
-    strategy:
-      matrix:
-        go_version: [1.17]
     steps:
-      - name: Set up Go ${{ matrix.go_version }}
-        uses: actions/setup-go@v2
-        with:
-          go-version: ${{ matrix.go_version }}
-
       - name: Check out source code
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version-file: go.mod
 
       - name: Run tests
         run: make ci

Makefile

@@ -11,9 +11,9 @@ sec:
 	gosec ./...
 
 depsdev:
-	go install github.com/Songmu/ghch/cmd/ghch@v0.10.2
-	go install github.com/Songmu/gocredits/cmd/gocredits@v0.2.0
-	go install github.com/securego/gosec/v2/cmd/gosec@v2.8.1
+	go install github.com/Songmu/ghch/cmd/ghch@latest
+	go install github.com/Songmu/gocredits/cmd/gocredits@latest
+	go install github.com/securego/gosec/v2/cmd/gosec@latest
 
 prerelease:
 	ghch -w -N ${VER}

exec.go

@@ -19,15 +19,10 @@ func (e *Exec) CommandContext(ctx context.Context, name string, arg ...string) *
 	if e.Signal == nil {
 		e.Signal = defaultSignal
 	}
-	cmd := command(name, arg...)
-	go func() {
-		<-ctx.Done()
-		err := terminate(cmd, e.Signal)
-		if err != nil {
-			// :thinking:
-			return
-		}
-	}()
+	cmd := commandContext(ctx, name, arg...)
+	cmd.Cancel = func() error {
+		return terminate(cmd, e.Signal)
+	}
 	return cmd
 }
 

exec_test.go

@@ -195,6 +195,43 @@ func TestKillCommand(t *testing.T) {
 	}
 }
 
+func TestCommandCancel(t *testing.T) {
+	tests := gentests(true)
+	for _, tt := range tests {
+		t.Run(fmt.Sprintf("%v", tt.cmd), func(t *testing.T) {
+			_ = killprocess()
+			if checkprocess() {
+				t.Fatal("the process has not exited")
+			}
+
+			var (
+				stdout bytes.Buffer
+				stderr bytes.Buffer
+			)
+			ctx, cancel := context.WithCancel(context.Background())
+			t.Cleanup(cancel)
+			cmd := CommandContext(ctx, tt.cmd[0], tt.cmd[1:]...)
+			cmd.Stdout = &stdout
+			cmd.Stderr = &stderr
+			err := cmd.Start()
+			if err != nil {
+				t.Fatalf("%v: %v", tt.cmd, err)
+			}
+			go func() {
+				cmd.Wait()
+			}()
+			if !checkprocess() && !tt.processFinished {
+				t.Errorf("%v: %s", tt.cmd, "the process has been exited")
+			}
+			_ = cmd.Cancel()
+
+			if checkprocess() {
+				t.Errorf("%v: %s", tt.cmd, "the process has not exited")
+			}
+		})
+	}
+}
+
 type testcase struct {
 	name            string
 	cmd             []string
@@ -213,6 +250,7 @@ func checkprocess() bool {
 	} else {
 		out, err = exec.Command("bash", "-c", "ps aux | grep stubcmd | grep -v grep").Output()
 	}
+
 	return (err == nil || strings.TrimRight(string(out), "\n\r") != "")
 }
 
@@ -224,8 +262,9 @@ func killprocess() error {
 	if runtime.GOOS == "windows" {
 		out, err = exec.Command("taskkill", "/im", "stubcmd.exe").Output()
 	} else {
-		out, err = exec.Command("bash", "-c", "ps aux | grep stubcmd | grep -v grep | xargs kill").Output()
+		out, err = exec.Command("bash", "-c", "ps aux | grep stubcmd | grep -v grep | xargs kill -9").Output()
 	}
+
 	if err != nil {
 		if strings.TrimRight(string(out), "\n\r") != "" {
 			_, _ = fmt.Fprintf(os.Stderr, "%s", string(out))

exec_unix.go

@@ -1,8 +1,10 @@
+//go:build !windows
 // +build !windows
 
 package exec
 
 import (
+	"context"
 	"os"
 	"os/exec"
 	"syscall"
@@ -21,6 +23,15 @@ func command(name string, arg ...string) *exec.Cmd {
 	return cmd
 }
 
+func commandContext(ctx context.Context, name string, arg ...string) *exec.Cmd {
+	cmd := exec.CommandContext(ctx, name, arg...) // #nosec
+	if cmd.SysProcAttr == nil {
+		cmd.SysProcAttr = &syscall.SysProcAttr{}
+	}
+	cmd.SysProcAttr.Setpgid = true // force setpgid
+	return cmd
+}
+
 func terminate(cmd *exec.Cmd, sig os.Signal) error {
 	syssig, ok := sig.(syscall.Signal)
 	if !ok {
@@ -31,7 +42,7 @@ func terminate(cmd *exec.Cmd, sig os.Signal) error {
 	}
 	err := syscall.Kill(-cmd.Process.Pid, syssig)
 	if err != nil {
-		return syscall.Kill(cmd.Process.Pid, syssig) // fallback
+		return cmd.Process.Signal(syssig) // fallback
 	}
 	if syssig != syscall.SIGKILL && syssig != syscall.SIGCONT {
 		_ = syscall.Kill(-cmd.Process.Pid, syscall.SIGCONT)

exec_windows.go

@@ -1,6 +1,7 @@
 package exec
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"os"
@@ -25,6 +26,16 @@ func command(name string, arg ...string) *exec.Cmd {
 	return cmd
 }
 
+func commandContext(ctx context.Context, name string, arg ...string) *exec.Cmd {
+	// #nosec
+	cmd := exec.CommandContext(ctx, name, arg...)
+	if cmd.SysProcAttr == nil {
+		cmd.SysProcAttr = &syscall.SysProcAttr{}
+	}
+	cmd.SysProcAttr.CreationFlags = syscall.CREATE_UNICODE_ENVIRONMENT | 0x00000200
+	return cmd
+}
+
 func terminate(cmd *exec.Cmd, sig os.Signal) error {
 	return killall(cmd) // fallback
 }

go.mod

@@ -1,3 +1,3 @@
 module github.com/k1LoW/exec
 
-go 1.12
+go 1.22