69 lines
1.2 KiB
Go
69 lines
1.2 KiB
Go
|
package fuse
|
||
|
|
|
||
|
|
import (
|
||
|
|
"os"
|
||
|
|
"path/filepath"
|
||
|
|
"runtime"
|
||
|
|
"testing"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/distribyted/distribyted/fs"
|
||
|
|
"github.com/stretchr/testify/require"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestHandler(t *testing.T) {
|
||
|
|
if runtime.GOOS != "windows" {
|
||
|
|
t.Skip("test for windows only")
|
||
|
|
}
|
||
|
|
|
||
|
|
require := require.New(t)
|
||
|
|
|
||
|
|
p := "./testmnt"
|
||
|
|
|
||
|
|
h := NewHandler(false, p)
|
||
|
|
|
||
|
|
mem := fs.NewMemory()
|
||
|
|
|
||
|
|
err := mem.Storage.Add(fs.NewMemoryFile([]byte("test")), "/test.txt")
|
||
|
|
require.NoError(err)
|
||
|
|
|
||
|
|
err = h.Mount(map[string]fs.Filesystem{"/mem": mem})
|
||
|
|
require.NoError(err)
|
||
|
|
|
||
|
|
time.Sleep(5 * time.Second)
|
||
|
|
|
||
|
|
fi, err := os.Stat(filepath.Join(p, "mem", "test.txt"))
|
||
|
|
require.NoError(err)
|
||
|
|
|
||
|
|
require.False(fi.IsDir())
|
||
|
|
require.Equal(int64(4), fi.Size())
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestHandlerDriveLetter(t *testing.T) {
|
||
|
|
if runtime.GOOS != "windows" {
|
||
|
|
t.Skip("test for windows only")
|
||
|
|
}
|
||
|
|
|
||
|
|
require := require.New(t)
|
||
|
|
|
||
|
|
p := "Z:"
|
||
|
|
|
||
|
|
h := NewHandler(false, p)
|
||
|
|
|
||
|
|
mem := fs.NewMemory()
|
||
|
|
|
||
|
|
err := mem.Storage.Add(fs.NewMemoryFile([]byte("test")), "/test.txt")
|
||
|
|
require.NoError(err)
|
||
|
|
|
||
|
|
err = h.Mount(map[string]fs.Filesystem{"/mem": mem})
|
||
|
|
require.NoError(err)
|
||
|
|
|
||
|
|
time.Sleep(5 * time.Second)
|
||
|
|
|
||
|
|
fi, err := os.Stat(filepath.Join(p, "mem", "test.txt"))
|
||
|
|
require.NoError(err)
|
||
|
|
|
||
|
|
require.False(fi.IsDir())
|
||
|
|
require.Equal(int64(4), fi.Size())
|
||
|
|
}
|