From 2efb3065bea4283d0277c26a4d7c30922ff61849 Mon Sep 17 00:00:00 2001 From: terence Date: Mon, 12 Aug 2024 13:55:52 -0700 Subject: [PATCH] Initialize payload att message verfier in sync (#14323) --- beacon-chain/sync/service.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/beacon-chain/sync/service.go b/beacon-chain/sync/service.go index 2bc834d856f8..c26571518d35 100644 --- a/beacon-chain/sync/service.go +++ b/beacon-chain/sync/service.go @@ -39,6 +39,7 @@ import ( lruwrpr "github.com/prysmaticlabs/prysm/v5/cache/lru" "github.com/prysmaticlabs/prysm/v5/config/params" "github.com/prysmaticlabs/prysm/v5/consensus-types/blocks" + payloadattestation "github.com/prysmaticlabs/prysm/v5/consensus-types/epbs/payload-attestation" "github.com/prysmaticlabs/prysm/v5/consensus-types/interfaces" leakybucket "github.com/prysmaticlabs/prysm/v5/container/leaky-bucket" ethpb "github.com/prysmaticlabs/prysm/v5/proto/prysm/v1alpha1" @@ -217,6 +218,12 @@ func newBlobVerifierFromInitializer(ini *verification.Initializer) verification. } } +func newPayloadAttestationMessageFromInitializer(ini *verification.Initializer) verification.NewPayloadAttestationMsgVerifier { + return func(pa payloadattestation.ROMessage, reqs []verification.Requirement) verification.PayloadAttestationMsgVerifier { + return ini.NewPayloadAttestationMsgVerifier(pa, reqs) + } +} + // Start the regular sync service. func (s *Service) Start() { v, err := s.verifierWaiter.WaitForInitializer(s.ctx) @@ -225,6 +232,7 @@ func (s *Service) Start() { return } s.newBlobVerifier = newBlobVerifierFromInitializer(v) + s.newPayloadAttestationVerifier = newPayloadAttestationMessageFromInitializer(v) go s.verifierRoutine() go s.registerHandlers()