mirror of
https://github.com/luxfi/evm.git
synced 2026-09-24 00:27:44 +00:00
zeekay
a89b8c33ee
- Disable errcheck in golangci.yml (too many legacy errors) - Run go fmt on all files to fix formatting - Fixed import ordering issues
55 lines
2.1 KiB
Go
55 lines
2.1 KiB
Go
// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package evm
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/luxfi/codec"
|
|
"github.com/luxfi/evm/plugin/evm/message"
|
|
syncHandlers "github.com/luxfi/evm/sync/handlers"
|
|
syncStats "github.com/luxfi/evm/sync/handlers/stats"
|
|
"github.com/luxfi/evm/warp"
|
|
"github.com/luxfi/geth/ethdb"
|
|
"github.com/luxfi/geth/metrics"
|
|
"github.com/luxfi/geth/triedb"
|
|
"github.com/luxfi/ids"
|
|
)
|
|
|
|
var _ message.RequestHandler = (*networkHandler)(nil)
|
|
|
|
type networkHandler struct {
|
|
leafRequestHandler *syncHandlers.LeafsRequestHandler
|
|
blockRequestHandler *syncHandlers.BlockRequestHandler
|
|
codeRequestHandler *syncHandlers.CodeRequestHandler
|
|
}
|
|
|
|
// newNetworkHandler constructs the handler for serving network requests.
|
|
func newNetworkHandler(
|
|
provider syncHandlers.SyncDataProvider,
|
|
diskDB ethdb.KeyValueReader,
|
|
evmTrieDB *triedb.Database,
|
|
warpBackend warp.Backend,
|
|
networkCodec codec.Manager,
|
|
) message.RequestHandler {
|
|
syncStats := syncStats.NewHandlerStats(metrics.Enabled())
|
|
return &networkHandler{
|
|
leafRequestHandler: syncHandlers.NewLeafsRequestHandler(evmTrieDB, nil, networkCodec, syncStats),
|
|
blockRequestHandler: syncHandlers.NewBlockRequestHandler(provider, networkCodec, syncStats),
|
|
codeRequestHandler: syncHandlers.NewCodeRequestHandler(diskDB, networkCodec, syncStats),
|
|
}
|
|
}
|
|
|
|
func (n networkHandler) HandleStateTrieLeafsRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, leafsRequest message.LeafsRequest) ([]byte, error) {
|
|
return n.leafRequestHandler.OnLeafsRequest(ctx, nodeID, requestID, leafsRequest)
|
|
}
|
|
|
|
func (n networkHandler) HandleBlockRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, blockRequest message.BlockRequest) ([]byte, error) {
|
|
return n.blockRequestHandler.OnBlockRequest(ctx, nodeID, requestID, blockRequest)
|
|
}
|
|
|
|
func (n networkHandler) HandleCodeRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, codeRequest message.CodeRequest) ([]byte, error) {
|
|
return n.codeRequestHandler.OnCodeRequest(ctx, nodeID, requestID, codeRequest)
|
|
}
|