| // Copyright 2025 The Dawn & Tint Authors |
| // |
| // Redistribution and use in source and binary forms, with or without |
| // modification, are permitted provided that the following conditions are met: |
| // |
| // 1. Redistributions of source code must retain the above copyright notice, this |
| // list of conditions and the following disclaimer. |
| // |
| // 2. Redistributions in binary form must reproduce the above copyright notice, |
| // this list of conditions and the following disclaimer in the documentation |
| // and/or other materials provided with the distribution. |
| // |
| // 3. Neither the name of the copyright holder nor the names of its |
| // contributors may be used to endorse or promote products derived from |
| // this software without specific prior written permission. |
| // |
| // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" |
| // AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
| // IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
| // DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE |
| // FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL |
| // DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR |
| // SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER |
| // CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, |
| // OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| |
| package fileutils_test |
| |
| import ( |
| "path/filepath" |
| "testing" |
| |
| "dawn.googlesource.com/dawn/tools/src/fileutils" |
| "dawn.googlesource.com/dawn/tools/src/oswrapper" |
| "github.com/stretchr/testify/require" |
| ) |
| |
| func TestCopyFile(t *testing.T) { |
| tests := []struct { |
| name string |
| srcPath string |
| dstPath string |
| setupFS func(t *testing.T, fs oswrapper.MemMapOSWrapper) |
| wantErr bool |
| verify func(t *testing.T, fs oswrapper.MemMapOSWrapper) |
| }{ |
| { |
| name: "Simple copy", |
| srcPath: "/src/file.txt", |
| dstPath: "/dst/file.txt", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src", 0777)) |
| require.NoError(t, fs.WriteFile("/src/file.txt", []byte("hello world"), 0666)) |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| }, |
| wantErr: false, |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| content, err := fs.ReadFile("/dst/file.txt") |
| require.NoError(t, err) |
| require.Equal(t, "hello world", string(content)) |
| }, |
| }, |
| { |
| name: "Overwrite existing file", |
| srcPath: "/src/file.txt", |
| dstPath: "/dst/file.txt", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src", 0777)) |
| require.NoError(t, fs.WriteFile("/src/file.txt", []byte("new content"), 0666)) |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| require.NoError(t, fs.WriteFile("/dst/file.txt", []byte("old content"), 0666)) |
| }, |
| wantErr: false, |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| content, err := fs.ReadFile("/dst/file.txt") |
| require.NoError(t, err) |
| require.Equal(t, "new content", string(content)) |
| }, |
| }, |
| { |
| name: "Source does not exist", |
| srcPath: "/src/nonexistent.txt", |
| dstPath: "/dst/file.txt", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| }, |
| wantErr: true, |
| }, |
| { |
| name: "Source is a directory", |
| srcPath: "/src/dir", |
| dstPath: "/dst/file.txt", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src/dir", 0777)) |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| }, |
| wantErr: true, |
| }, |
| { |
| name: "Destination directory does not exist", |
| srcPath: "/src/file.txt", |
| dstPath: "/nonexistent/dst/file.txt", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src", 0777)) |
| require.NoError(t, fs.WriteFile("/src/file.txt", []byte("hello"), 0666)) |
| }, |
| wantErr: false, // CopyFile creates the destination directory |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| content, err := fs.ReadFile("/nonexistent/dst/file.txt") |
| require.NoError(t, err) |
| require.Equal(t, "hello", string(content)) |
| }, |
| }, |
| } |
| |
| for _, tc := range tests { |
| t.Run(tc.name, func(t *testing.T) { |
| wrapper := oswrapper.CreateMemMapOSWrapper() |
| if tc.setupFS != nil { |
| tc.setupFS(t, wrapper) |
| } |
| |
| err := fileutils.CopyFile(tc.dstPath, tc.srcPath, wrapper) |
| |
| if tc.wantErr { |
| require.Error(t, err) |
| } else { |
| require.NoError(t, err) |
| } |
| |
| if tc.verify != nil { |
| tc.verify(t, wrapper) |
| } |
| }) |
| } |
| } |
| |
| func TestCopyDir(t *testing.T) { |
| tests := []struct { |
| name string |
| srcPath string |
| dstPath string |
| setupFS func(t *testing.T, fs oswrapper.MemMapOSWrapper) |
| wantErr bool |
| verify func(t *testing.T, fs oswrapper.MemMapOSWrapper) |
| }{ |
| { |
| name: "Copy to non-existent destination", |
| srcPath: "/src/data", |
| dstPath: "/dst", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src/data/subdir", 0777)) |
| require.NoError(t, fs.WriteFile("/src/data/file1.txt", []byte("file1"), 0666)) |
| }, |
| wantErr: false, |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.True(t, fileutils.IsDir("/dst", fs)) |
| content, err := fs.ReadFile(filepath.Join("/dst", "file1.txt")) |
| require.NoError(t, err) |
| require.Equal(t, "file1", string(content)) |
| require.True(t, fileutils.IsDir(filepath.Join("/dst", "subdir"), fs)) |
| }, |
| }, |
| { |
| name: "Overwrite existing destination", |
| srcPath: "/src/new_data", |
| dstPath: "/dst", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| // Source |
| require.NoError(t, fs.MkdirAll("/src/new_data", 0777)) |
| require.NoError(t, fs.WriteFile("/src/new_data/new_file.txt", []byte("new"), 0666)) |
| // Destination with old content |
| require.NoError(t, fs.MkdirAll("/dst/old_subdir", 0777)) |
| require.NoError(t, fs.WriteFile("/dst/old_file.txt", []byte("old"), 0666)) |
| }, |
| wantErr: false, |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| // Check new file exists |
| content, err := fs.ReadFile(filepath.Join("/dst", "new_file.txt")) |
| require.NoError(t, err) |
| require.Equal(t, "new", string(content)) |
| |
| // Check old files are gone |
| require.False(t, fileutils.IsFile(filepath.Join("/dst", "old_file.txt"), fs)) |
| require.False(t, fileutils.IsDir(filepath.Join("/dst", "old_subdir"), fs)) |
| }, |
| }, |
| { |
| name: "Copy complex directory structure", |
| srcPath: "/src/complex", |
| dstPath: "/dst", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| // Source with complex structure |
| require.NoError(t, fs.MkdirAll("/src/complex/a", 0777)) |
| require.NoError(t, fs.MkdirAll("/src/complex/b/c", 0777)) |
| require.NoError(t, fs.WriteFile("/src/complex/root.txt", []byte("root"), 0666)) |
| require.NoError(t, fs.WriteFile("/src/complex/a/a.txt", []byte("a"), 0666)) |
| require.NoError(t, fs.WriteFile("/src/complex/b/b.txt", []byte("b"), 0666)) |
| require.NoError(t, fs.WriteFile("/src/complex/b/c/c.txt", []byte("c"), 0666)) |
| // Empty destination |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| }, |
| wantErr: false, |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| content, err := fs.ReadFile(filepath.Join("/dst", "root.txt")) |
| require.NoError(t, err) |
| require.Equal(t, "root", string(content)) |
| content, err = fs.ReadFile(filepath.Join("/dst", "a", "a.txt")) |
| require.NoError(t, err) |
| require.Equal(t, "a", string(content)) |
| content, err = fs.ReadFile(filepath.Join("/dst", "b", "b.txt")) |
| require.NoError(t, err) |
| require.Equal(t, "b", string(content)) |
| content, err = fs.ReadFile(filepath.Join("/dst", "b", "c", "c.txt")) |
| require.NoError(t, err) |
| require.Equal(t, "c", string(content)) |
| }, |
| }, |
| { |
| name: "Copy empty directory to existing destination", |
| srcPath: "/src/empty", |
| dstPath: "/dst", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src/empty", 0777)) |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| require.NoError(t, fs.WriteFile("/dst/old_file.txt", []byte("old"), 0666)) |
| }, |
| wantErr: false, |
| verify: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| isEmpty, err := fileutils.IsEmptyDir("/dst", fs) |
| require.NoError(t, err) |
| require.True(t, isEmpty) |
| }, |
| }, |
| { |
| name: "Source does not exist", |
| srcPath: "/src/nonexistent", |
| dstPath: "/dst", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| }, |
| wantErr: true, |
| }, |
| { |
| name: "Source is a file", |
| srcPath: "/src/file.txt", |
| dstPath: "/dst", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.WriteFile("/src/file.txt", []byte("i am a file"), 0666)) |
| require.NoError(t, fs.MkdirAll("/dst", 0777)) |
| }, |
| wantErr: true, |
| }, |
| { |
| name: "Destination is a file", |
| srcPath: "/src/data", |
| dstPath: "/dst_is_a_file", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src/data", 0777)) |
| require.NoError(t, fs.WriteFile("/dst_is_a_file", []byte("i am a file"), 0666)) |
| }, |
| wantErr: true, |
| }, |
| { |
| name: "Destination is a subdirectory of source", |
| srcPath: "/src", |
| dstPath: "/src/sub", |
| setupFS: func(t *testing.T, fs oswrapper.MemMapOSWrapper) { |
| require.NoError(t, fs.MkdirAll("/src/sub", 0777)) |
| }, |
| wantErr: true, |
| }, |
| } |
| |
| for _, tc := range tests { |
| t.Run(tc.name, func(t *testing.T) { |
| wrapper := oswrapper.CreateMemMapOSWrapper() |
| if tc.setupFS != nil { |
| tc.setupFS(t, wrapper) |
| } |
| |
| err := fileutils.CopyDir(tc.dstPath, tc.srcPath, wrapper) |
| |
| require.Equal(t, tc.wantErr, err != nil, "CopyDir() error = %v, wantErr %v", err, tc.wantErr) |
| |
| if tc.verify != nil { |
| tc.verify(t, wrapper) |
| } |
| }) |
| } |
| } |