cleaning up old integration tests

1 files changed, 0 insertions, 154 deletions

diff --git a/integrationtests-old/commandutils.go b/integrationtests-old/commandutils.go
deleted file mode 100644
index 8d81955..0000000
--- a/integrationtests-old/commandutils.go
+++ /dev/null
@@ -1,154 +0,0 @@
-package integrationtests
-
-import (
-	"bufio"
-	"context"
-	"fmt"
-	"io"
-	"os"
-	"os/exec"
-	"strings"
-	"syscall"
-	"testing"
-	"time"
-)
-
-func runCommand(ctx context.Context, t *testing.T, stdoutFile, cmdStr string,
-	args ...string) (int, error) {
-
-	if _, err := os.Stat(cmdStr); err != nil {
-		return 0, fmt.Errorf("no such executable '%s', please compile first: %w", cmdStr, err)
-	}
-
-	t.Log("Creating stdout file", stdoutFile)
-	fd, err := os.Create(stdoutFile)
-	if err != nil {
-		return 0, nil
-	}
-	defer fd.Close()
-
-	t.Log("Running command", cmdStr, strings.Join(args, " "))
-	cmd := exec.CommandContext(ctx, cmdStr, args...)
-	out, err := cmd.CombinedOutput()
-	t.Log("Done running command!", err)
-	_, _ = fd.Write(out)
-
-	return exitCodeFromError(err), err
-}
-
-func runCommandRetry(ctx context.Context, t *testing.T, retries int, stdoutFile,
-	cmd string, args ...string) (exitCode int, err error) {
-
-	for i := 0; i < retries; i++ {
-		time.Sleep(time.Second)
-		if exitCode, err = runCommand(ctx, t, stdoutFile, cmd, args...); exitCode == 0 {
-			return
-		}
-	}
-	return
-}
-
-func startCommand(ctx context.Context, t *testing.T, inPipeFile,
-	cmdStr string, args ...string) (<-chan string, <-chan string, <-chan error, error) {
-
-	stdoutCh := make(chan string)
-	stderrCh := make(chan string)
-
-	if _, err := os.Stat(cmdStr); err != nil {
-		return stdoutCh, stderrCh, nil,
-			fmt.Errorf("no such executable '%s', please compile first: %w", cmdStr, err)
-	}
-
-	t.Log(cmdStr, strings.Join(args, " "))
-	cmd := exec.CommandContext(ctx, cmdStr, args...)
-
-	var stdinPipe io.WriteCloser
-	if inPipeFile != "" {
-		var err error
-		stdinPipe, err = cmd.StdinPipe()
-		if err != nil {
-			return stdoutCh, stderrCh, nil, err
-		}
-	}
-	cmdStdout, err := cmd.StdoutPipe()
-	if err != nil {
-		return stdoutCh, stderrCh, nil, err
-	}
-	cmdStderr, err := cmd.StderrPipe()
-	if err != nil {
-		return stdoutCh, stderrCh, nil, err
-	}
-	err = cmd.Start()
-	if err != nil {
-		return stdoutCh, stderrCh, nil, err
-	}
-
-	// Read input file and send to stdin pipe?
-	if inPipeFile != "" {
-		t.Logf("Piping %s to stdin pipe", inPipeFile)
-		fd, err := os.Open(inPipeFile)
-		if err != nil {
-			return stdoutCh, stderrCh, nil, err
-		}
-		go func() {
-			_, _ = io.Copy(stdinPipe, bufio.NewReader(fd))
-			stdinPipe.Close()
-			fd.Close()
-		}()
-	}
-
-	go func() {
-		scanner := bufio.NewScanner(cmdStdout)
-		scanner.Split(bufio.ScanLines)
-		for scanner.Scan() {
-			stdoutCh <- scanner.Text()
-		}
-	}()
-	go func() {
-		scanner := bufio.NewScanner(cmdStderr)
-		scanner.Split(bufio.ScanLines)
-		for scanner.Scan() {
-			stderrCh <- scanner.Text()
-		}
-		close(stderrCh)
-	}()
-
-	cmdErrCh := make(chan error)
-	go func() {
-		cmdErrCh <- cmd.Wait()
-	}()
-
-	return stdoutCh, stderrCh, cmdErrCh, nil
-}
-
-func waitForCommand(ctx context.Context, t *testing.T,
-	stdoutCh, stderrCh <-chan string, cmdErrCh <-chan error) {
-
-	for {
-		select {
-		case line, ok := <-stdoutCh:
-			if ok {
-				t.Log(line)
-			}
-		case line, ok := <-stderrCh:
-			if ok {
-				t.Log(line)
-			}
-		case cmdErr := <-cmdErrCh:
-			t.Logf("Command finished with with exit code %d: %v",
-				exitCodeFromError(cmdErr), cmdErr)
-			return
-		}
-	}
-}
-
-func exitCodeFromError(err error) int {
-	if err == nil {
-		return 0
-	}
-	if exitError, ok := err.(*exec.ExitError); ok {
-		ws := exitError.Sys().(syscall.WaitStatus)
-		return ws.ExitStatus()
-	}
-	panic(fmt.Errorf("Unable to get process exit code from error: %w", err))
-}