coordinator.client.Client Class Reference

Public Member Functions
def	__init__ (self, str base_url, Optional[str] cert_path=None, bool insecure=False)
ContributorList	get_contributors (self)
ServerState	get_state (self)
None	get_challenge (self, str challenge_file)
None	push_contribution (self, str response_file, bytes response_digest, VerificationKey verification_key, Signature signature)

Public Attributes
	base_url

Detailed Description

Definition at line 21 of file client.py.

Constructor & Destructor Documentation

__init__()

def coordinator.client.Client.__init__	(		self,
		str	base_url,
		Optional[str]	cert_path = None,
		bool	insecure = False
	)

Definition at line 23 of file client.py.

    def __init__(
            self,
            base_url: str,
            cert_path: Optional[str] = None,
            insecure: bool = False):
        assert not cert_path or exists(cert_path)
        self.base_url = base_url
        self.verify: Union[bool, str, None] = False if insecure else cert_path
 

Member Function Documentation

get_challenge()

None coordinator.client.Client.get_challenge	(		self,
		str	challenge_file
	)

GET /challenge request, downloading to file

Definition at line 62 of file client.py.

    def get_challenge(self, challenge_file: str) -> None:
        """
        GET /challenge request, downloading to file
        """
        # Contributors should be notified of their turn AFTER processing has
        # completed on the previous contribution. However, it's possible for
        # the next contributor, knowing his turn is next, to be waiting for
        # processing to complete. Hence we loop with a message if the server
        # claims to be temporarily unavailable.
        def _get_challenge() -> Response:
            return get(
                join(self.base_url, "challenge"),
                stream=True,
                verify=self.verify)
 
        while True:
            with _get_challenge() as resp:
                if resp.status_code == 503:
                    print(SERVER_BUSY_503_CLIENT_MSG)
                    time.sleep(5.0)
                    continue
 
                resp.raise_for_status()
                with open(challenge_file, "wb") as out_f:
                    for chunk in resp.iter_content(chunk_size=CHUNK_SIZE):
                        out_f.write(chunk)
                break
 

Here is the call graph for this function:

get_contributors()

ContributorList coordinator.client.Client.get_contributors

(

self

)

GET /contributors
Get the status of the server.

Definition at line 32 of file client.py.

    def get_contributors(self) -> ContributorList:
        """
        GET /contributors
        Get the status of the server.
        """
        while True:
            resp = get(join(self.base_url, "contributors"), verify=self.verify)
            if resp.status_code == 503:
                print(SERVER_BUSY_503_CLIENT_MSG)
                time.sleep(5.0)
                continue
 
            resp.raise_for_status()
            return ContributorList.from_json(resp.content.decode())
 

Here is the call graph for this function:

get_state()

ServerState coordinator.client.Client.get_state

(

self

)

GET /state
Get the status of the server.

Definition at line 47 of file client.py.

    def get_state(self) -> ServerState:
        """
        GET /state
        Get the status of the server.
        """
        while True:
            resp = get(join(self.base_url, "state"), verify=self.verify)
            if resp.status_code == 503:
                print(SERVER_BUSY_503_CLIENT_MSG)
                time.sleep(5.0)
                continue
 
            resp.raise_for_status()
            return ServerState.from_json(resp.content.decode())
 

Here is the call graph for this function:

push_contribution()

None coordinator.client.Client.push_contribution	(		self,
		str	response_file,
		bytes	response_digest,
		VerificationKey	verification_key,
		Signature	signature
	)

POST /contribute, uploading from file with all authentication headers

Definition at line 90 of file client.py.

    def push_contribution(
            self,
            response_file: str,
            response_digest: bytes,
            verification_key: VerificationKey,
            signature: Signature) -> None:
        """
        POST /contribute, uploading from file with all authentication headers
        """
        headers = {
            'X-MPC-Digest': export_digest(response_digest),
            'X-MPC-Public-Key': export_verification_key(verification_key),
            'X-MPC-Signature': export_signature(signature),
        }
        with open(response_file, "rb") as upload_f:
            resp = post(
                join(self.base_url, "contribute"),
                files={'response': upload_f},
                headers=headers,
                verify=self.verify)
            resp.raise_for_status()

Here is the call graph for this function:

Member Data Documentation

base_url

coordinator.client.Client.base_url

Definition at line 25 of file client.py.

---

The documentation for this class was generated from the following file:

• /home/runner/work/zeth/zeth/mpc/coordinator/client.py