summaryrefslogtreecommitdiff
path: root/fs_test.go
blob: f8b7db061c58dfe0f09502600d03b8150aafe7f3 (plain)
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
package s3

import (
	"testing"
	"time"

	"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 TestFsChmod(t *testing.T) {
	is := is.New(t)
	fs, err := newTestFs()
	is.NoErr(err)
	err = fs.Chmod("test", 0o644)
	is.Equal(err, ErrUnsupported)
}

func TestFsChown(t *testing.T) {
	is := is.New(t)
	fs, err := newTestFs()
	is.NoErr(err)
	err = fs.Chown("test", 1000, 1000)
	is.Equal(err, ErrUnsupported)
}

func TestFsChtimes(t *testing.T) {
	is := is.New(t)
	fs, err := newTestFs()
	is.NoErr(err)
	now := time.Now()
	err = fs.Chtimes("test", now, now)
	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 := NewFsFromURL("http://testuser:[email protected]:9000/test-bucket")
	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
}