forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-23 13:16:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix live log in test

Browse source 
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
Sina Mahmoodi 2023-07-07 18:50:49 +02:00 committed by jsvisa
parent c1f986b8d3
commit d7bb05a499
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
eth/filters/filter_system_test.go
View file

@ -964,10 +964,10 @@ func TestLogsSubscriptionReorg(t *testing.T) {
// Generate pending block, logs for which // Generate pending block, logs for which
// will be sent to subscription feed. // will be sent to subscription feed.
_, preceipts := core.GenerateChain(genesis.Config, blocks[len(blocks)-1], ethash.NewFaker(), db, 1, func(i int, gen *core.BlockGen) { _, preceipts := core.GenerateChain(genesis.Config, reorgChain[len(reorgChain)-1], ethash.NewFaker(), db, 1, func(i int, gen *core.BlockGen) {
// transfer(address to, uint256 value) // transfer(address to, uint256 value)
data := fmt.Sprintf("0xa9059cbb%s%s", common.HexToHash(common.BigToAddress(big.NewInt(int64(i + 1))).Hex()).String()[2:], common.BytesToHash([]byte{byte(i + 11)}).String()[2:]) data := fmt.Sprintf("0xa9059cbb%s%s", common.HexToHash(common.BigToAddress(big.NewInt(int64(i + 1))).Hex()).String()[2:], common.BytesToHash([]byte{byte(i + 11)}).String()[2:])
tx, _ := types.SignTx(types.NewTx(&types.LegacyTx{Nonce: uint64(len(blocks) + i), To: &contract, Value: big.NewInt(0), Gas: 46000, GasPrice: gen.BaseFee(), Data: common.FromHex(data)}), signer, key) tx, _ := types.SignTx(types.NewTx(&types.LegacyTx{Nonce: uint64(6 + i), To: &contract, Value: big.NewInt(0), Gas: 46000, GasPrice: gen.BaseFee(), Data: common.FromHex(data)}), signer, key)
gen.AddTx(tx) gen.AddTx(tx)
}) })
liveLogs := preceipts[0][0].Logs liveLogs := preceipts[0][0].Logs
@ -1047,7 +1047,7 @@ func TestLogsSubscriptionReorg(t *testing.T) {
// Wait for historical logs to be processed. // Wait for historical logs to be processed.
// The reason we need to wait is this test is artificial // The reason we need to wait is this test is artificial
// and no new block containing the logs is mined. // and no new block containing the logs is mined.
time.Sleep(1 * time.Second) time.Sleep(2 * time.Second)
// Send live logs // Send live logs
backend.logsFeed.Send(liveLogs) backend.logsFeed.Send(liveLogs)