mirror of
https://github.com/luxfi/coreth.git
synced 2026-10-30 17:00:51 +00:00
zeekay
1f3c4f30ba
- Changed plugin/main.go to use vm/vms/rpcchainvm - Changed tests/warp/warp_test.go to use vm/vms/platformvm This breaks the circular dependency between coreth and node.
49 lines
1.5 KiB
Go
49 lines
1.5 KiB
Go
// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package atomic
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/luxfi/codec"
|
|
"github.com/luxfi/coreth/plugin/evm/message"
|
|
"github.com/luxfi/coreth/sync/handlers"
|
|
"github.com/luxfi/coreth/sync/handlers/stats"
|
|
"github.com/luxfi/ids"
|
|
|
|
"github.com/luxfi/geth/metrics"
|
|
"github.com/luxfi/geth/triedb"
|
|
)
|
|
|
|
var (
|
|
_ handlers.LeafRequestHandler = (*uninitializedHandler)(nil)
|
|
|
|
errUninitialized = errors.New("uninitialized handler")
|
|
)
|
|
|
|
type uninitializedHandler struct{}
|
|
|
|
func (h *uninitializedHandler) OnLeafsRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, leafsRequest message.LeafsRequest) ([]byte, error) {
|
|
return nil, errUninitialized
|
|
}
|
|
|
|
// atomicLeafHandler is a wrapper around handlers.LeafRequestHandler that allows for initialization after creation
|
|
type leafHandler struct {
|
|
handlers.LeafRequestHandler
|
|
}
|
|
|
|
// NewAtomicLeafHandler returns a new uninitialized leafHandler that can be later initialized
|
|
func NewLeafHandler() *leafHandler {
|
|
return &leafHandler{
|
|
LeafRequestHandler: &uninitializedHandler{},
|
|
}
|
|
}
|
|
|
|
// Initialize initializes the atomicLeafHandler with the provided atomicTrieDB, trieKeyLength, and networkCodec
|
|
func (a *leafHandler) Initialize(atomicTrieDB *triedb.Database, trieKeyLength int, networkCodec codec.Manager) {
|
|
handlerStats := stats.GetOrRegisterHandlerStats(metrics.Enabled())
|
|
a.LeafRequestHandler = handlers.NewLeafsRequestHandler(atomicTrieDB, trieKeyLength, nil, networkCodec, handlerStats)
|
|
}
|