Skip to content

Commit 8c5e715

Browse files
committed
Replace eon with keyper set index in shares msg
1 parent ad464c7 commit 8c5e715

File tree

3 files changed

+4
-9
lines changed

3 files changed

+4
-9
lines changed

rolling-shutter/keyper/epochkghandler/sendkeyshare.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ func (ksh *KeyShareHandler) ConstructDecryptionKeyShares(
122122
})
123123
}
124124

125-
eonUint, err := medley.Int64ToUint64Safe(eon.Eon)
125+
keyperSetIndexUint, err := medley.Int64ToUint64Safe(eon.Eon)
126126
if err != nil {
127127
return nil, err
128128
}
@@ -132,7 +132,7 @@ func (ksh *KeyShareHandler) ConstructDecryptionKeyShares(
132132
}
133133
msg := &p2pmsg.DecryptionKeyShares{
134134
InstanceID: ksh.InstanceID,
135-
Eon: eonUint,
135+
Eon: keyperSetIndexUint,
136136
KeyperIndex: keyperIndexUint,
137137
Shares: shares,
138138
}

rolling-shutter/keyperimpl/gnosis/handlers.go

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -223,13 +223,8 @@ func (h *DecryptionKeysHandler) ValidateMessage(ctx context.Context, msg p2pmsg.
223223
return pubsub.ValidationReject, errors.New("msg does not contain any keys")
224224
}
225225

226-
keyperCoreDB := corekeyperdatabase.New(h.dbpool)
227226
obsKeyperDB := obskeyperdatabase.New(h.dbpool)
228-
eonData, err := keyperCoreDB.GetEon(ctx, int64(keys.Eon))
229-
if err != nil {
230-
return pubsub.ValidationReject, errors.Wrapf(err, "failed to get eon data from database for eon %d", keys.Eon)
231-
}
232-
keyperSet, err := obsKeyperDB.GetKeyperSet(ctx, eonData.ActivationBlockNumber)
227+
keyperSet, err := obsKeyperDB.GetKeyperSetByKeyperConfigIndex(ctx, int64(keys.Eon))
233228
if err != nil {
234229
return pubsub.ValidationReject, errors.Wrapf(err, "failed to get keyper set from database for eon %d", keys.Eon)
235230
}

rolling-shutter/medley/chainsync/syncer/keyperset.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ func (s *KeyperSetSyncer) GetKeyperSetForBlock(ctx context.Context, opts *bind.C
160160

161161
idx, err := s.Contract.GetKeyperSetIndexByBlock(opts, atBlock)
162162
if err != nil {
163-
return nil, errors.Wrap(err, "could not retrieve keyper set index")
163+
return nil, errors.Wrapf(err, "could not retrieve keyper set index at block %d", atBlock)
164164
}
165165
return s.GetKeyperSetByIndex(ctx, opts, idx)
166166
}

0 commit comments

Comments
 (0)