123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265 |
- // Copyright (C) 2015 The Syncthing Authors.
- //
- // This Source Code Form is subject to the terms of the Mozilla Public
- // License, v. 2.0. If a copy of the MPL was not distributed with this file,
- // You can obtain one at https://mozilla.org/MPL/2.0/.
- package versioner
- import (
- "context"
- "io"
- "os"
- "path/filepath"
- "testing"
- "time"
- "github.com/syncthing/syncthing/lib/config"
- "github.com/syncthing/syncthing/lib/fs"
- )
- func TestTrashcanArchiveRestoreSwitcharoo(t *testing.T) {
- // This tests that trashcan versioner restoration correctly archives existing file, because trashcan versioner
- // files are untagged, archiving existing file to replace with a restored version technically should collide in
- // in names.
- tmpDir1 := t.TempDir()
- tmpDir2 := t.TempDir()
- cfg := config.FolderConfiguration{
- FilesystemType: fs.FilesystemTypeBasic,
- Path: tmpDir1,
- Versioning: config.VersioningConfiguration{
- FSType: fs.FilesystemTypeBasic,
- FSPath: tmpDir2,
- },
- }
- folderFs := cfg.Filesystem(nil)
- versionsFs := fs.NewFilesystem(fs.FilesystemTypeBasic, tmpDir2)
- writeFile(t, folderFs, "file", "A")
- versioner := newTrashcan(cfg)
- if err := versioner.Archive("file"); err != nil {
- t.Fatal(err)
- }
- if _, err := folderFs.Stat("file"); !fs.IsNotExist(err) {
- t.Fatal(err)
- }
- // Check versions
- versions, err := versioner.GetVersions()
- if err != nil {
- t.Fatal(err)
- }
- fileVersions := versions["file"]
- if len(fileVersions) != 1 {
- t.Fatalf("unexpected number of versions: %d != 1", len(fileVersions))
- }
- fileVersion := fileVersions[0]
- if !fileVersion.ModTime.Equal(fileVersion.VersionTime) {
- t.Error("time mismatch")
- }
- if content := readFile(t, versionsFs, "file"); content != "A" {
- t.Errorf("expected A got %s", content)
- }
- writeFile(t, folderFs, "file", "B")
- versionInfo, err := versionsFs.Stat("file")
- if err != nil {
- t.Fatal(err)
- }
- if !versionInfo.ModTime().Truncate(time.Second).Equal(fileVersion.ModTime) {
- t.Error("time mismatch")
- }
- if err := versioner.Restore("file", fileVersion.VersionTime); err != nil {
- t.Fatal(err)
- }
- if content := readFile(t, folderFs, "file"); content != "A" {
- t.Errorf("expected A got %s", content)
- }
- if content := readFile(t, versionsFs, "file"); content != "B" {
- t.Errorf("expected B got %s", content)
- }
- }
- func TestTrashcanRestoreDeletedFile(t *testing.T) {
- // This tests that the Trash Can restore function works correctly when the file
- // to be restored was deleted/nonexistent in the folder where the file/folder is
- // going to be restored in. (Issue: #7965)
- tmpDir1 := t.TempDir()
- tmpDir2 := t.TempDir()
- cfg := config.FolderConfiguration{
- FilesystemType: fs.FilesystemTypeBasic,
- Path: tmpDir1,
- Versioning: config.VersioningConfiguration{
- FSType: fs.FilesystemTypeBasic,
- FSPath: tmpDir2,
- },
- }
- folderFs := cfg.Filesystem(nil)
- versionsFs := fs.NewFilesystem(fs.FilesystemTypeBasic, tmpDir2)
- versioner := newTrashcan(cfg)
- writeFile(t, folderFs, "file", "Some content")
- if err := versioner.Archive("file"); err != nil {
- t.Fatal(err)
- }
- // Shouldn't be in the default folder anymore, thus "deleted"
- if _, err := folderFs.Stat("file"); !fs.IsNotExist(err) {
- t.Fatal(err)
- }
- // It should, however, be in the archive
- if _, err := versionsFs.Lstat("file"); fs.IsNotExist(err) {
- t.Fatal(err)
- }
- versions, err := versioner.GetVersions()
- if err != nil {
- t.Fatal(err)
- }
- fileVersions := versions["file"]
- if len(fileVersions) != 1 {
- t.Fatalf("unexpected number of versions: %d != 1", len(fileVersions))
- }
- fileVersion := fileVersions[0]
- if !fileVersion.ModTime.Equal(fileVersion.VersionTime) {
- t.Error("time mismatch")
- }
- // Restore the file from the archive.
- if err := versioner.Restore("file", fileVersion.VersionTime); err != nil {
- t.Fatal(err)
- }
- // The file should be correctly restored
- if content := readFile(t, folderFs, "file"); content != "Some content" {
- t.Errorf("expected A got %s", content)
- }
- // It should no longer be in the archive
- if _, err := versionsFs.Lstat("file"); !fs.IsNotExist(err) {
- t.Fatal(err)
- }
- }
- func readFile(t *testing.T, filesystem fs.Filesystem, name string) string {
- t.Helper()
- fd, err := filesystem.Open(name)
- if err != nil {
- t.Fatal(err)
- }
- defer fd.Close()
- buf, err := io.ReadAll(fd)
- if err != nil {
- t.Fatal(err)
- }
- return string(buf)
- }
- func writeFile(t *testing.T, filesystem fs.Filesystem, name, content string) {
- fd, err := filesystem.OpenFile(name, fs.OptReadWrite|fs.OptCreate, 0777)
- if err != nil {
- t.Fatal(err)
- }
- defer fd.Close()
- if err := fd.Truncate(int64(len(content))); err != nil {
- t.Fatal(err)
- }
- if n, err := fd.Write([]byte(content)); err != nil || n != len(content) {
- t.Fatal(n, len(content), err)
- }
- }
- func TestTrashcanCleanOut(t *testing.T) {
- testDir := t.TempDir()
- cfg := config.FolderConfiguration{
- FilesystemType: fs.FilesystemTypeBasic,
- Path: testDir,
- Versioning: config.VersioningConfiguration{
- Params: map[string]string{
- "cleanoutDays": "7",
- },
- },
- }
- fs := cfg.Filesystem(nil)
- v := newTrashcan(cfg)
- var testcases = map[string]bool{
- ".stversions/file1": false,
- ".stversions/file2": true,
- ".stversions/keep1/file1": false,
- ".stversions/keep1/file2": false,
- ".stversions/keep2/file1": false,
- ".stversions/keep2/file2": true,
- ".stversions/keep3/keepsubdir/file1": false,
- ".stversions/remove/file1": true,
- ".stversions/remove/file2": true,
- ".stversions/remove/removesubdir/file1": true,
- }
- t.Run("trashcan versioner trashcan clean up", func(t *testing.T) {
- oldTime := time.Now().Add(-8 * 24 * time.Hour)
- for file, shouldRemove := range testcases {
- fs.MkdirAll(filepath.Dir(file), 0777)
- writeFile(t, fs, file, "some content")
- if shouldRemove {
- if err := fs.Chtimes(file, oldTime, oldTime); err != nil {
- t.Fatal(err)
- }
- }
- }
- if err := v.Clean(context.Background()); err != nil {
- t.Fatal(err)
- }
- for file, shouldRemove := range testcases {
- _, err := fs.Lstat(file)
- if shouldRemove && !os.IsNotExist(err) {
- t.Error(file, "should have been removed")
- } else if !shouldRemove && err != nil {
- t.Error(file, "should not have been removed")
- }
- }
- if _, err := fs.Lstat(".stversions/keep3"); os.IsNotExist(err) {
- t.Error("directory with non empty subdirs should not be removed")
- }
- if _, err := fs.Lstat(".stversions/remove"); !os.IsNotExist(err) {
- t.Error("empty directory should have been removed")
- }
- })
- }
|