diff --git a/main.go b/main.go index fb6ad6f..a3132cd 100644 --- a/main.go +++ b/main.go @@ -186,10 +186,7 @@ func (job ContainerExecJob) Run() { // Maybe print output if hj.Reader != nil { - slog.Debugf("%s: Getting exec reader", job.name) for scanner.Scan() { - slog.Debugf("%s: Getting exec line", job.name) - line := scanner.Text() if len(line) > 0 { slog.Infof("%s: Exec output: %s", job.name, line) diff --git a/main_test.go b/main_test.go index 9246bdb..7aceb0f 100644 --- a/main_test.go +++ b/main_test.go @@ -1,11 +1,13 @@ package main import ( + "bufio" "errors" "fmt" "log" "reflect" "sort" + "strings" "testing" dockerTypes "github.com/docker/docker/api/types" @@ -145,7 +147,9 @@ func (fakeClient *FakeDockerClient) ContainerInspect(ctx context.Context, contai } func (fakeClient *FakeDockerClient) ContainerExecAttach(ctx context.Context, execID string, options container.ExecAttachOptions) (dockerTypes.HijackedResponse, error) { - return dockerTypes.HijackedResponse{}, nil + return dockerTypes.HijackedResponse{ + Reader: bufio.NewReader(strings.NewReader("Some output from our command")), + }, nil } // NewFakeDockerClient creates an empty client