Function TestRWScanRecovery

lib/model/model_test.go:1724–1770

(t *testing.T)

}

func TestRWScanRecovery(t *testing.T) {
	fcfg := config.FolderConfiguration{
		FilesystemType:  config.FilesystemTypeFake,
		ID:              "default",
		Path:            srand.String(32),
		Type:            config.FolderTypeSendReceive,
		RescanIntervalS: 1,
		MarkerName:      config.DefaultMarkerName,
	}
	cfg, cancel := newConfigWrapper(config.Configuration{
		Version: config.CurrentVersion,
		Folders: []config.FolderConfiguration{fcfg},
		Devices: []config.DeviceConfiguration{
			{
				DeviceID: device1,
			},
		},
	})
	defer cancel()
	m := newModel(t, cfg, myID, nil)

	m.sdb.Update("default", protocol.LocalDeviceID, []protocol.FileInfo{
		{Name: "dummyfile", Version: protocol.Vector{Counters: []protocol.Counter{{ID: 42, Value: 1}}}},
	})

	ffs := fcfg.Filesystem()

	// Generate error
	if err := ffs.Remove(config.DefaultMarkerName); err != nil {
		t.Fatal(err)
	}

	sub := m.evLogger.Subscribe(events.StateChanged)
	defer sub.Unsubscribe()
	m.ServeBackground()
	defer cleanupModel(m)

	waitForState(t, sub, "default", config.ErrMarkerMissing.Error())

	fd, err := ffs.Create(config.DefaultMarkerName)
	if err != nil {
		t.Error(err)
	}
	fd.Close()

	waitForState(t, sub, "default", "")
}

func TestGlobalDirectoryTree(t *testing.T) {
	m, conn, fcfg := setupModelWithConnection(t)