package fs

import (
	"context"
	_ "crypto/sha256"
	"fmt"
	"os"
	"path/filepath"
	"runtime"
	"sort"
	"strings"
	"testing"
	"time"

	"github.com/containerd/continuity/fs/fstest"
	"github.com/pkg/errors"
	"github.com/stretchr/testify/require"
	"github.com/tonistiigi/fsutil"
)

// TODO: Create copy directory which requires privilege
//  chown
//  mknod
//  setxattr fstest.SetXAttr("/home", "trusted.overlay.opaque", "y"),

func TestCopyDirectory(t *testing.T) {
	apply := fstest.Apply(
		fstest.CreateDir("/etc/", 0755),
		fstest.CreateFile("/etc/hosts", []byte("localhost 127.0.0.1"), 0644),
		fstest.Link("/etc/hosts", "/etc/hosts.allow"),
		fstest.CreateDir("/usr/local/lib", 0755),
		fstest.CreateFile("/usr/local/lib/libnothing.so", []byte{0x00, 0x00}, 0755),
		fstest.Symlink("libnothing.so", "/usr/local/lib/libnothing.so.2"),
		fstest.CreateDir("/home", 0755),
	)

	exp := filepath.FromSlash("add:/etc,add:/etc/hosts,add:/etc/hosts.allow,add:/home,add:/usr,add:/usr/local,add:/usr/local/lib,add:/usr/local/lib/libnothing.so,add:/usr/local/lib/libnothing.so.2")

	if err := testCopy(t, apply, exp); err != nil {
		t.Fatalf("Copy test failed: %+v", err)
	}
}

// This test used to fail because link-no-nothing.txt would be copied first,
// then file operations in dst during the CopyDir would follow the symlink and
// fail.
func TestCopyDirectoryWithLocalSymlink(t *testing.T) {
	apply := fstest.Apply(
		fstest.CreateFile("nothing.txt", []byte{0x00, 0x00}, 0755),
		fstest.Symlink("nothing.txt", "link-no-nothing.txt"),
	)

	exp := filepath.FromSlash("add:/link-no-nothing.txt,add:/nothing.txt")

	if err := testCopy(t, apply, exp); err != nil {
		t.Fatalf("Copy test failed: %+v", err)
	}
}

func TestCopyToWorkDir(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateFile("foo.txt", []byte("contents"), 0755),
	)

	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()
	err := Copy(context.TODO(), t1, "foo.txt", t2, "foo.txt")
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)
}

func TestCopySingleFile(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateFile("foo.txt", []byte("contents"), 0755),
	)

	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	err := Copy(context.TODO(), t1, "foo.txt", t2, "/")
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)

	t3 := t.TempDir()

	err = Copy(context.TODO(), t1, "foo.txt", t3, "foo.txt")
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)

	t4 := t.TempDir()

	err = Copy(context.TODO(), t1, "foo.txt", t4, "foo2.txt")
	require.NoError(t, err)

	_, err = os.Stat(filepath.Join(t4, "foo2.txt"))
	require.NoError(t, err)

	ch := &changeCollector{}

	err = Copy(context.TODO(), t1, "foo.txt", t4, "a/b/c/foo2.txt", WithChangeNotifier(ch.onChange))
	require.NoError(t, err)

	_, err = os.Stat(filepath.Join(t4, "a/b/c/foo2.txt"))
	require.NoError(t, err)

	require.Equal(t, filepath.FromSlash("add:/a/b/c/foo2.txt"), ch.String())
}

func TestCopyOverrideFile(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateFile("foo.txt", []byte("contents"), 0755),
	)

	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	err := Copy(context.TODO(), t1, "foo.txt", t2, "foo.txt")
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)

	err = Copy(context.TODO(), t1, "foo.txt", t2, "foo.txt")
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)

	err = Copy(context.TODO(), t1, "/.", t2, "/")
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)
}

func TestCopyDirectoryBasename(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateDir("foo", 0755),
		fstest.CreateDir("foo/bar", 0755),
		fstest.CreateFile("foo/bar/baz.txt", []byte("contents"), 0755),
	)
	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	ch := &changeCollector{}

	err := Copy(context.TODO(), t1, "foo", t2, "foo", WithChangeNotifier(ch.onChange))
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)

	require.Equal(t, filepath.FromSlash("add:/foo,add:/foo/bar,add:/foo/bar/baz.txt"), ch.String())

	ch = &changeCollector{}
	err = Copy(context.TODO(), t1, "foo", t2, "foo", WithCopyInfo(CopyInfo{
		CopyDirContents: true,
		ChangeFunc:      ch.onChange,
	}))
	require.NoError(t, err)

	require.Equal(t, filepath.FromSlash("add:/foo/bar,add:/foo/bar/baz.txt"), ch.String())

	err = fstest.CheckDirectoryEqual(t1, t2)
	require.NoError(t, err)
}

func TestCopyWildcards(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateFile("foo.txt", []byte("foo-contents"), 0755),
		fstest.CreateFile("foo.go", []byte("go-contents"), 0755),
		fstest.CreateFile("bar.txt", []byte("bar-contents"), 0755),
	)

	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	err := Copy(context.TODO(), t1, "foo*", t2, "/")
	require.Error(t, err)

	err = Copy(context.TODO(), t1, "foo*", t2, "/", AllowWildcards)
	require.NoError(t, err)

	_, err = os.Stat(filepath.Join(t2, "foo.txt"))
	require.NoError(t, err)
	_, err = os.Stat(filepath.Join(t2, "foo.go"))
	require.NoError(t, err)
	_, err = os.Stat(filepath.Join(t2, "bar.txt"))
	require.Error(t, err)
	require.True(t, os.IsNotExist(err))

	t3 := t.TempDir()

	err = Copy(context.TODO(), t1, "bar*", t3, "foo.txt", AllowWildcards)
	require.NoError(t, err)
	dt, err := os.ReadFile(filepath.Join(t3, "foo.txt"))
	require.NoError(t, err)
	require.Equal(t, "bar-contents", string(dt))
}

func TestCopyExistingDirDest(t *testing.T) {
	if os.Getuid() != 0 {
		t.Skip()
	}

	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateDir("dir", 0755),
		fstest.CreateFile("dir/foo.txt", []byte("foo-contents"), 0644),
		fstest.CreateFile("dir/bar.txt", []byte("bar-contents"), 0644),
	)
	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	apply = fstest.Apply(
		// notice how perms for destination and source are different
		fstest.CreateDir("dir", 0700),
		// dir/foo.txt does not exist, but dir/bar.txt does
		// notice how both perms and contents for destination and source are different
		fstest.CreateFile("dir/bar.txt", []byte("old-bar-contents"), 0600),
	)
	require.NoError(t, apply.Apply(t2))

	for _, x := range []string{"dir", "dir/bar.txt"} {
		err := os.Chown(filepath.Join(t2, x), 1, 1)
		require.NoErrorf(t, err, "x=%s", x)
	}

	err := Copy(context.TODO(), t1, "dir", t2, "dir", WithCopyInfo(CopyInfo{
		CopyDirContents: true,
	}))
	require.NoError(t, err)

	// verify that existing destination dir's metadata was not overwritten
	st, err := os.Lstat(filepath.Join(t2, "dir"))
	require.NoError(t, err)
	require.Equal(t, st.Mode()&os.ModePerm, os.FileMode(0700))
	var uid, gid int
	if runtime.GOOS != "windows" {
		uid, gid = getUIDGID(st)
		require.Equal(t, 1, uid)
		require.Equal(t, 1, gid)
	}

	// verify that non-existing file was created
	_, err = os.Lstat(filepath.Join(t2, "dir/foo.txt"))
	require.NoError(t, err)

	// verify that existing file's content and metadata was overwritten
	st, err = os.Lstat(filepath.Join(t2, "dir/bar.txt"))
	require.NoError(t, err)
	require.Equal(t, os.FileMode(0644), st.Mode()&os.ModePerm)
	if runtime.GOOS != "windows" {
		uid, gid = getUIDGID(st)
		require.Equal(t, 0, uid)
		require.Equal(t, 0, gid)
	}
	dt, err := os.ReadFile(filepath.Join(t2, "dir/bar.txt"))
	require.NoError(t, err)
	require.Equal(t, "bar-contents", string(dt))
}

func TestCopyDirectoryChmodChown(t *testing.T) {
	if os.Getuid() != 0 {
		t.Skip()
	}

	t1 := t.TempDir()
	apply := fstest.Apply(
		fstest.CreateDir("dir", 0755),
		fstest.CreateFile("dir/foo.txt", []byte("foo-contents"), 0644),
		fstest.CreateDir("dir/sub2", 0755),
	)
	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	mod := int(0700)
	err := Copy(context.TODO(), t1, "dir", t2, "dest/sub", WithCopyInfo(CopyInfo{
		CopyDirContents: true,
		Mode:            &mod,
	}), WithChown(100, 200))
	require.NoError(t, err)

	st, err := os.Lstat(filepath.Join(t2, "dest/sub"))
	require.NoError(t, err)
	uid, gid, ok := readUidGid(st)
	if ok {
		require.Equal(t, 100, uid)
		require.Equal(t, 200, gid)
	}
	require.Equal(t, os.FileMode(0700), st.Mode()&os.ModePerm)

	st, err = os.Lstat(filepath.Join(t2, "dest/sub/foo.txt"))
	require.NoError(t, err)
	uid, gid, ok = readUidGid(st)
	if ok {
		require.Equal(t, 100, uid)
		require.Equal(t, 200, gid)
	}
	require.Equal(t, os.FileMode(0700), st.Mode()&os.ModePerm)

	st, err = os.Lstat(filepath.Join(t2, "dest/sub/sub2"))
	require.NoError(t, err)
	uid, gid, ok = readUidGid(st)
	if ok {
		require.Equal(t, 100, uid)
		require.Equal(t, 200, gid)
	}
	require.Equal(t, os.FileMode(0700), st.Mode()&os.ModePerm)
}

func TestCopyDirectoryContentsTimestamp(t *testing.T) {
	timestamp := time.Unix(0, 0)
	apply := fstest.Apply(
		fstest.CreateDir("/foo/", 0755),
		fstest.CreateDir("/foo/bar", 0755),
		fstest.CreateFile("/foo/bar/baz", []byte{}, 0644),
	)

	t1 := t.TempDir()
	t2 := t.TempDir()

	require.NoError(t, apply.Apply(t1))
	require.NoError(t, Copy(context.TODO(), t1, "/foo", t2, "/foo", WithCopyInfo(CopyInfo{
		CopyDirContents: true,
		Utime:           &timestamp,
	})))
	require.NoError(t, fstest.CheckDirectoryEqual(t1, t2))

	for _, s := range []string{"/foo/bar/baz", "/foo/bar", "/foo"} {
		stat, _ := os.Stat(filepath.Join(t2, s))
		require.Equal(t, timestamp, stat.ModTime())
	}
}

func TestCopySymlinks(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateDir("testdir", 0755),
		fstest.CreateFile("testdir/foo.txt", []byte("foo-contents"), 0644),
		fstest.Symlink("foo.txt", "testdir/link2"),
		fstest.Symlink("/testdir", "link"),
	)
	require.NoError(t, apply.Apply(t1))

	t2 := t.TempDir()

	err := Copy(context.TODO(), t1, "link/link2", t2, "foo", WithCopyInfo(CopyInfo{
		FollowLinks: true,
	}))
	require.NoError(t, err)

	// verify that existing destination dir's metadata was not overwritten
	st, err := os.Lstat(filepath.Join(t2, "foo"))
	require.NoError(t, err)
	if runtime.GOOS != "windows" {
		require.Equal(t, os.FileMode(0644), st.Mode()&os.ModePerm)
	}
	require.Equal(t, 0, int(st.Mode()&os.ModeSymlink))
	dt, err := os.ReadFile(filepath.Join(t2, "foo"))
	require.NoError(t, err)
	require.Equal(t, "foo-contents", string(dt))

	t3 := t.TempDir()

	err = Copy(context.TODO(), t1, "link/link2", t3, "foo", WithCopyInfo(CopyInfo{}))
	require.NoError(t, err)

	// verify that existing destination dir's metadata was not overwritten
	st, err = os.Lstat(filepath.Join(t3, "foo"))
	require.NoError(t, err)
	require.Equal(t, os.ModeSymlink, st.Mode()&os.ModeSymlink)
	link, err := os.Readlink(filepath.Join(t3, "foo"))
	require.NoError(t, err)
	require.Equal(t, "foo.txt", link)
}

func TestCopyWithAlwaysReplaceExistingDestPaths(t *testing.T) {
	destDir := t.TempDir()
	require.NoError(t, fstest.Apply(
		fstest.CreateDir("root", 0755),
		fstest.CreateDir("root/overwritedir", 0755),
		fstest.CreateFile("root/overwritedir/subfile", nil, 0755),
		fstest.CreateFile("root/overwritefile", nil, 0755),
		fstest.Symlink("dir", "root/overwritesymlink"),
		fstest.CreateDir("root/dir", 0755),
		fstest.CreateFile("root/dir/dirfile1", nil, 0755),
		fstest.CreateDir("root/dir/overwritesubdir", 0755),
		fstest.CreateFile("root/dir/overwritesubfile", nil, 0755),
		fstest.Symlink("dirfile1", "root/dir/overwritesymlink"),
	).Apply(destDir))

	srcDir := t.TempDir()
	require.NoError(t, fstest.Apply(
		fstest.CreateDir("root", 0755),
		fstest.CreateFile("root/overwritedir", nil, 0755),
		fstest.CreateDir("root/overwritefile", 0755),
		fstest.CreateFile("root/overwritefile/foo", nil, 0755),
		fstest.CreateDir("root/overwritesymlink", 0755),
		fstest.CreateDir("root/dir", 0755),
		fstest.CreateFile("root/dir/dirfile2", nil, 0755),
		fstest.CreateFile("root/dir/overwritesubdir", nil, 0755),
		fstest.CreateDir("root/dir/overwritesubfile", 0755),
		fstest.CreateDir("root/dir/overwritesymlink", 0755),
	).Apply(srcDir))

	expectedDir := t.TempDir()
	require.NoError(t, fstest.Apply(
		fstest.CreateDir("root", 0755),
		fstest.CreateFile("root/overwritedir", nil, 0755),
		fstest.CreateDir("root/overwritefile", 0755),
		fstest.CreateFile("root/overwritefile/foo", nil, 0755),
		fstest.CreateDir("root/overwritesymlink", 0755),
		fstest.CreateDir("root/dir", 0755),
		fstest.CreateFile("root/dir/dirfile1", nil, 0755),
		fstest.CreateFile("root/dir/dirfile2", nil, 0755),
		fstest.CreateFile("root/dir/overwritesubdir", nil, 0755),
		fstest.CreateDir("root/dir/overwritesubfile", 0755),
		fstest.CreateDir("root/dir/overwritesymlink", 0755),
	).Apply(expectedDir))

	err := Copy(context.TODO(), srcDir, "root", destDir, "root", WithCopyInfo(CopyInfo{
		AlwaysReplaceExistingDestPaths: true,
		CopyDirContents:                true,
	}))
	require.NoError(t, err)

	err = fstest.CheckDirectoryEqual(destDir, expectedDir)
	require.NoError(t, err)
}

func testCopy(t *testing.T, apply fstest.Applier, exp string) error {
	t1 := t.TempDir()
	t2 := t.TempDir()

	if err := apply.Apply(t1); err != nil {
		return errors.Wrap(err, "failed to apply changes")
	}

	ch := &changeCollector{}
	if err := Copy(context.TODO(), t1, "/.", t2, "/", WithChangeNotifier(ch.onChange)); err != nil {
		return errors.Wrap(err, "failed to copy")
	}

	if exp != ch.String() {
		return errors.Errorf("unexpected changes: %s", ch)
	}

	return fstest.CheckDirectoryEqual(t1, t2)
}

func TestCopyIncludeExclude(t *testing.T) {
	t1 := t.TempDir()

	apply := fstest.Apply(
		fstest.CreateDir("bar", 0755),
		fstest.CreateFile("bar/foo", []byte("foo-contents"), 0755),
		fstest.CreateDir("bar/baz", 0755),
		fstest.CreateFile("bar/baz/foo3", []byte("foo3-contents"), 0755),
		fstest.CreateFile("foo2", []byte("foo2-contents"), 0755),
	)

	require.NoError(t, apply.Apply(t1))

	testCases := []struct {
		name            string
		opts            []Opt
		expectedResults []string
		expectedChanges string
	}{
		{
			name:            "include bar",
			opts:            []Opt{WithIncludePattern("bar")},
			expectedResults: []string{"bar", "bar/foo", "bar/baz", "bar/baz/foo3"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/baz,add:/bar/baz/foo3,add:/bar/foo"),
		},
		{
			name:            "include *",
			opts:            []Opt{WithIncludePattern("*")},
			expectedResults: []string{"bar", "bar/foo", "bar/baz", "bar/baz/foo3", "foo2"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/baz,add:/bar/baz/foo3,add:/bar/foo,add:/foo2"),
		},
		{
			name:            "include bar/foo",
			opts:            []Opt{WithIncludePattern("bar/foo")},
			expectedResults: []string{"bar", "bar/foo"},
			expectedChanges: filepath.FromSlash("add:/bar/foo"),
		},
		{
			name:            "include bar except bar/foo",
			opts:            []Opt{WithIncludePattern("bar"), WithIncludePattern("!bar/foo")},
			expectedResults: []string{"bar", "bar/baz", "bar/baz/foo3"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/baz,add:/bar/baz/foo3"),
		},
		{
			name:            "include bar/foo and foo*",
			opts:            []Opt{WithIncludePattern("bar/foo"), WithIncludePattern("foo*")},
			expectedResults: []string{"bar", "bar/foo", "foo2"},
			expectedChanges: filepath.FromSlash("add:/bar/foo,add:/foo2"),
		},
		{
			name:            "include b*",
			opts:            []Opt{WithIncludePattern("b*")},
			expectedResults: []string{"bar", "bar/foo", "bar/baz", "bar/baz/foo3"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/baz,add:/bar/baz/foo3,add:/bar/foo"),
		},
		{
			name:            "include bar/f*",
			opts:            []Opt{WithIncludePattern("bar/f*")},
			expectedResults: []string{"bar", "bar/foo"},
		},
		{
			name:            "include bar/g*",
			opts:            []Opt{WithIncludePattern("bar/g*")},
			expectedResults: nil,
		},
		{
			name:            "include b*/f*",
			opts:            []Opt{WithIncludePattern("b*/f*")},
			expectedResults: []string{"bar", "bar/foo"},
		},
		{
			name:            "include b*/foo",
			opts:            []Opt{WithIncludePattern("b*/foo")},
			expectedResults: []string{"bar", "bar/foo"},
		},
		{
			name:            "include b*/",
			opts:            []Opt{WithIncludePattern("b*/")},
			expectedResults: []string{"bar", "bar/foo", "bar/baz", "bar/baz/foo3"},
		},
		{
			name:            "include bar/*/foo3",
			opts:            []Opt{WithIncludePattern("bar/*/foo3")},
			expectedResults: []string{"bar", "bar/baz", "bar/baz/foo3"},
		},
		{
			name:            "exclude bar*, !bar/baz",
			opts:            []Opt{WithExcludePattern("bar*"), WithExcludePattern("!bar/baz")},
			expectedResults: []string{"bar", "bar/baz", "bar/baz/foo3", "foo2"},
		},
		{
			name:            "exclude **, !bar/baz",
			opts:            []Opt{WithExcludePattern("**"), WithExcludePattern("!bar/baz")},
			expectedResults: []string{"bar", "bar/baz", "bar/baz/foo3"},
		},
		{
			name:            "exclude **, !bar/baz, bar/baz/foo3",
			opts:            []Opt{WithExcludePattern("**"), WithExcludePattern("!bar/baz"), WithExcludePattern("bar/baz/foo3")},
			expectedResults: []string{"bar", "bar/baz"},
		},
		{
			name:            "include bar, exclude bar/baz",
			opts:            []Opt{WithIncludePattern("bar"), WithExcludePattern("bar/baz")},
			expectedResults: []string{"bar", "bar/foo"},
		},
		{
			name:            "doublestar include",
			opts:            []Opt{WithIncludePattern("**/foo3")},
			expectedResults: []string{"bar", "bar/baz", "bar/baz/foo3"},
		},
		{
			name:            "doublestar matching second item in path",
			opts:            []Opt{WithIncludePattern("**/baz")},
			expectedResults: []string{"bar", "bar/baz", "bar/baz/foo3"},
			expectedChanges: filepath.FromSlash("add:/bar/baz,add:/bar/baz/foo3"),
		},
		{
			name:            "doublestar matching first item in path",
			opts:            []Opt{WithIncludePattern("**/bar")},
			expectedResults: []string{"bar", "bar/foo", "bar/baz", "bar/baz/foo3"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/baz,add:/bar/baz/foo3,add:/bar/foo"),
		},
		{
			name:            "doublestar exclude",
			opts:            []Opt{WithIncludePattern("bar"), WithExcludePattern("**/foo3")},
			expectedResults: []string{"bar", "bar/foo", "bar/baz"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/baz,add:/bar/foo"),
		},
		{
			name:            "exclude bar/baz",
			opts:            []Opt{WithExcludePattern("bar/baz")},
			expectedResults: []string{"bar", "bar/foo", "foo2"},
			expectedChanges: filepath.FromSlash("add:/bar,add:/bar/foo,add:/foo2"),
		},
	}

	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			t2 := t.TempDir()

			ch := &changeCollector{}
			tc.opts = append(tc.opts, WithChangeNotifier(ch.onChange))

			err := Copy(context.Background(), t1, "/", t2, "/", tc.opts...)
			require.NoError(t, err, tc.name)

			var results []string
			for _, path := range []string{"bar", "bar/foo", "bar/baz", "bar/baz/asdf", "bar/baz/asdf/x", "bar/baz/foo3", "foo2"} {
				_, err := os.Stat(filepath.Join(t2, path))
				if err == nil {
					results = append(results, path)
				}
			}

			require.Equal(t, tc.expectedResults, results, tc.name)

			if tc.expectedChanges != "" {
				require.Equal(t, tc.expectedChanges, ch.String())
			}
		})
	}
}

func TestCopyFileWithPathTimestamp(t *testing.T) {
	timestamp := time.Unix(0, 0)
	apply := fstest.Apply(
		fstest.CreateDir("/foo/", 0755),
		fstest.CreateFile("/foo/bar", []byte{}, 0644),
	)

	t1 := t.TempDir()
	t2 := t.TempDir()

	require.NoError(t, apply.Apply(t1))
	require.NoError(t, Copy(context.TODO(), t1, "/foo/bar", t2, "/test1/test2/test3/bar", WithCopyInfo(CopyInfo{
		CopyDirContents: true,
		Utime:           &timestamp,
	})))

	for _, s := range []string{"/test1/test2/test3/bar", "/test1/test2/test3", "/test1/test2", "/test1"} {
		stat, _ := os.Stat(filepath.Join(t2, s))
		require.Equal(t, timestamp, stat.ModTime(), "path: %s", s)
	}
}

type changeCollector struct {
	changes []string
}

func (c *changeCollector) onChange(kind fsutil.ChangeKind, path string, _ os.FileInfo, _ error) error {
	c.changes = append(c.changes, fmt.Sprintf("%s:%s", kind, path))
	return nil
}

func (c *changeCollector) String() string {
	sort.Strings(c.changes)
	return strings.Join(c.changes, ",")
}