Skip to content

Commit ae215ab

Browse files
committed
Ensure consistent naming of decryption key
1 parent e449787 commit ae215ab

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

timeboost-sequencer/src/decrypt.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -272,7 +272,7 @@ impl Decrypter {
272272
return None;
273273
};
274274

275-
let Some(dec_sk) = self.dec_key.get() else {
275+
let Some(dec_key) = self.dec_key.get() else {
276276
warn!(node = %self.label, committee = %committee_id, "no existing key to reshare");
277277
return None;
278278
};
@@ -281,7 +281,7 @@ impl Decrypter {
281281
.encrypt_reshares(
282282
next_store.committee(),
283283
next_store.sorted_keys(),
284-
*dec_sk.privkey().share(),
284+
*dec_key.privkey().share(),
285285
DKG_AAD,
286286
)
287287
.ok()?;
@@ -717,12 +717,12 @@ impl Worker {
717717

718718
if let Some((&subset, _)) = counts.iter().find(|(_, count)| **count >= threshold) {
719719
let acc = DkgAccumulator::from_subset(key_store.to_owned(), subset.to_owned());
720-
let dec_sk = acc
720+
let dec_key = acc
721721
.extract_key(&self.dkg_sk, None)
722722
.map_err(|e| DecrypterError::Dkg(e.to_string()))?;
723723
self.tracker.insert(committee.id(), acc);
724724

725-
self.dec_key.set(dec_sk);
725+
self.dec_key.set(dec_key);
726726
self.state = WorkerState::Running;
727727
info!(node = %self.label, committee_id = %committee.id(), "dkg finished (catchup successful)");
728728
}
@@ -1027,7 +1027,7 @@ impl Worker {
10271027
/// NOTE: when a ciphertext is malformed, we will skip decrypting it (treat as garbage) here.
10281028
/// but will later be marked as decrypted during `hatch()`
10291029
async fn decrypt(&mut self, incl: &InclusionList) -> Result<DecShareBatch> {
1030-
let dec_sk: DecryptionKey = match &self.state {
1030+
let dec_key: DecryptionKey = match &self.state {
10311031
WorkerState::DkgPending(_) => {
10321032
self.pending.insert(incl.round(), incl.clone());
10331033
return Err(DecrypterError::DkgPending);
@@ -1055,7 +1055,7 @@ impl Worker {
10551055
optional_ct.and_then(|ct| {
10561056
// TODO: (anders) consider using committee_id as part of `aad`.
10571057
<DecryptionScheme as ThresholdEncScheme>::decrypt(
1058-
dec_sk.privkey(),
1058+
dec_key.privkey(),
10591059
&ct,
10601060
&THRES_AAD.to_vec(),
10611061
)
@@ -1133,7 +1133,7 @@ impl Worker {
11331133
return Ok(Some(incl));
11341134
}
11351135

1136-
let dec_sk = match &self.state {
1136+
let dec_key = match &self.state {
11371137
WorkerState::Running
11381138
| WorkerState::ResharingComplete(_)
11391139
| WorkerState::ShuttingDown => self.dec_key.get().ok_or_else(|| {
@@ -1200,7 +1200,7 @@ impl Worker {
12001200
if let Some(ct) = opt_ct {
12011201
match DecryptionScheme::combine(
12021202
key_store.committee(),
1203-
dec_sk.combkey(),
1203+
dec_key.combkey(),
12041204
dec_shares,
12051205
&ct,
12061206
&THRES_AAD.to_vec(),

timeboost-types/src/decryption.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -505,15 +505,15 @@ impl DkgAccumulator {
505505
.map(|s| (s, b.comm().clone()))
506506
}));
507507

508-
let dec_sk = DecryptionKey::from_dkg(
508+
let dec_key = DecryptionKey::from_dkg(
509509
self.committee().size().into(),
510510
dkg_sk.node_idx(),
511511
&mut dealings_iter,
512512
)?;
513513

514514
dealings_iter.result()?;
515515

516-
Ok(dec_sk)
516+
Ok(dec_key)
517517
}
518518
AccumulatorMode::Resharing(combkey) => {
519519
let Some(prev) = prev else {

0 commit comments

Comments
 (0)