From d109507034dc7e331a0c76ff7f7fb8a1405638ba Mon Sep 17 00:00:00 2001 From: Abhishek Kumar <43061995+xenowits@users.noreply.github.com> Date: Thu, 14 Mar 2024 19:06:21 +0530 Subject: [PATCH] core: remove todo (#2957) Remove unimplemented function in `transport` package. category: misc ticket: none --- core/consensus/transport.go | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/core/consensus/transport.go b/core/consensus/transport.go index 33d91f2ee..369825af7 100644 --- a/core/consensus/transport.go +++ b/core/consensus/transport.go @@ -13,7 +13,6 @@ import ( "google.golang.org/protobuf/types/known/timestamppb" "github.com/obolnetwork/charon/app/errors" - "github.com/obolnetwork/charon/app/log" "github.com/obolnetwork/charon/core" pbv1 "github.com/obolnetwork/charon/core/corepb/v1" "github.com/obolnetwork/charon/core/qbft" @@ -144,11 +143,6 @@ func (t *transport) ProcessReceives(ctx context.Context, outerBuffer chan msg) { case <-ctx.Done(): return case msg := <-outerBuffer: - if err := validateMsg(msg); err != nil { - log.Warn(ctx, "Dropping invalid message", err) - continue - } - t.setValues(msg) select { @@ -196,12 +190,6 @@ func createMsg(typ qbft.MsgType, duty core.Duty, return newMsg(pbMsg, justMsgs, values) } -// validateMsg returns an error if the message is invalid. -func validateMsg(_ msg) error { - // TODO(corver): implement (incl signature verification). - return nil -} - // newSniffer returns a new sniffer. func newSniffer(nodes, peerIdx int64) *sniffer { return &sniffer{