1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
package s3
import (
"testing"
"github.com/matryer/is"
"github.com/spf13/afero"
)
func TestFsListBuckets(t *testing.T) {
is := is.New(t)
fs, err := newTestFs()
is.NoErr(err)
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 TestFsStat(t *testing.T) {
is := is.New(t)
fs, err := newTestFs()
is.NoErr(err)
info, err := fs.Stat("dir/file")
is.NoErr(err)
is.Equal(info.Name(), "file")
}
func TestFsStatNoExist(t *testing.T) {
is := is.New(t)
fs, err := newTestFs()
is.NoErr(err)
_, err = fs.Stat("dir/non-existent")
is.Equal(err, afero.ErrFileNotFound)
}
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
}
|
