Skip to content

Commit

Permalink
lint fix
Browse files Browse the repository at this point in the history
  • Loading branch information
goran-ethernal committed Jun 20, 2024
1 parent 4166f42 commit 81c6e03
Show file tree
Hide file tree
Showing 6 changed files with 49 additions and 17 deletions.
2 changes: 1 addition & 1 deletion core/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,7 @@ func (c *cluster) runSequences(ctx context.Context, height uint64) error {
// wait for the worker threads to return
<-sequenceDone

return errors.New("timeout")
return errors.New("timeout") //nolint:err113
}
}

Expand Down
5 changes: 1 addition & 4 deletions core/mock_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -532,10 +532,7 @@ func (m *mockCluster) awaitNCompletions(
for {
select {
case <-ctx.Done():
return fmt.Errorf(
"await exceeded timeout for %d nodes",
count,
)
return fmt.Errorf("await exceeded timeout for %d nodes", count) //nolint:err113
default:
if m.wg.getDone() >= count {
return nil
Expand Down
3 changes: 3 additions & 0 deletions core/rapid_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -358,11 +358,14 @@ func TestProperty(t *testing.T) {
// Make sure we have inserted blocks >= quorum per round.
lastRound := setup.lastRound(height)
badNodes := lastRound.badNodes()

var proposalsNumber int

for nodeID, proposalMap := range insertedProposals.proposals {
if nodeID >= int(badNodes) {
// Only one inserted block per valid round
assert.LessOrEqual(t, len(proposalMap), 1)

proposalsNumber++

// Make sure inserted block value is correct
Expand Down
40 changes: 32 additions & 8 deletions messages/helpers.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,10 @@ func ExtractCommittedSeals(commitMessages []*proto.IbftMessage) ([]*CommittedSea

// ExtractCommittedSeal extracts the committed seal from the passed in message
func ExtractCommittedSeal(commitMessage *proto.IbftMessage) *CommittedSeal {
commitData, _ := commitMessage.Payload.(*proto.IbftMessage_CommitData)
commitData, ok := commitMessage.Payload.(*proto.IbftMessage_CommitData)
if !ok {
return nil
}

return &CommittedSeal{
Signer: commitMessage.From,
Expand All @@ -50,7 +53,10 @@ func ExtractCommitHash(commitMessage *proto.IbftMessage) []byte {
return nil
}

commitData, _ := commitMessage.Payload.(*proto.IbftMessage_CommitData)
commitData, ok := commitMessage.Payload.(*proto.IbftMessage_CommitData)
if !ok {
return nil
}

return commitData.CommitData.ProposalHash
}
Expand All @@ -61,7 +67,10 @@ func ExtractProposal(proposalMessage *proto.IbftMessage) *proto.Proposal {
return nil
}

preprepareData, _ := proposalMessage.Payload.(*proto.IbftMessage_PreprepareData)
preprepareData, ok := proposalMessage.Payload.(*proto.IbftMessage_PreprepareData)
if !ok {
return nil
}

return preprepareData.PreprepareData.Proposal
}
Expand All @@ -72,7 +81,10 @@ func ExtractProposalHash(proposalMessage *proto.IbftMessage) []byte {
return nil
}

preprepareData, _ := proposalMessage.Payload.(*proto.IbftMessage_PreprepareData)
preprepareData, ok := proposalMessage.Payload.(*proto.IbftMessage_PreprepareData)
if !ok {
return nil
}

return preprepareData.PreprepareData.ProposalHash
}
Expand All @@ -83,7 +95,10 @@ func ExtractRoundChangeCertificate(proposalMessage *proto.IbftMessage) *proto.Ro
return nil
}

preprepareData, _ := proposalMessage.Payload.(*proto.IbftMessage_PreprepareData)
preprepareData, ok := proposalMessage.Payload.(*proto.IbftMessage_PreprepareData)
if !ok {
return nil
}

return preprepareData.PreprepareData.Certificate
}
Expand All @@ -94,7 +109,10 @@ func ExtractPrepareHash(prepareMessage *proto.IbftMessage) []byte {
return nil
}

prepareData, _ := prepareMessage.Payload.(*proto.IbftMessage_PrepareData)
prepareData, ok := prepareMessage.Payload.(*proto.IbftMessage_PrepareData)
if !ok {
return nil
}

return prepareData.PrepareData.ProposalHash
}
Expand All @@ -105,7 +123,10 @@ func ExtractLatestPC(roundChangeMessage *proto.IbftMessage) *proto.PreparedCerti
return nil
}

rcData, _ := roundChangeMessage.Payload.(*proto.IbftMessage_RoundChangeData)
rcData, ok := roundChangeMessage.Payload.(*proto.IbftMessage_RoundChangeData)
if !ok {
return nil
}

return rcData.RoundChangeData.LatestPreparedCertificate
}
Expand All @@ -116,7 +137,10 @@ func ExtractLastPreparedProposal(roundChangeMessage *proto.IbftMessage) *proto.P
return nil
}

rcData, _ := roundChangeMessage.Payload.(*proto.IbftMessage_RoundChangeData)
rcData, ok := roundChangeMessage.Payload.(*proto.IbftMessage_RoundChangeData)
if !ok {
return nil
}

return rcData.RoundChangeData.LastPreparedProposal
}
Expand Down
2 changes: 0 additions & 2 deletions messages/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -180,8 +180,6 @@ func TestMessages_ExtractProposal(t *testing.T) {
func TestMessages_ExtractProposalHash(t *testing.T) {
t.Parallel()

proposalHash := []byte("proposal hash")

testTable := []struct {
name string
expectedProposalHash []byte
Expand Down
14 changes: 12 additions & 2 deletions messages/proto/helper.go
Original file line number Diff line number Diff line change
@@ -1,11 +1,21 @@
// Package proto defines the code for protocol buffer
package proto

import "google.golang.org/protobuf/proto"
import (
"errors"

"google.golang.org/protobuf/proto"
)

var errNotIbftMessage = errors.New("not an Ibft message")

// PayloadNoSig returns marshaled message without signature
func (m *IbftMessage) PayloadNoSig() ([]byte, error) {
mm, _ := proto.Clone(m).(*IbftMessage)
mm, ok := proto.Clone(m).(*IbftMessage)
if !ok {
return nil, errNotIbftMessage
}

mm.Signature = nil

raw, err := proto.Marshal(mm)
Expand Down

0 comments on commit 81c6e03

Please sign in to comment.