RanchiMall/blockbook
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Set unlimited size of ETH RPC message

Browse Source
This commit is contained in:
Martin Boehm 2024-06-04 15:06:40 +02:00
parent 2751a9b03f
commit 35ab7a3966
4 changed files with 16 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
bchain/coins/bsc/bscrpc.go
View File

@ -4,8 +4,6 @@ import (
"context" "context"
"encoding/json" "encoding/json"
"github.com/ethereum/go-ethereum/ethclient"
"github.com/ethereum/go-ethereum/rpc"
"github.com/golang/glog" "github.com/golang/glog"
"github.com/juju/errors" "github.com/juju/errors"
"github.com/trezor/blockbook/bchain" "github.com/trezor/blockbook/bchain"
@ -46,15 +44,7 @@ func NewBNBSmartChainRPC(config json.RawMessage, pushHandler func(bchain.Notific
// Initialize bnb smart chain rpc interface // Initialize bnb smart chain rpc interface
func (b *BNBSmartChainRPC) Initialize() error { func (b *BNBSmartChainRPC) Initialize() error {
b.OpenRPC = func(url string) (bchain.EVMRPCClient, bchain.EVMClient, error) { b.OpenRPC = eth.OpenRPC
r, err := rpc.Dial(url)
if err != nil {
return nil, nil, err
}
rc := &eth.EthereumRPCClient{Client: r}
ec := &eth.EthereumClient{Client: ethclient.NewClient(r)}
return rc, ec, nil
}
rc, ec, err := b.OpenRPC(b.ChainConfig.RPCURL) rc, ec, err := b.OpenRPC(b.ChainConfig.RPCURL)
if err != nil { if err != nil {

23
bchain/coins/eth/ethrpc.go
View File

@ -107,17 +107,22 @@ func NewEthereumRPC(config json.RawMessage, pushHandler func(bchain.Notification
return s, nil return s, nil
} }
// OpenRPC opens RPC connection to ETH backend
var OpenRPC = func(url string) (bchain.EVMRPCClient, bchain.EVMClient, error) {
opts := []rpc.ClientOption{}
opts = append(opts, rpc.WithWebsocketMessageSizeLimit(0))
r, err := rpc.DialOptions(context.Background(), url, opts...)
if err != nil {
return nil, nil, err
}
rc := &EthereumRPCClient{Client: r}
ec := &EthereumClient{Client: ethclient.NewClient(r)}
return rc, ec, nil
}
// Initialize initializes ethereum rpc interface // Initialize initializes ethereum rpc interface
func (b *EthereumRPC) Initialize() error { func (b *EthereumRPC) Initialize() error {
b.OpenRPC = func(url string) (bchain.EVMRPCClient, bchain.EVMClient, error) { b.OpenRPC = OpenRPC
r, err := rpc.Dial(url)
if err != nil {
return nil, nil, err
}
rc := &EthereumRPCClient{Client: r}
ec := &EthereumClient{Client: ethclient.NewClient(r)}
return rc, ec, nil
}
rc, ec, err := b.OpenRPC(b.ChainConfig.RPCURL) rc, ec, err := b.OpenRPC(b.ChainConfig.RPCURL)
if err != nil { if err != nil {

12
bchain/coins/polygon/polygonrpc.go
View File

@ -4,8 +4,6 @@ import (
"context" "context"
"encoding/json" "encoding/json"
"github.com/ethereum/go-ethereum/ethclient"
"github.com/ethereum/go-ethereum/rpc"
"github.com/golang/glog" "github.com/golang/glog"
"github.com/juju/errors" "github.com/juju/errors"
"github.com/trezor/blockbook/bchain" "github.com/trezor/blockbook/bchain"
@ -38,15 +36,7 @@ func NewPolygonRPC(config json.RawMessage, pushHandler func(bchain.NotificationT
// Initialize polygon rpc interface // Initialize polygon rpc interface
func (b *PolygonRPC) Initialize() error { func (b *PolygonRPC) Initialize() error {
b.OpenRPC = func(url string) (bchain.EVMRPCClient, bchain.EVMClient, error) { b.OpenRPC = eth.OpenRPC
r, err := rpc.Dial(url)
if err != nil {
return nil, nil, err
}
rc := &eth.EthereumRPCClient{Client: r}
ec := &eth.EthereumClient{Client: ethclient.NewClient(r)}
return rc, ec, nil
}
rc, ec, err := b.OpenRPC(b.ChainConfig.RPCURL) rc, ec, err := b.OpenRPC(b.ChainConfig.RPCURL)
if err != nil { if err != nil {

1
build/docker/bin/Makefile
View File

@ -38,5 +38,4 @@ prepare-sources:
mkdir -p $(BLOCKBOOK_BASE) mkdir -p $(BLOCKBOOK_BASE)
cp -r /src $(BLOCKBOOK_SRC) cp -r /src $(BLOCKBOOK_SRC)
cd $(BLOCKBOOK_SRC) && go mod download cd $(BLOCKBOOK_SRC) && go mod download
sed -i 's/wsMessageSizeLimit\ =\ 15\ \*\ 1024\ \*\ 1024/wsMessageSizeLimit = 80 * 1024 * 1024/g' $(GOPATH)/pkg/mod/github.com/ethereum/go-ethereum*/rpc/websocket.go
sed -i 's/wsMessageSizeLimit\ =\ 15\ \*\ 1024\ \*\ 1024/wsMessageSizeLimit = 80 * 1024 * 1024/g' $(GOPATH)/pkg/mod/github.com/ava-labs/coreth*/rpc/websocket.go sed -i 's/wsMessageSizeLimit\ =\ 15\ \*\ 1024\ \*\ 1024/wsMessageSizeLimit = 80 * 1024 * 1024/g' $(GOPATH)/pkg/mod/github.com/ava-labs/coreth*/rpc/websocket.go