Inheritance diagram for coordinator.phase1_contribution_handler.Phase1ContributionHandler:

Collaboration diagram for coordinator.phase1_contribution_handler.Phase1ContributionHandler:

Public Member Functions
def	__init__ (self, Phase1ServerConfig phase1_config)

str	get_current_challenge_file (self, int contributor_idx)

bool	process_contribution (self, int contribution_idx, str file_name)

None	on_completed (self)

Public Attributes
	powersoftau

	state

Detailed Description

Handler processing phase1 (powersoftau) challenges and contributions. Some
complexity is involved, because we need to track the number of valid
contributions that have been made.

Definition at line 102 of file phase1_contribution_handler.py.

Constructor & Destructor Documentation

◆ init()

def coordinator.phase1_contribution_handler.Phase1ContributionHandler.__init__	(		self,
		Phase1ServerConfig	phase1_config
	)

Definition at line 109 of file phase1_contribution_handler.py.

     def __init__(self, phase1_config: Phase1ServerConfig):
         self.powersoftau = PowersOfTauCommand(
             phase1_config.powersoftau_path, phase1_config.num_powers)
  
         if exists(PHASE1_STATE_FILE):
             with open(PHASE1_STATE_FILE, "r") as state_f:
                 self.state = _Phase1State.from_json(state_f.read())
         else:
             self.state = _Phase1State.new()
  
         # Create challenge file if it does not exist.
         if not exists(CHALLENGE_FILE):
             assert not exists(NEW_CHALLENGE_FILE)
             assert not exists(TRANSCRIPT_FILE)
             print("Phase1: creating initial challenge ...")
             self.powersoftau.begin()
         assert exists(CHALLENGE_FILE)
  

Member Function Documentation

◆ get_current_challenge_file()

str coordinator.phase1_contribution_handler.Phase1ContributionHandler.get_current_challenge_file	(		self,
		int	contributor_idx
	)

Return the location of the current challenge to serve.

Reimplemented from coordinator.icontributionhandler.IContributionHandler.

Definition at line 127 of file phase1_contribution_handler.py.

     def get_current_challenge_file(self, contributor_idx: int) -> str:
         # Single "challenge" file always contains the next challenge
         return CHALLENGE_FILE
  

◆ on_completed()

None coordinator.phase1_contribution_handler.Phase1ContributionHandler.on_completed ( self )

All contributions have been received and the MPC is complete.

Reimplemented from coordinator.icontributionhandler.IContributionHandler.

Definition at line 154 of file phase1_contribution_handler.py.

     def on_completed(self) -> None:
         # Confirm that there has been at least one contribution, otherwise the
         # MPC is invalid.
         if not exists(TRANSCRIPT_FILE):
             raise Exception("no contributions made")
  
         # Perform a validation of the full transcript
         mpc_valid = self.powersoftau.verify_transcript(
             self.state.num_valid_contributions)
         if not mpc_valid:
             raise Exception("error in MPC transcript")
  
         # If all is well, move the final challenge file
         rename(CHALLENGE_FILE, FINAL_OUTPUT)
         rename(TRANSCRIPT_FILE, FINAL_TRANSCRIPT)
  
         # Notify that handler execution completed
         print("Phase 1 coordinator correctly executed.")
         print("(CTRL-C to stop the server)")
  

◆ process_contribution()

bool coordinator.phase1_contribution_handler.Phase1ContributionHandler.process_contribution	(		self,
		int	contribution_idx,
		str	file_name
	)

Process the given uploaded file as a contribution. If any errors are
found, throw an exception with an appropriate message, or return false.

Reimplemented from coordinator.icontributionhandler.IContributionHandler.

Definition at line 131 of file phase1_contribution_handler.py.

     def process_contribution(
             self, contribution_idx: int, file_name: str) -> bool:
  
         rename(file_name, RESPONSE_FILE)
         contribution_valid = self.powersoftau.verify_contribution()
         if contribution_valid:
             if not exists(NEW_CHALLENGE_FILE):
                 raise Exception("unknown error creating new challenge")
  
             # concatenate part of response into transcript
             self.powersoftau.append_response_to_transcript(
                 RESPONSE_FILE, TRANSCRIPT_FILE)
  
             # update internal state
             self.state.on_valid_contribution()
             self._save_state()
  
             # move new_challenge to be the next challenge
             rename(NEW_CHALLENGE_FILE, CHALLENGE_FILE)
             return True
  
         return False
  