fsys/s3_test.go

package fsys

import (
	"github.com/stretchr/testify/assert"
	"io"
	"io/fs"
	"testing"
)

func TestStorageS3(t *testing.T) {

	stor, err := New(Config{
		Type:         "s3",
		S3BucketName: "test",
		S3AccessID:   "root",
		S3AccessKey:  "password123",
		S3Endpoint:   "127.0.0.1:9000",
	})
	assert.NoError(t, err)

	t.Log("== Write ==")

	err = stor.Write("test.txt", []byte("hi"), WriteOptions{})
	assert.NoError(t, err)

	err = stor.Write("testing/1.txt", []byte("hi"), WriteOptions{})
	assert.NoError(t, err)
	err = stor.Write("testing/2.txt", []byte("hi"), WriteOptions{})
	assert.NoError(t, err)
	err = stor.Write("testing/test/2.txt", []byte("hi"), WriteOptions{})
	assert.NoError(t, err)

	t.Log("== Stat ==")

	fileInfo, err := stor.Stat("test.txt")
	assert.NoError(t, err)
	assert.Equal(t, "test.txt", fileInfo.Name)
	assert.Equal(t, int64(len("hi")), fileInfo.Size)
	assert.Equal(t, fs.FileMode(0777), fileInfo.Mode)

	t.Log("== Read ==")

	fileContent, err := stor.Read("test.txt")
	assert.NoError(t, err)
	assert.Equal(t, []byte("hi"), fileContent)

	_, err = stor.Read("nonexistent")
	assert.Error(t, err)
	assert.Equal(t, ErrFileNotFound, err)

	t.Log("== ReadDir ==")

	files, err := stor.ReadDir("testing")
	assert.NoError(t, err)
	assert.Equal(t, 3, len(files))

	t.Log("== Copy ==")

	err = stor.Copy("test.txt", "test2.txt")
	assert.NoError(t, err)

	copyFileInfo, err := stor.Stat("test2.txt")
	assert.NoError(t, err)
	assert.Equal(t, fs.FileMode(0777), copyFileInfo.Mode)
	assert.Equal(t, "test2.txt", copyFileInfo.Name)
	assert.Equal(t, int64(len("hi")), copyFileInfo.Size)

	t.Log("== Move ==")

	err = stor.Move("test2.txt", "test3.txt")
	assert.NoError(t, err)

	moveFileInfo, err := stor.Stat("test3.txt")
	assert.NoError(t, err)
	assert.Equal(t, fs.FileMode(0777), moveFileInfo.Mode)
	assert.Equal(t, "test3.txt", moveFileInfo.Name)
	assert.Equal(t, int64(len("hi")), moveFileInfo.Size)

	t.Log("== Open ==")

	file, err := stor.Open("test.txt")
	assert.NoError(t, err)
	assert.Equal(t, "test.txt", file.Name)

	fileContent, err = io.ReadAll(file)
	assert.NoError(t, err)
	assert.Equal(t, []byte("hi"), fileContent)

	err = file.Close()
	assert.NoError(t, err)

	t.Log("== Delete ==")

	err = stor.Delete("test.txt")
	assert.NoError(t, err)

}