summaryrefslogtreecommitdiff
path: root/internal/pipeline
diff options
context:
space:
mode:
Diffstat (limited to 'internal/pipeline')
-rw-r--r--internal/pipeline/pipeline_test.go36
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)
}