Secagg

def __init__(
    self,
    researcher_id: str,
    secagg_id: str,
    parties: List[str],
    experiment_id: Union[str, None],
):
    """Constructor of the class.

    Args:
        researcher_id: ID of the researcher that requests setup
        secagg_id: ID of secagg context element for this setup request
        parties: List of parties participating in the secagg context element setup
        experiment_id: ID of the experiment to which this secagg context element
            is attached

    Raises:
        FedbiomedSecaggError: bad argument type or value
    """
    errmess: str = ""
    if len(parties) < self._min_num_parties:
        errmess = (
            f"{ErrorNumbers.FB318.value}: bad parameter `parties` : {parties} : need  "
            f"at least {self._min_num_parties} parties for secure aggregation, but got "
            f"{len(parties)}"
        )

    if researcher_id is None:
        errmess = (
            f"{ErrorNumbers.FB318.value}: argument `researcher_id` must be a non-None value"
        )

    if errmess:
        # if one of the above condition is met, raise error
        logger.error(errmess)
        raise FedbiomedSecaggError(errmess)

    # assign argument values
    self._researcher_id = researcher_id
    self._secagg_id = secagg_id
    self._experiment_id = experiment_id
    self._parties = parties
    self._element: SecaggElementTypes = None

def __init__(
        self,
        *args,
        n2n_router: NodeToNodeRouter,
        grpc_client: GrpcController,
        pending_requests: EventWaitExchange,
        controller_data: EventWaitExchange,
        **kwargs,
):
    """Constructor of the class.

    Args:
        n2n_router: object managing node to node messages
        grpc_client: object managing the communication with other components
        pending_requests: object for receiving overlay node to node messages
        controller_data: object for passing data to the node controller
        *args: Please see [SecaggBaseSetup]
        **kwargs: Please see [SecaggBaseSetup]
    Raises:
        FedbiomedSecaggError: bad argument type or value
    """

    super().__init__(*args, **kwargs)

    # self._secagg_manager = SKManager
    self._n2n_router = n2n_router
    self._grpc_client = grpc_client
    self._pending_requests = pending_requests
    self._controller_data = controller_data

def __init__(
    self,
    secagg_arguments: Dict[str, Any],
    experiment_id: str
) -> None:
    """Constructor of the class"""

    self.use_secagg: bool = False
    self.scheme: _SecaggSchemeRound | None = None

    if not secagg_arguments and environ["FORCE_SECURE_AGGREGATION"]:
        raise FedbiomedSecureAggregationError(
            f"{ErrorNumbers.FB318.value}: Node requires to apply secure aggregation but "
            f"training request does not define it.")

    if secagg_arguments:
        if not environ["SECURE_AGGREGATION"]:
            raise FedbiomedSecureAggregationError(
                f"{ErrorNumbers.FB318.value} Requesting secure aggregation while "
                "it's not activated on the node."
            )

        sn = secagg_arguments.get('secagg_scheme')

        if sn is None:
            raise FedbiomedSecureAggregationError(f"{ErrorNumbers.FB318.value}: Secagg scheme value missing in "
                                                  "the argument `secagg_arguments`")
        try:
            _scheme = SecureAggregationSchemes(sn)
        except ValueError as e:
            raise FedbiomedSecureAggregationError(
                f"{ErrorNumbers.FB318.value}: Bad secagg scheme value in train request: {sn}"
            ) from e

        self.scheme = SecaggRound.element2class[_scheme.value](secagg_arguments, experiment_id)
        self.use_secagg = True

def __init__(
        self,
        *args,
        n2n_router: NodeToNodeRouter,
        grpc_client: GrpcController,
        pending_requests: EventWaitExchange,
        controller_data: EventWaitExchange,
        **kwargs,
):
    """Constructor of the class.

    Args:
        n2n_router: object managing node to node messages
        grpc_client: object managing the communication with other components
        pending_requests: object for receiving overlay node to node messages
        controller_data: object for passing data to the node controller
        *args: Please see [SecaggBaseSetup]
        **kwargs: Please see [SecaggBaseSetup]
    Raises:
        FedbiomedSecaggError: bad argument type or value
    """

    super().__init__(*args, **kwargs)

    # self._secagg_manager = SKManager
    self._n2n_router = n2n_router
    self._grpc_client = grpc_client
    self._pending_requests = pending_requests
    self._controller_data = controller_data

def __init__(self, element: int, **kwargs):
    """Constructor of the class"""
    self._element = element
    self.kwargs = kwargs