Function TestVFSFile_NewDatabase_WriteAndSync

vfs_write_test.go:780–839

(t *testing.T)

}

func TestVFSFile_NewDatabase_WriteAndSync(t *testing.T) {
	// Test writing to a new database and syncing to remote
	client := newWriteTestReplicaClient()

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

	logger := slog.Default()
	f := NewVFSFile(client, "new.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 to page 1
	writeData := []byte("new database content")
	n, err := f.WriteAt(writeData, 0)
	if err != nil {
		t.Fatal(err)
	}
	if n != len(writeData) {
		t.Errorf("expected %d bytes written, got %d", len(writeData), n)
	}

	// Verify dirty page exists
	if len(f.dirty) != 1 {
		t.Errorf("expected 1 dirty page, got %d", len(f.dirty))
	}

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

	// Verify TXID advanced
	if f.expectedTXID != 1 {
		t.Errorf("expected expectedTXID 1 after sync, got %d", f.expectedTXID)
	}
	if f.pendingTXID != 2 {
		t.Errorf("expected pendingTXID 2 after sync, got %d", f.pendingTXID)
	}

	// Verify LTX file was written
	client.mu.Lock()
	if len(client.ltxFiles[0]) != 1 {
		t.Errorf("expected 1 LTX file after sync, got %d", len(client.ltxFiles[0]))
	}
	if len(client.ltxFiles[0]) > 0 {
		info := client.ltxFiles[0][0]
		if info.MinTXID != 1 || info.MaxTXID != 1 {
			t.Errorf("expected TXID 1, got min=%d max=%d", info.MinTXID, info.MaxTXID)
		}
	}