diff options
| -rw-r--r-- | fs_test.go | 41 | ||||
| -rw-r--r-- | testing.go | 15 |
2 files changed, 38 insertions, 18 deletions
@@ -6,11 +6,46 @@ import ( "github.com/matryer/is" ) -func TestFsInit(t *testing.T) { +func TestFsListBuckets(t *testing.T) { is := is.New(t) - fs, err := NewFs("127.0.0.1:9000", "test-bucket", "testuser", "testsecret", false) + fs, err := newTestFs() is.NoErr(err) - buckets, err := fs.listBuckets() + buckets, err := testListBuckets(fs) is.NoErr(err) is.Equal(len(buckets), 1) } + +func TestFsMkdir(t *testing.T) { + is := is.New(t) + fs, err := newTestFs() + is.NoErr(err) + err = fs.Mkdir("test", 0o644) + is.Equal(err, ErrUnsupported) +} + +func TestFsMkdirAll(t *testing.T) { + is := is.New(t) + fs, err := newTestFs() + is.NoErr(err) + err = fs.MkdirAll("test1/test2", 0o644) + is.Equal(err, ErrUnsupported) +} + +func newTestFs() (*Fs, error) { + fs, err := NewFs("127.0.0.1:9000", "test-bucket", "testuser", "testsecret", false) + return fs, err +} + +func testListBuckets(fs *Fs) ([]string, error) { + ctx, cancel := fs.contextWithTimeout() + defer cancel() + bucketInfos, err := fs.client.ListBuckets(ctx) + if err != nil { + return nil, err + } + buckets := make([]string, 0, len(bucketInfos)) + for _, bi := range bucketInfos { + buckets = append(buckets, bi.Name) + } + return buckets, nil +} diff --git a/testing.go b/testing.go deleted file mode 100644 index 8286abc..0000000 --- a/testing.go +++ /dev/null @@ -1,15 +0,0 @@ -package s3 - -func (fs *Fs) listBuckets() ([]string, error) { - ctx, cancel := fs.contextWithTimeout() - defer cancel() - bucketInfos, err := fs.client.ListBuckets(ctx) - if err != nil { - return nil, err - } - buckets := make([]string, 0, len(bucketInfos)) - for _, bi := range bucketInfos { - buckets = append(buckets, bi.Name) - } - return buckets, nil -} |