Test unsupported functions

2 files changed, 38 insertions, 18 deletions

diff --git a/fs_test.go b/fs_test.go
index 1677415..77d6d20 100644
--- a/fs_test.go
+++ b/fs_test.go
@@ -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
-}