mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-11 12:10:05 +00:00
879e310332
* panic in SizeSSZ * moving slowly * adapt old code to new interfaces * return interfaces from factory functions * replace the rest of WrappedSignedBeaconBlock * WrappedBeaconBlock * WrappedBeaconBlockBody * miscellaneous * Test_BeaconBlockIsNil * replace usages of BeaconBlockIsNil * replace usages of mutator * fix all build errors * fix some more issues * mutator changes * relax assertions when initializing * revert changes in object_mapping.go * allow calling Proto on nil * Revert "allow calling Proto on nil" This reverts commit ecc84e455381b03d24aec2fa0fa17bddbec71705. * modify Copy and Proto methods * remove unused var * fix block batch tests * correct BUILD file * Error when initializing nil objects * one more error fix * add missing comma * rename alias to blocktest * add logging * error when SignedBeaconBlock is nil * fix last test * import fix * broken * working * test fixes * reduce complexity of processPendingBlocks * simplified
68 lines
1.8 KiB
Go
68 lines
1.8 KiB
Go
package sync
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/blockchain"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/core/helpers"
|
|
"github.com/prysmaticlabs/prysm/beacon-chain/core/transition/interop"
|
|
"github.com/prysmaticlabs/prysm/consensus-types/blocks"
|
|
ethpb "github.com/prysmaticlabs/prysm/proto/prysm/v1alpha1"
|
|
"google.golang.org/protobuf/proto"
|
|
)
|
|
|
|
func (s *Service) beaconBlockSubscriber(ctx context.Context, msg proto.Message) error {
|
|
signed, err := blocks.NewSignedBeaconBlock(msg)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if err := blocks.BeaconBlockIsNil(signed); err != nil {
|
|
return err
|
|
}
|
|
|
|
s.setSeenBlockIndexSlot(signed.Block().Slot(), signed.Block().ProposerIndex())
|
|
|
|
block := signed.Block()
|
|
|
|
root, err := block.HashTreeRoot()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := s.cfg.chain.ReceiveBlock(ctx, signed, root); err != nil {
|
|
if blockchain.IsInvalidBlock(err) {
|
|
r := blockchain.InvalidBlockRoot(err)
|
|
if r != [32]byte{} {
|
|
s.setBadBlock(ctx, r) // Setting head block as bad.
|
|
} else {
|
|
interop.WriteBlockToDisk(signed, true /*failed*/)
|
|
s.setBadBlock(ctx, root)
|
|
}
|
|
}
|
|
// Set the returned invalid ancestors as bad.
|
|
for _, root := range blockchain.InvalidAncestorRoots(err) {
|
|
s.setBadBlock(ctx, root)
|
|
}
|
|
return err
|
|
}
|
|
return err
|
|
}
|
|
|
|
// The input attestations are seen by the network, this deletes them from pool
|
|
// so proposers don't include them in a block for the future.
|
|
func (s *Service) deleteAttsInPool(atts []*ethpb.Attestation) error {
|
|
for _, att := range atts {
|
|
if helpers.IsAggregated(att) {
|
|
if err := s.cfg.attPool.DeleteAggregatedAttestation(att); err != nil {
|
|
return err
|
|
}
|
|
} else {
|
|
// Ideally there's shouldn't be any unaggregated attestation in the block.
|
|
if err := s.cfg.attPool.DeleteUnaggregatedAttestation(att); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
return nil
|
|
}
|