mirror of
https://github.com/luxfi/coreth.git
synced 2026-10-30 17:00:51 +00:00
zeekay
f70bac500d
- Update import from vm/rpcchainvm to vm/rpc/chain - Update vm dependency to v1.0.18 - node dependency now test-only (platformvm.NewClient for warp tests)
92 lines
3.0 KiB
Go
92 lines
3.0 KiB
Go
// Copyright (C) 2019-2025, Lux Industries, Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
package vm
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/luxfi/consensus/engine/chain/block"
|
|
"github.com/luxfi/database"
|
|
|
|
"github.com/luxfi/coreth/core"
|
|
synccommon "github.com/luxfi/coreth/sync"
|
|
|
|
log "github.com/luxfi/log"
|
|
)
|
|
|
|
var errProviderNotSet = fmt.Errorf("provider not set")
|
|
|
|
type server struct {
|
|
chain *core.BlockChain
|
|
|
|
provider synccommon.SummaryProvider
|
|
syncableInterval uint64
|
|
}
|
|
|
|
type Server interface {
|
|
GetLastStateSummary(context.Context) (block.StateSummary, error)
|
|
GetStateSummary(context.Context, uint64) (block.StateSummary, error)
|
|
}
|
|
|
|
func NewServer(chain *core.BlockChain, provider synccommon.SummaryProvider, syncableInterval uint64) Server {
|
|
return &server{
|
|
chain: chain,
|
|
syncableInterval: syncableInterval,
|
|
provider: provider,
|
|
}
|
|
}
|
|
|
|
// GetLastStateSummary returns the latest state summary.
|
|
// State summary is calculated by the block nearest to last accepted
|
|
// that is divisible by [syncableInterval]
|
|
// If no summary is available, [database.ErrNotFound] must be returned.
|
|
func (server *server) GetLastStateSummary(context.Context) (block.StateSummary, error) {
|
|
lastHeight := server.chain.LastAcceptedBlock().NumberU64()
|
|
lastSyncSummaryNumber := lastHeight - lastHeight%server.syncableInterval
|
|
|
|
summary, err := server.stateSummaryAtHeight(lastSyncSummaryNumber)
|
|
if err != nil {
|
|
log.Debug("could not get latest state summary", "err", err)
|
|
return nil, database.ErrNotFound
|
|
}
|
|
log.Debug("Serving syncable block at latest height", "summary", summary)
|
|
return summary, nil
|
|
}
|
|
|
|
// GetStateSummary implements StateSyncableVM and returns a summary corresponding
|
|
// to the provided [height] if the node can serve state sync data for that key.
|
|
// If not, [database.ErrNotFound] must be returned.
|
|
func (server *server) GetStateSummary(_ context.Context, height uint64) (block.StateSummary, error) {
|
|
summaryBlock := server.chain.GetBlockByNumber(height)
|
|
if summaryBlock == nil ||
|
|
summaryBlock.NumberU64() > server.chain.LastAcceptedBlock().NumberU64() ||
|
|
summaryBlock.NumberU64()%server.syncableInterval != 0 {
|
|
return nil, database.ErrNotFound
|
|
}
|
|
|
|
summary, err := server.stateSummaryAtHeight(summaryBlock.NumberU64())
|
|
if err != nil {
|
|
log.Debug("could not get state summary", "height", height, "err", err)
|
|
return nil, database.ErrNotFound
|
|
}
|
|
|
|
log.Debug("Serving syncable block at requested height", "height", height, "summary", summary)
|
|
return summary, nil
|
|
}
|
|
|
|
func (server *server) stateSummaryAtHeight(height uint64) (block.StateSummary, error) {
|
|
blk := server.chain.GetBlockByNumber(height)
|
|
if blk == nil {
|
|
return nil, fmt.Errorf("block not found for height (%d)", height)
|
|
}
|
|
|
|
if !server.chain.HasState(blk.Root()) {
|
|
return nil, fmt.Errorf("block root does not exist for height (%d), root (%s)", height, blk.Root())
|
|
}
|
|
if server.provider == nil {
|
|
return nil, errProviderNotSet
|
|
}
|
|
return server.provider.StateSummaryAtBlock(blk)
|
|
}
|