forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-07 15:38:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge 0ecf792f98 into 12eabbd76d

Browse source
This commit is contained in:
hero5512 2026-05-21 21:57:26 -07:00 committed by GitHub
commit 3a9e4b81bc
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 30 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
ethclient/gethclient/gethclient_test.go
View file

@ -23,6 +23,7 @@ import (
"math/big" "math/big"
"strings" "strings"
"testing" "testing"
"time"
"github.com/ethereum/go-ethereum" "github.com/ethereum/go-ethereum"
"github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common"
@ -420,12 +421,20 @@ func testSubscribePendingTransactions(t *testing.T, client *rpc.Client) {
// Subscribe to Transactions // Subscribe to Transactions
ch1 := make(chan common.Hash) ch1 := make(chan common.Hash)
ec.SubscribePendingTransactions(context.Background(), ch1) sub1, err := ec.SubscribePendingTransactions(context.Background(), ch1)
if err != nil {
t.Fatalf("Failed to subscribe to pending transactions: %v", err)
}
defer sub1.Unsubscribe()
// Subscribe to Transactions // Subscribe to Transactions
ch2 := make(chan *types.Transaction) ch2 := make(chan *types.Transaction)
ec.SubscribeFullPendingTransactions(context.Background(), ch2) sub2, err := ec.SubscribeFullPendingTransactions(context.Background(), ch2)
if err != nil {
t.Fatalf("Failed to subscribe to full pending transactions: %v", err)
}
defer sub2.Unsubscribe()
time.Sleep(100 * time.Millisecond)
// Send a transaction // Send a transaction
chainID, err := ethcl.ChainID(context.Background()) chainID, err := ethcl.ChainID(context.Background())
if err != nil { if err != nil {
@ -452,14 +461,26 @@ func testSubscribePendingTransactions(t *testing.T, client *rpc.Client) {
t.Fatal(err) t.Fatal(err)
} }
// Check that the transaction was sent over the channel // Check that the transaction was sent over the channel
hash := <-ch1 select {
if hash != signedTx.Hash() { case hash := <-ch1:
t.Fatalf("Invalid tx hash received, got %v, want %v", hash, signedTx.Hash()) if hash != signedTx.Hash() {
t.Fatalf("Invalid tx hash received, got %v, want %v", hash, signedTx.Hash())
}
case err := <-sub1.Err():
t.Fatalf("Subscription error: %v", err)
case <-time.After(5 * time.Second):
t.Fatal("Timeout waiting for pending transaction hash")
} }
// Check that the transaction was sent over the channel // Check that the transaction was sent over the channel
tx = <-ch2 select {
if tx.Hash() != signedTx.Hash() { case tx = <-ch2:
t.Fatalf("Invalid tx hash received, got %v, want %v", tx.Hash(), signedTx.Hash()) if tx.Hash() != signedTx.Hash() {
t.Fatalf("Invalid tx hash received, got %v, want %v", tx.Hash(), signedTx.Hash())
}
case err := <-sub2.Err():
t.Fatalf("Subscription error: %v", err)
case <-time.After(5 * time.Second):
t.Fatal("Timeout waiting for full pending transaction")
} }
} }