diff options
Diffstat (limited to 'fs_test.go')
| -rw-r--r-- | fs_test.go | 41 |
1 files changed, 38 insertions, 3 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 +} |