// Copyright (C) 2014 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 http://mozilla.org/MPL/2.0/. // +build integration package integration import ( "log" "os" "testing" "github.com/syncthing/protocol" "github.com/syncthing/syncthing/internal/config" ) func TestFileTypeChange(t *testing.T) { // Use no versioning id, _ := protocol.DeviceIDFromString(id2) cfg, _ := config.Load("h2/config.xml", id) fld := cfg.Folders()["default"] fld.Versioning = config.VersioningConfiguration{} cfg.SetFolder(fld) cfg.Save() testFileTypeChange(t) } func TestFileTypeChangeSimpleVersioning(t *testing.T) { // Use simple versioning id, _ := protocol.DeviceIDFromString(id2) cfg, _ := config.Load("h2/config.xml", id) fld := cfg.Folders()["default"] fld.Versioning = config.VersioningConfiguration{ Type: "simple", Params: map[string]string{"keep": "5"}, } cfg.SetFolder(fld) cfg.Save() testFileTypeChange(t) } func TestFileTypeChangeStaggeredVersioning(t *testing.T) { // Use staggered versioning id, _ := protocol.DeviceIDFromString(id2) cfg, _ := config.Load("h2/config.xml", id) fld := cfg.Folders()["default"] fld.Versioning = config.VersioningConfiguration{ Type: "staggered", } cfg.SetFolder(fld) cfg.Save() testFileTypeChange(t) } func testFileTypeChange(t *testing.T) { log.Println("Cleaning...") err := removeAll("s1", "s2", "h1/index*", "h2/index*") if err != nil { t.Fatal(err) } log.Println("Generating files...") err = generateFiles("s1", 100, 20, "../LICENSE") if err != nil { t.Fatal(err) } // A file that we will replace with a directory later fd, err := os.Create("s1/fileToReplace") if err != nil { t.Fatal(err) } fd.Close() // A directory that we will replace with a file later err = os.Mkdir("s1/emptyDirToReplace", 0755) if err != nil { t.Fatal(err) } // A directory with files that we will replace with a file later err = os.Mkdir("s1/dirToReplace", 0755) if err != nil { t.Fatal(err) } fd, err = os.Create("s1/dirToReplace/emptyFile") if err != nil { t.Fatal(err) } fd.Close() // Verify that the files and directories sync to the other side log.Println("Syncing...") sender := syncthingProcess{ // id1 instance: "1", argv: []string{"-home", "h1"}, port: 8081, apiKey: apiKey, } err = sender.start() if err != nil { t.Fatal(err) } defer sender.stop() receiver := syncthingProcess{ // id2 instance: "2", argv: []string{"-home", "h2"}, port: 8082, apiKey: apiKey, } err = receiver.start() if err != nil { sender.stop() t.Fatal(err) } defer receiver.stop() err = awaitCompletion("default", sender, receiver) if err != nil { t.Fatal(err) } _, err = sender.stop() if err != nil { t.Fatal(err) } _, err = receiver.stop() if err != nil { t.Fatal(err) } log.Println("Comparing directories...") err = compareDirectories("s1", "s2") if err != nil { t.Fatal(err) } log.Println("Making some changes...") // Replace file with directory err = os.RemoveAll("s1/fileToReplace") if err != nil { t.Fatal(err) } err = os.Mkdir("s1/fileToReplace", 0755) if err != nil { t.Fatal(err) } // Replace empty directory with file err = os.RemoveAll("s1/emptyDirToReplace") if err != nil { t.Fatal(err) } fd, err = os.Create("s1/emptyDirToReplace") if err != nil { t.Fatal(err) } fd.Close() // Clear directory and replace with file err = os.RemoveAll("s1/dirToReplace") if err != nil { t.Fatal(err) } fd, err = os.Create("s1/dirToReplace") if err != nil { t.Fatal(err) } fd.Close() // Sync these changes and recheck log.Println("Syncing...") err = sender.start() if err != nil { t.Fatal(err) } err = receiver.start() if err != nil { t.Fatal(err) } err = awaitCompletion("default", sender, receiver) if err != nil { t.Fatal(err) } log.Println("Comparing directories...") err = compareDirectories("s1", "s2") if err != nil { t.Fatal(err) } }