Skip to content

Commit f734139

Browse files
committed
feat: panic on missing signing policy
1 parent 33158af commit f734139

2 files changed

Lines changed: 5 additions & 7 deletions

File tree

client/finalizer/finalizer_client.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package finalizer
22

33
import (
44
"context"
5-
"fmt"
65
"time"
76

87
clientContext "github.com/flare-foundation/flare-system-client/client/context"
@@ -218,10 +217,10 @@ func (c *client) messagesChannelListener(ctx context.Context) error {
218217
oldestSP := c.signingPolicyStorage.OldestStored()
219218
if oldestSP != nil && protocolMessage.VotingRoundID < oldestSP.StartVotingRoundID {
220219
// This is a submission for an old voting round, skip it
221-
logger.Debugf("Ignoring message for voting round %d, protocolID %d - before policy startVotingRoundID", protocolMessage.VotingRoundID, protocolMessage.ProtocolID)
220+
logger.Warnf("Ignoring message for voting round %d, protocolID %d - before policy startVotingRoundID", protocolMessage.VotingRoundID, protocolMessage.ProtocolID)
222221
continue
223222
}
224-
return fmt.Errorf("no signing policy found for voting round %d", protocolMessage.VotingRoundID) // this stops the whole fsp client
223+
logger.Panicf("messagesChannelListener: no signing policy found for voting round %d. Storage is empty: %v", protocolMessage.VotingRoundID, c.signingPolicyStorage.OldestStored() == nil) // this stops the whole fsp client, it only happens if there is no signing policy in the storage.
225224
}
226225
finalizationReady, err := c.finalizationStorage.AddMessage(&protocolMessage, sp, threshold)
227226

client/finalizer/submission_processor.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package finalizer
22

33
import (
44
"encoding/hex"
5-
"fmt"
65

76
"github.com/flare-foundation/go-flare-common/pkg/database"
87
"github.com/flare-foundation/go-flare-common/pkg/logger"
@@ -61,18 +60,18 @@ func (c *client) ProcessSubmissionData(payloads []*submitSignaturesPayload) erro
6160

6261
// Skip if voting round is in the future
6362
if !c.checkVotingRoundTime(payloadItem.votingRoundID) {
64-
logger.Debugf("Ignoring submitted signature for voting round %d, protocolID %d - round not started yet", payloadItem.votingRoundID, payloadItem.protocolID)
63+
logger.Debugf("ProcessSubmissionData: Ignoring submitted signature for voting round %d, protocolID %d - round not started yet", payloadItem.votingRoundID, payloadItem.protocolID)
6564
continue
6665
}
6766
sp, threshold := c.signingPolicyData(payloadItem.votingRoundID)
6867
if sp == nil {
6968
oldestSP := c.signingPolicyStorage.OldestStored()
7069
if oldestSP != nil && payloadItem.votingRoundID < oldestSP.StartVotingRoundID {
7170
// This is a submission for an old voting round, skip it
72-
logger.Debugf("Ignoring submitted signature for voting round %d, protocolID %d - before policy startVotingRoundID", payloadItem.votingRoundID, payloadItem.protocolID)
71+
logger.Warnf("ProcessSubmissionData: Ignoring submitted signature for voting round %d, protocolID %d - before policy startVotingRoundID", payloadItem.votingRoundID, payloadItem.protocolID)
7372
continue
7473
}
75-
return fmt.Errorf("no signing policy found for voting round %d", payloadItem.votingRoundID) // this stops the whole fsp client
74+
logger.Panicf("ProcessSubmissionData: no signing policy found for voting round %d. Storage is empty: %v", payloadItem.votingRoundID, c.signingPolicyStorage.OldestStored() == nil) // this stops the whole fsp client, it only happens if there is no signing policy in the storage.
7675
}
7776
finalizationReady, err := c.finalizationStorage.addPayload(payloadItem, sp, threshold)
7877
if err != nil {

0 commit comments

Comments
 (0)