mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-29 06:37:17 +00:00
48 lines
1.4 KiB
Go
48 lines
1.4 KiB
Go
package sync
|
|
|
|
import (
|
|
"context"
|
|
"encoding/base64"
|
|
"time"
|
|
|
|
"github.com/gogo/protobuf/proto"
|
|
"github.com/karlseguin/ccache"
|
|
"github.com/prysmaticlabs/go-ssz"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/core/helpers"
|
|
ethpb "github.com/prysmaticlabs/prysm/proto/eth/v1alpha1"
|
|
"github.com/prysmaticlabs/prysm/shared/bytesutil"
|
|
)
|
|
|
|
// pendingBlocks cache.
|
|
// TODO(3147): This cache value should represent a doubly linked list or some management to
|
|
// process pending blocks after a link to the canonical chain is found.
|
|
var pendingBlocks = ccache.New(ccache.Configure())
|
|
|
|
func (r *RegularSync) beaconBlockSubscriber(ctx context.Context, msg proto.Message) error {
|
|
block := msg.(*ethpb.BeaconBlock)
|
|
|
|
headState := r.chain.HeadState()
|
|
|
|
// Ignore block older than last finalized checkpoint.
|
|
if block.Slot < helpers.StartSlot(headState.FinalizedCheckpoint.Epoch+1) {
|
|
return nil
|
|
}
|
|
|
|
// Handle block when the parent is unknown.
|
|
if !r.db.HasBlock(ctx, bytesutil.ToBytes32(block.ParentRoot)) {
|
|
blockRoot, err := ssz.SigningRoot(block)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
b64BlockRoot := base64.StdEncoding.EncodeToString(blockRoot[:])
|
|
pendingBlocks.Set(b64BlockRoot, block, 2*time.Hour)
|
|
|
|
// TODO(3147): Request parent block from peers
|
|
log.Warn("Received a block which we do not have the parent block in the database. " +
|
|
"Requesting missing blocks from peers is not yet implemented.")
|
|
return nil
|
|
}
|
|
|
|
return r.chain.ReceiveBlockNoPubsub(ctx, block)
|
|
}
|