diff options
Diffstat (limited to 'internal/pipeline')
| -rw-r--r-- | internal/pipeline/pipeline_test.go | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/internal/pipeline/pipeline_test.go b/internal/pipeline/pipeline_test.go index 806f9be..4a08d3b 100644 --- a/internal/pipeline/pipeline_test.go +++ b/internal/pipeline/pipeline_test.go @@ -36,7 +36,7 @@ type PipelineTester interface { type connection struct { name string - c PipelineTester + c PipelineTester } // Test_download tests the download() function inside the pipeline @@ -53,11 +53,11 @@ func Test_download(t *testing.T) { } cases := []struct { - dl string + dl string contents []byte - process string - errs []error - } { + process string + errs []error + }{ {"notpresent", []byte(""), "", []error{errors.New("no such file or directory"), errors.New("NoSuchKey: The specified key does not exist")}}, {"empty", []byte{}, "empty", []error{}}, {"justastring", []byte("I am just a basic string"), "justastring", []error{}}, @@ -73,7 +73,7 @@ func Test_download(t *testing.T) { slog.log = "" tempDir := filepath.Join(os.TempDir(), "pipelinetest") err = os.MkdirAll(tempDir, 0700) - if err != nil && ! os.IsExist(err) { + if err != nil && !os.IsExist(err) { t.Fatalf("Could not create temporary directory %s: %v\nLog: %s", tempDir, err, slog.log) } @@ -174,11 +174,11 @@ func Test_up(t *testing.T) { } cases := []struct { - ul string + ul string contents []byte - process string - errs []error - } { + process string + errs []error + }{ {"notpresent", []byte(""), "", []error{errors.New("no such file or directory"), errors.New("NoSuchKey: The specified key does not exist")}}, {"empty", []byte{}, "empty", []error{}}, {"justastring", []byte("I am just a basic string"), "justastring", []error{}}, @@ -194,7 +194,7 @@ func Test_up(t *testing.T) { slog.log = "" tempDir := filepath.Join(os.TempDir(), "pipelinetest") err = os.MkdirAll(tempDir, 0700) - if err != nil && ! os.IsExist(err) { + if err != nil && !os.IsExist(err) { t.Fatalf("Could not create temporary directory %s: %v\nLog: %s", tempDir, err, slog.log) } @@ -244,7 +244,7 @@ func Test_up(t *testing.T) { t.Fatalf("Uploaded file not removed as it should have been after uploading %s: %v\nLog: %s", tempFile, err, slog.log) } - err = conn.c.Download(conn.c.WIPStorageId(), "pipelinetest/" + c.ul, tempFile) + err = conn.c.Download(conn.c.WIPStorageId(), "pipelinetest/"+c.ul, tempFile) if err != nil { t.Fatalf("Could not download file %s: %v\nLog: %s", tempFile, err, slog.log) } @@ -292,11 +292,11 @@ func Test_upAndQueue(t *testing.T) { } cases := []struct { - ul string + ul string contents []byte - process string - errs []error - } { + process string + errs []error + }{ {"notpresent", []byte(""), "", []error{errors.New("no such file or directory"), errors.New("NoSuchKey: The specified key does not exist")}}, {"empty", []byte{}, "empty", []error{}}, {"justastring", []byte("I am just a basic string"), "justastring", []error{}}, @@ -312,7 +312,7 @@ func Test_upAndQueue(t *testing.T) { slog.log = "" tempDir := filepath.Join(os.TempDir(), "pipelinetest") err = os.MkdirAll(tempDir, 0700) - if err != nil && ! os.IsExist(err) { + if err != nil && !os.IsExist(err) { t.Fatalf("Could not create temporary directory %s: %v\nLog: %s", tempDir, err, slog.log) } @@ -376,7 +376,7 @@ func Test_upAndQueue(t *testing.T) { t.Fatalf("Uploaded file not removed as it should have been after uploading %s: %v\nLog: %s", tempFile, err, slog.log) } - err = conn.c.Download(conn.c.WIPStorageId(), "pipelinetest/" + c.ul, tempFile) + err = conn.c.Download(conn.c.WIPStorageId(), "pipelinetest/"+c.ul, tempFile) if err != nil { t.Fatalf("Could not download file %s: %v\nLog: %s", tempFile, err, slog.log) } |