(t *testing.T)
| 90 | } |
| 91 | |
| 92 | func TestS3WriteFiles(t *testing.T) { |
| 93 | if *flagTestData == "" { |
| 94 | t.Skipf("testdata dir not specified, skipping test.") |
| 95 | } |
| 96 | sto, err := newFromConfig(nil, jsonconfig.Obj{ |
| 97 | "aws_access_key": *key, |
| 98 | "aws_secret_access_key": *secret, |
| 99 | "bucket": *bucket, |
| 100 | }) |
| 101 | if err != nil { |
| 102 | t.Fatalf("newFromConfig error: %v", err) |
| 103 | } |
| 104 | dir, err := os.Open(*flagTestData) |
| 105 | if err != nil { |
| 106 | t.Fatal(err) |
| 107 | } |
| 108 | defer dir.Close() |
| 109 | names, err := dir.Readdirnames(-1) |
| 110 | if err != nil { |
| 111 | t.Fatal(err) |
| 112 | } |
| 113 | for _, name := range names { |
| 114 | f, err := os.Open(filepath.Join(*flagTestData, name)) |
| 115 | if err != nil { |
| 116 | t.Fatal(err) |
| 117 | } |
| 118 | defer f.Close() // assuming there aren't that many files. |
| 119 | if _, err := schema.WriteFileFromReaderWithModTime(ctxbg, sto, name, time.Now(), f); err != nil { |
| 120 | t.Fatalf("Error while writing %v to S3: %v", name, err) |
| 121 | } |
| 122 | t.Logf("Wrote %v successfully to S3", name) |
| 123 | } |
| 124 | } |
| 125 | |
| 126 | func testStorage(t *testing.T, bucketDir string) { |
| 127 | if *bucket == "" || *key == "" || *secret == "" { |
nothing calls this directly
no test coverage detected