Function runCommand

utils.go:89–165

TODO: see if this can be cleaned up.

( //nolint:funlen
	log *zerolog.Logger,
	cwd string,
	session ssh.Session,
	args []string,
	environ []string,
)

// TODO: see if this can be cleaned up.
func runCommand( //nolint:funlen
	log *zerolog.Logger,
	cwd string,
	session ssh.Session,
	args []string,
	environ []string,
) int {
	// NOTE: we are explicitly ignoring gosec here because we *only* pass in
	// known commands here.
	cmd := exec.Command(args[0], args[1:]...) //nolint:gosec
	cmd.Dir = cwd

	cmd.Env = append(cmd.Env, environ...)
	cmd.Env = append(cmd.Env, "PATH="+os.Getenv("PATH"))

	stdin, err := cmd.StdinPipe()
	if err != nil {
		log.Error().Err(err).Msg("Failed to get stdin pipe")
		return 1
	}

	stdout, err := cmd.StdoutPipe()
	if err != nil {
		log.Error().Err(err).Msg("Failed to get stdout pipe")
		return 1
	}

	stderr, err := cmd.StderrPipe()
	if err != nil {
		log.Error().Err(err).Msg("Failed to get stderr pipe")
		return 1
	}

	wg := &sync.WaitGroup{}
	wg.Add(2)

	if err = cmd.Start(); err != nil {
		log.Error().Err(err).Msg("Failed to start command")
		return 1
	}

	go func() {
		defer stdin.Close()

		if _, stdinErr := io.Copy(stdin, session); stdinErr != nil {
			log.Error().Err(err).Msg("Failed to write session to stdin")
		}
	}()

	go func() {
		defer wg.Done()

		if _, stdoutErr := io.Copy(session, stdout); stdoutErr != nil {
			log.Error().Err(err).Msg("Failed to write stdout to session")
		}
	}()

	go func() {