Function TestNormalSync

pkg/devspace/sync/sync_test.go:156–263

(t *testing.T)

}

func TestNormalSync(t *testing.T) {
	remote, local, outside := initTestDirs(t)
	defer os.RemoveAll(remote)
	defer os.RemoveAll(local)
	defer os.RemoveAll(outside)

	filesToCheck, foldersToCheck := makeBasicTestCases()
	filesToCheck, foldersToCheck = makeRemoveAndRenameTestCases(filesToCheck, foldersToCheck)
	sort.Stable(foldersToCheck)

	syncClient, err := createTestSyncClient(local, append(filesToCheck, foldersToCheck...))
	if err != nil {
		t.Fatal(err)
	}
	defer syncClient.Stop(nil)

	// Start the downstream server
	downClientReader, downClientWriter, _ := os.Pipe()
	downServerReader, downServerWriter, _ := os.Pipe()
	defer downClientReader.Close()
	defer downClientWriter.Close()
	defer downServerReader.Close()
	defer downServerWriter.Close()

	// Build exclude paths
	excludePaths := []string{}
	excludePaths = append(excludePaths, syncClient.Options.ExcludePaths...)
	excludePaths = append(excludePaths, syncClient.Options.DownloadExcludePaths...)

	go func() {
		err := server.StartDownstreamServer(downServerReader, downClientWriter, &server.DownstreamOptions{
			RemotePath:   remote,
			ExcludePaths: excludePaths,
			ExitOnClose:  false,
		})
		if err != nil {
			panic(err)
		}
	}()

	// Start downstream client
	err = syncClient.InitDownstream(downClientReader, downServerWriter)
	if err != nil {
		t.Fatal(err)
	}

	// Start upstream server
	upClientReader, upClientWriter, _ := os.Pipe()
	upServerReader, upServerWriter, _ := os.Pipe()
	defer upClientReader.Close()
	defer upClientWriter.Close()
	defer upServerReader.Close()
	defer upServerWriter.Close()

	go func() {
		err := server.StartUpstreamServer(upServerReader, upClientWriter, &server.UpstreamOptions{
			UploadPath:  remote,
			ExludePaths: []string{},