go-ethereum/core/txpool/blobpool/limbo_test.go
Bosul Mun 21652ef9ef
core/txpool: add blobTxForPool migration in limbo (#35209)
This PR adds blobTxForPool migration support in limbo. Previously, there
was no conversion path from limbo entries containing types.Transaction.
Now that we have the new blobTxForPool type, this PR adds migration
logic between both types. New test code (limbo_test.go) to test this
conversion is added.

---------

Co-authored-by: Felix Lange <fjl@twurst.com>
2026-07-01 11:12:46 +02:00

72 lines
2.4 KiB
Go

// Copyright 2026 The go-ethereum Authors
// This file is part of the go-ethereum library.
//
// The go-ethereum library is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// The go-ethereum library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
package blobpool
import (
"testing"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/crypto"
"github.com/ethereum/go-ethereum/params"
"github.com/ethereum/go-ethereum/rlp"
"github.com/holiman/billy"
)
// TestLimboLegacyMigration checks whether limbo entries in the legacy limboBlob type
// are migrated to the blobTxForPool layout on startup instead of being dropped.
func TestLimboLegacyMigration(t *testing.T) {
key, _ := crypto.GenerateKey()
tx := makeMultiBlobTx(0, 10, 100, 100, 2, 0, key)
dir := t.TempDir()
// Write a single entry using the legacy on-disk layout.
store, err := billy.Open(billy.Options{Path: dir}, newSlotterEIP7594(params.BlobTxMaxBlobs), nil)
if err != nil {
t.Fatalf("failed to open store: %v", err)
}
legacy := struct {
TxHash common.Hash
Block uint64
Tx *types.Transaction
}{tx.Hash(), 42, tx}
data, err := rlp.EncodeToBytes(&legacy)
if err != nil {
t.Fatalf("failed to encode legacy entry: %v", err)
}
if _, err := store.Put(data); err != nil {
t.Fatalf("failed to store legacy entry: %v", err)
}
store.Close()
// Open the limbo, which should migrate the legacy entry.
l, err := newLimbo(new(params.ChainConfig), dir)
if err != nil {
t.Fatalf("failed to open limbo: %v", err)
}
defer l.Close()
// The migrated transaction must be tracked and reconstruct the original.
ptx, err := l.pull(tx.Hash())
if err != nil {
t.Fatalf("failed to pull migrated tx: %v", err)
}
if got := ptx.ToTx().Hash(); got != tx.Hash() {
t.Fatalf("migrated tx hash mismatch: got %x, want %x", got, tx.Hash())
}
}