Skip to content

Commit 73b846e

Browse files
committed
Fix eon/keyper set index mismatch
1 parent 785a310 commit 73b846e

File tree

1 file changed

+5
-16
lines changed

1 file changed

+5
-16
lines changed

rolling-shutter/keyperimpl/gnosis/handlers.go

Lines changed: 5 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -44,25 +44,18 @@ func (h *DecryptionKeySharesHandler) ValidateMessage(ctx context.Context, msg p2
4444
return pubsub.ValidationReject, errors.New("tx pointer too large")
4545
}
4646

47-
keyperDB := corekeyperdatabase.New(h.dbpool)
48-
eon, err := keyperDB.GetEon(ctx, int64(keyShares.Eon))
49-
if err != nil {
50-
return pubsub.ValidationReject, errors.Wrapf(err, "failed to get eon from database for eon %d", keyShares.Eon)
51-
}
5247
obsKeyperDB := obskeyperdatabase.New(h.dbpool)
53-
keyperSet, err := obsKeyperDB.GetKeyperSetByKeyperConfigIndex(ctx, eon.KeyperConfigIndex)
48+
keyperSet, err := obsKeyperDB.GetKeyperSetByKeyperConfigIndex(ctx, int64(keyShares.Eon))
5449
if err != nil {
5550
return pubsub.ValidationReject, errors.Wrapf(err,
56-
"failed to get keyper set from database for keyper set index %d (eon %d)",
57-
eon.KeyperConfigIndex,
51+
"failed to get keyper set from database for keyper set index %d",
5852
keyShares.Eon,
5953
)
6054
}
6155
if keyShares.KeyperIndex >= uint64(len(keyperSet.Keypers)) {
6256
return pubsub.ValidationReject, errors.Errorf(
63-
"keyper index %d out of range for keyper set %d (eon %d)",
57+
"keyper index %d out of range for keyper set %d",
6458
keyShares.KeyperIndex,
65-
eon.KeyperConfigIndex,
6659
keyShares.Eon,
6760
)
6861
}
@@ -119,13 +112,9 @@ func (h *DecryptionKeySharesHandler) HandleMessage(ctx context.Context, msg p2pm
119112
return []p2pmsg.Message{}, errors.Wrap(err, "failed to insert tx pointer vote")
120113
}
121114

122-
eonData, err := keyperCoreDB.GetEon(ctx, int64(keyShares.Eon))
123-
if err != nil {
124-
return []p2pmsg.Message{}, errors.Wrapf(err, "failed to get eon data from database for eon %d", keyShares.Eon)
125-
}
126-
keyperSet, err := obsKeyperDB.GetKeyperSetByKeyperConfigIndex(ctx, eonData.KeyperConfigIndex)
115+
keyperSet, err := obsKeyperDB.GetKeyperSetByKeyperConfigIndex(ctx, int64(keyShares.Eon))
127116
if err != nil {
128-
return []p2pmsg.Message{}, errors.Wrapf(err, "failed to get keyper set from database for eon %d", keyShares.Eon)
117+
return []p2pmsg.Message{}, errors.Wrapf(err, "failed to get keyper set from database for index %d", keyShares.Eon)
129118
}
130119

131120
signaturesDB, err := gnosisDB.GetSlotDecryptionSignatures(ctx, database.GetSlotDecryptionSignaturesParams{

0 commit comments

Comments
 (0)