Basic window support in subprocess mode

cmd/pplog/main.go

@@ -110,59 +110,6 @@ func prepareFormatters() (func([]slogtotext.Pair) error, func([]slogtotext.Pair)
 	return slogtotext.MustFormatter(os.Stdout, logLine), slogtotext.MustFormatter(os.Stdout, errLine)
 }
 
-func runSubprocessMode() {
-	deb("run subprocess mode")
-
-	target := flag.Args()
-	binary, err := exec.LookPath(target[0])
-	if err != nil {
-		panic(err)
-	}
-
-	r, w, err := os.Pipe()
-	if err != nil {
-		panic(err)
-	}
-
-	chFiles := make([]uintptr, 3) // in, out, err
-	chFiles[0] = r.Fd()
-	chFiles[1] = os.Stdout.Fd()
-	chFiles[2] = os.Stderr.Fd()
-
-	selfBinaty, err := exec.LookPath(os.Args[0])
-	if err != nil {
-		panic(err)
-	}
-	cwd, err := os.Getwd()
-	if err != nil {
-		panic(err)
-	}
-	pid, err := syscall.ForkExec(selfBinaty, os.Args[:1], &syscall.ProcAttr{
-		Dir:   cwd,
-		Env:   os.Environ(),
-		Files: chFiles,
-		Sys:   nil,
-	})
-	if err != nil {
-		panic(selfBinaty + ": " + err.Error())
-	}
-	deb(fmt.Sprintf("subprocess pid: %d", pid))
-
-	err = syscall.Dup2(int(w.Fd()), syscall.Stdout) // os.Stdout = w
-	if err != nil {
-		panic(err)
-	}
-	err = syscall.Dup2(int(w.Fd()), syscall.Stderr) // os.Stderr = w
-	if err != nil {
-		panic(err)
-	}
-
-	err = syscall.Exec(binary, target, os.Environ())
-	if err != nil {
-		panic(binary + ": " + err.Error())
-	}
-}
-
 func runPipeMode() {
 	deb("run pipe mode")
 	f, g := prepareFormatters()

cmd/pplog/run.go

@@ -0,0 +1,65 @@
+//go:build !windows
+// +build !windows
+
+package main
+
+import (
+	"flag"
+	"fmt"
+	"os"
+	"os/exec"
+	"syscall"
+)
+
+func runSubprocessMode() {
+	deb("run subprocess mode")
+
+	target := flag.Args()
+	binary, err := exec.LookPath(target[0])
+	if err != nil {
+		panic(err)
+	}
+
+	r, w, err := os.Pipe()
+	if err != nil {
+		panic(err)
+	}
+
+	chFiles := make([]uintptr, 3) //nolint:mnd // in, out, err
+	chFiles[0] = r.Fd()
+	chFiles[1] = os.Stdout.Fd()
+	chFiles[2] = os.Stderr.Fd()
+
+	selfBinaty, err := exec.LookPath(os.Args[0])
+	if err != nil {
+		panic(err)
+	}
+	cwd, err := os.Getwd()
+	if err != nil {
+		panic(err)
+	}
+	pid, err := syscall.ForkExec(selfBinaty, os.Args[:1], &syscall.ProcAttr{
+		Dir:   cwd,
+		Env:   os.Environ(),
+		Files: chFiles,
+		Sys:   nil,
+	})
+	if err != nil {
+		panic(selfBinaty + ": " + err.Error())
+	}
+	deb(fmt.Sprintf("subprocess pid: %d", pid))
+
+	err = syscall.Dup2(int(w.Fd()), syscall.Stdout) // os.Stdout = w
+	if err != nil {
+		panic(err)
+	}
+	err = syscall.Dup2(int(w.Fd()), syscall.Stderr) // os.Stderr = w
+	if err != nil {
+		panic(err)
+	}
+
+	err = syscall.Exec(binary, target, os.Environ())
+	if err != nil {
+		panic(binary + ": " + err.Error())
+	}
+}

cmd/pplog/run_windows.go

@@ -0,0 +1,50 @@
+//go:build windows
+// +build windows
+
+package main
+
+import (
+	"context"
+	"flag"
+	"io"
+	"os"
+	"os/exec"
+
+	"github.com/michurin/human-readable-json-logging/slogtotext"
+)
+
+func runSubprocessMode() {
+	deb("run subprocess mode (windows)")
+
+	ctx := context.Background()
+
+	rd, wr := io.Pipe()
+
+	f, g := prepareFormatters()
+	go func() {
+		err := slogtotext.Read(rd, f, g, 32768)
+		if err != nil {
+			deb("reader is finished with err: " + err.Error())
+			return
+		}
+		deb("reader is finished")
+	}()
+
+	args := flag.Args()[1:]
+	command := flag.Args()[0]
+
+	cmd := exec.CommandContext(ctx, command, args...)
+	cmd.Stdout = wr
+	cmd.Stderr = wr
+
+	err := cmd.Run()
+	deb("subprocess is finished")
+	if err != nil {
+		printError(err)
+	}
+	exitCode := cmd.ProcessState.ExitCode() // exit code can be set even if error
+	if exitCode < 0 {
+		exitCode = 1
+	}
+	os.Exit(exitCode)
+}