Function TestVFSFile_WriteBufferClearAfterSync

vfs_write_test.go:602–648

(t *testing.T)

}

func TestVFSFile_WriteBufferClearAfterSync(t *testing.T) {
	client := newWriteTestReplicaClient()

	// Create initial LTX file
	pageSize := uint32(4096)
	initialPage := make([]byte, pageSize)
	createTestLTXFile(t, client, 1, pageSize, 1, map[uint32][]byte{1: initialPage})

	// Create temp directory for buffer
	tmpDir := t.TempDir()
	bufferPath := tmpDir + "/.litestream-write-buffer"

	// Create VFSFile with write buffer
	logger := slog.Default()
	f := NewVFSFile(client, "test.db", logger)
	f.writeEnabled = true
	f.dirty = make(map[uint32]int64)
	f.syncInterval = 0
	f.bufferPath = bufferPath

	if err := f.Open(); err != nil {
		t.Fatal(err)
	}
	defer f.Close()

	// Write data
	if _, err := f.WriteAt([]byte("sync test"), 0); err != nil {
		t.Fatal(err)
	}

	// Check buffer has content before sync
	stat, _ := os.Stat(bufferPath)
	if stat.Size() == 0 {
		t.Error("buffer should have content before sync")
	}

	// Sync to remote
	if err := f.Sync(0); err != nil {
		t.Fatal(err)
	}

	// Check buffer is cleared after sync
	stat, _ = os.Stat(bufferPath)
	if stat.Size() != 0 {
		t.Errorf("buffer should be empty after sync, got size %d", stat.Size())
	}
}

func TestVFSFile_OpenFailsWithInvalidBufferPath(t *testing.T) {
	client := newWriteTestReplicaClient()