Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

handle validator resolution independantly from transcript downloads.

remotes/origin/v7.4.x
KPrasch 2024-01-26 15:07:18 +01:00 committed by Derek Pierre
parent 2d1c044215
commit 9f8661c0bb
1 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
nucypher/blockchain/eth/actors.py
View File

@ -333,11 +333,8 @@ class Operator(BaseActor):
external_validator = Validator(
address=staking_provider_address, public_key=public_key
)
transcript = Transcript.from_bytes(transcript_bytes) if transcript_bytes else None
result.append((external_validator, transcript))
result = sorted(result, key=lambda x: x[0].address)
result.append(external_validator)
result = sorted(result, key=lambda x: x.address)
return result
def publish_transcript(self, ritual_id: int, transcript: Transcript) -> HexBytes:
@ -428,15 +425,14 @@ class Operator(BaseActor):
f"performing round 1 of DKG ritual #{ritual_id} from blocktime {timestamp} with authority {authority}."
)
# gather the cohort transcripts
ritual = self.coordinator_agent.get_ritual(ritual_id)
nodes, _ = list(zip(*self._resolve_validators(ritual, ritual_id)))
nodes = sorted(nodes, key=lambda n: n.address)
# gather the ritual metadata
ritual = self.get_ritual(ritual_id, download_transcripts=False)
validators = list(zip(*self._resolve_validators(ritual, ritual_id)))
# generate a transcript
try:
transcript = self.ritual_power.generate_transcript(
nodes=nodes,
nodes=validators,
threshold=ritual.threshold,
shares=ritual.shares,
checksum_address=self.checksum_address,