Function TestVFSFile_Hydration_Basic

vfs_test.go:1049–1092

TestVFSFile_Hydration_Basic tests that hydration completes and reads from local file.

(t *testing.T)

// TestVFSFile_Hydration_Basic tests that hydration completes and reads from local file.
func TestVFSFile_Hydration_Basic(t *testing.T) {
	client := newMockReplicaClient()
	client.addFixture(t, buildLTXFixture(t, 1, 'a'))

	// Create temp directory for hydration
	hydrationDir := t.TempDir()

	// Create VFSFile with hydration enabled
	f := NewVFSFile(client, "test.db", slog.Default())
	f.hydrationPath = filepath.Join(hydrationDir, "test.db.hydration.db")
	f.PollInterval = 100 * time.Millisecond

	if err := f.Open(); err != nil {
		t.Fatalf("open vfs file: %v", err)
	}
	defer f.Close()

	// Wait for hydration to complete
	deadline := time.Now().Add(5 * time.Second)
	for f.hydrator == nil || !f.hydrator.Complete() {
		if time.Now().After(deadline) {
			t.Fatalf("hydration did not complete in time")
		}
		time.Sleep(10 * time.Millisecond)
	}

	// Verify hydration file exists
	if _, err := os.Stat(f.hydrationPath); err != nil {
		t.Fatalf("hydration file not found: %v", err)
	}

	// Read a page - should come from hydrated file
	buf := make([]byte, 4096)
	if _, err := f.ReadAt(buf, 0); err != nil {
		t.Fatalf("read at: %v", err)
	}

	// Check that the data matches (excluding modified header bytes)
	for i := 28; i < len(buf); i++ {
		if buf[i] != 'a' {
			t.Fatalf("expected byte 'a' at position %d, got %q", i, buf[i])
		}
	}
}

// TestVFSFile_Hydration_ReadsDuringHydration tests that reads work via cache/remote during hydration.
func TestVFSFile_Hydration_ReadsDuringHydration(t *testing.T) {