# stdlib
from copy import deepcopy
from functools import reduce
from typing import Any
from typing import Dict
from typing import Optional
from typing import Union
from uuid import UUID

# third party
import numpy as np

# relative
from ....common.uid import UID
from ....store.storeable_object import StorableObject
from ....tensor.autodp.phi_tensor import PhiTensor
from ....tensor.smpc import context
from ....tensor.smpc import utils
from ....tensor.smpc.share_tensor import ShareTensor
from ....tensor.smpc.utils import count_wraps
from ...abstract.node import AbstractNode
from .beaver_action import BeaverAction
from .greenlets_switch import beaver_retrieve_object
from .greenlets_switch import crypto_store_retrieve_object


def get_id_at_location_from_op(seed: int, operation_str: str) -> UID:
    generator = np.random.default_rng(seed)
    return UID(UUID(bytes=generator.bytes(16)))


def private_mul(x: ShareTensor, y: ShareTensor, op_str: str) -> ShareTensor:
    """Performs SMPC Private Multiplication using Beaver Triples.

    Args:
        x (ShareTensor): input share tensor
        y (ShareTensor): input share tensor

    Returns:
        res (ShareTensor): Result of the operation.
    """
    seed_id_locations = context.SMPC_CONTEXT.get("seed_id_locations", None)
    if seed_id_locations is None:
        raise ValueError(
            f"Input seed : {seed_id_locations} for private multiplication should not None"
        )
    generator = np.random.default_rng(seed_id_locations)
    _ = UID(
        UUID(bytes=generator.bytes(16))
    )  # Ignore first one as it is used for result.
    eps_id = UID(UUID(bytes=generator.bytes(16)))
    delta_id = UID(UUID(bytes=generator.bytes(16)))
    ring_size = utils.get_ring_size(x.ring_size, y.ring_size)
    a_shape = tuple(x.shape)
    b_shape = tuple(y.shape)

    # TODO: Make beaver retrieval context less, this might fail when there are several
    # parallel multiplications.
    a_share, b_share, c_share = crypto_store_retrieve_object(
        f"beaver_{op_str}",
        a_shape=a_shape,
        b_shape=b_shape,
        ring_size=ring_size,
        remove=True,
    )

    node = context.SMPC_CONTEXT.get("node", None)
    # SMPC Multiplication

    # Phase 1: Communication Phase (Beaver dispatch)
    spdz_mask(x, y, eps_id, delta_id, a_share, b_share, node)

    # Phase 2: Share Reconstruction Phase:
    res = spdz_multiply(x, y, op_str, eps_id, delta_id, a_share, b_share, c_share, node)

    return res


def spdz_mask(
    x: ShareTensor,
    y: ShareTensor,
    eps_id: UID,
    delta_id: UID,
    a_share: ShareTensor,
    b_share: ShareTensor,
    node: Optional[AbstractNode] = None,
) -> None:

    if node is None:
        raise ValueError("Node context should be passed to spdz mask")

    clients = ShareTensor.login_clients(parties_info=x.parties_info)

    eps = x - a_share  # beaver intermediate values.
    delta = y - b_share

    client_id_map = {client.id: client for client in clients}
    curr_client = client_id_map[node.id]  # type: ignore
    beaver_action = BeaverAction(
        values=[eps, delta],
        locations=[eps_id, delta_id],
        address=curr_client.address,
    )
    beaver_action.execute_action(node, None)

    for _, client in enumerate(clients):
        if client != curr_client:
            beaver_action.address = client.address
            client.send_immediate_msg_without_reply(msg=beaver_action)


def spdz_multiply(
    x: ShareTensor,
    y: ShareTensor,
    op_str: str,
    eps_id: UID,
    delta_id: UID,
    a_share: ShareTensor,
    b_share: ShareTensor,
    c_share: ShareTensor,
    node: Optional[Any] = None,
) -> ShareTensor:

    nr_parties = x.nr_parties
    ring_size = x.ring_size

    eps = beaver_retrieve_object(node, eps_id, nr_parties)  # type: ignore
    delta = beaver_retrieve_object(node, delta_id, nr_parties)  # type: ignore

    eps: ShareTensor = sum(eps.data)  # type: ignore
    delta: ShareTensor = sum(delta.data)  # type: ignore

    op = ShareTensor.get_op(ring_size, op_str)
    add_op = ShareTensor.get_op(ring_size, "add")

    eps_b = op(eps.child, b_share.child)  # type: ignore
    delta_a = op(a_share.child, delta.child)  # type: ignore

    tensor = reduce(add_op, [c_share.child, eps_b, delta_a])
    if x.rank == 0:
        eps_delta = op(eps.child, delta.child)  # type: ignore
        tensor = add_op(tensor, eps_delta)

    share = x.copy_tensor()
    share.child = tensor

    return share


def public_divide(x: ShareTensor, y: Union[int, np.integer]) -> ShareTensor:
    """Performs SMPC Public Division.

    Args:
        x (ShareTensor): input share tensor
        y (Union[int, np.integer]): input share tensor

    Returns:
        res (ShareTensor): Result of the operation.
    """
    seed_id_locations = context.FPT_CONTEXT.get("seed_id_locations", None)
    if seed_id_locations is None:
        raise ValueError(
            f"Input seed : {seed_id_locations} for public  division should not None"
        )
    generator = np.random.default_rng(seed_id_locations)
    # SKIPPING first 3 location as they are used for multiplication.
    for _ in range(3):
        _ = UID(
            UUID(bytes=generator.bytes(16))
        )  # Ignore first one as it is used for result.
    z_id = UID(UUID(bytes=generator.bytes(16)))  # id for result of x+r

    ring_size = x.ring_size
    shape = tuple(x.shape)

    # TODO: Make  retrieval context less, this might fail when there are several
    # parallel division.
    r_sh, theta_r_sh = crypto_store_retrieve_object(
        "beaver_wraps",
        shape=shape,
        ring_size=ring_size,
        remove=True,
    )

    node = context.SMPC_CONTEXT.get("node", None)
    # SMPC Public Division

    # Phase 1: Communication Phase (Beaver dispatch)
    divide_mask(x, r_sh, z_id, node)

    # Phase 2: Share Corretion Phase:
    theta_x = divide_wrap_correction(x, y, z_id, r_sh, theta_r_sh, node)

    x.child = np.trunc(x.child / y).astype(x.child.dtype)
    # To avoid out-of-bounds when y is small
    res = x - theta_x * 4 * ((x.ring_size // 4) // y)

    return res


def divide_mask(
    x: ShareTensor,
    r: ShareTensor,
    z_id: UID,
    node: Optional[AbstractNode] = None,
) -> None:

    if node is None:
        raise ValueError("Node context should be passed to spdz mask")

    clients = ShareTensor.login_clients(parties_info=x.parties_info)

    z = x + r

    client_id_map = {client.id: client for client in clients}
    curr_client = client_id_map[node.id]  # type: ignore
    beaver_action = BeaverAction(
        values=[z],
        locations=[z_id],
        address=curr_client.address,
    )
    beaver_action.execute_action(node, None)

    for _, client in enumerate(clients):
        if client != curr_client:
            beaver_action.address = client.address
            client.send_immediate_msg_without_reply(msg=beaver_action)


def divide_wrap_correction(
    x: ShareTensor,
    y: Union[int, np.integer],
    z_id: UID,
    r_share: ShareTensor,
    theta_r_sh: ShareTensor,
    node: Optional[AbstractNode] = None,
) -> ShareTensor:
    """Privately computes the number of wraparounds for a set a shares.
    Adapted From Crypten

    To do so, we note that:
        [theta_x] = theta_z + [beta_xr] - [theta_r] - [eta_xr]
    Where:
        [theta_x] is the wraps for a variable x
        [beta_xr] is the differential wraps for variables x and r
        [eta_xr]  is the plaintext wraps for variables x and r
    Note: Since [eta_xr] = 0 with probability 1 - |x| / Q for modulus Q, we
    can make the assumption that [eta_xr] = 0 with high probability.

    Args:
        x (ShareTensor): shares for which we want to compute the number of wraparounds
        y (Union[int, np.integer]): the number/tensor by which we divide
        r_share (ShareTensor): share for a random variable "r"
        theta_r_sh (ShareTensor): share for the number of wraparounds for "r"
        z_id (UID): UID which contains the z(z=x+r_share) from all parties
        node (Optional[Any]) : current node context.

    Returns:
        ShareTensor representing the number of wraparounds
    """
    nr_parties = x.nr_parties
    theta_x = x.copy_tensor()

    z_shares = beaver_retrieve_object(node, z_id, nr_parties).data  # type: ignore

    beta_xr = count_wraps([x.child, r_share.child])

    theta_x.child = beta_xr - theta_r_sh.child
    theta_z = count_wraps([share.child for share in z_shares])

    # TODO: We neglect calculation of Etaxr as it involves a comparision which bottlnecks
    # the computation, we assume Etaxr =0 , the probability of an error in the division
    # is low when we make this assumption.
    theta_x = theta_x + theta_z

    return theta_x


def _decomposition(x: ShareTensor, ring_size: int, bitwise: bool) -> None:
    seed_id_locations = context.SMPC_CONTEXT.get("seed_id_locations", None)
    node = context.SMPC_CONTEXT.get("node", None)
    read_permissions = context.SMPC_CONTEXT.get("read_permissions", None)
    if seed_id_locations is None or node is None or read_permissions is None:
        raise ValueError(
            f"Input values seed,node,read_permissions : {seed_id_locations,node,read_permissions}"
            + " for decomposition should not None"
        )

    local_decomposition(
        x, ring_size, bitwise, seed_id_locations, node, read_permissions
    )


def local_decomposition(
    x: ShareTensor,
    ring_size: int,
    bitwise: bool,
    seed_id_locations: int,
    node: Any,
    read_permissions: Dict[Any, Any],
) -> None:
    """Performs local decomposition to generate shares of shares.

    Args:
        x (ShareTensor) : input ShareTensor.
        ring_size (str) : Ring size to generate decomposed shares in.
        bitwise (bool): Perform bit level decomposition on bits if set.

    Returns:
        List[List[ShareTensor]]: Decomposed shares in the given ring size.
    """
    generator = np.random.default_rng(seed_id_locations)
    # Skip the first ID ,as it is used for None return type in run class method.
    _ = UID(UUID(bytes=generator.bytes(16)))

    tensor_values = context.tensor_values if context.tensor_values else None
    context.tensor_values = None

    rank = x.rank
    nr_parties = x.nr_parties
    numpy_type = utils.RING_SIZE_TO_TYPE[ring_size]
    shape = x.shape
    zero = np.zeros(shape, numpy_type)

    input_shares = []

    if bitwise:
        ring_bits = utils.get_nr_bits(x.ring_size)  # for bit-wise decomposition
        input_shares = [x.bit_extraction(idx) for idx in range(ring_bits)]
    else:
        input_shares.append(x)

    for share in input_shares:

        for i in range(nr_parties):
            id_at_location = UID(UUID(bytes=generator.bytes(16)))
            sh = x.copy_tensor()
            sh.ring_size = ring_size
            if rank != i:
                sh.child = deepcopy(zero)
            else:
                sh.child = deepcopy(share.child.astype(numpy_type))

            if tensor_values is not None:
                if isinstance(tensor_values.child, PhiTensor):
                    # Remove it when we move PC to share tensor.
                    if ring_size != 2:  # type: ignore
                        sh.child = tensor_values.child.child.encode(sh.child)
                    tensor_values.child.child.child = sh
                else:
                    tensor_values.child = sh
                data = tensor_values
            else:
                data = sh

            store_obj = StorableObject(
                id=id_at_location,
                data=data,
                read_permissions=read_permissions,
            )

            node.store[id_at_location] = store_obj


# Function mapped with seed in RunClassMethodSMPC
ACTION_FUNCTIONS = ["__add__", "__sub__", "__mul__", "bit_decomposition"]

# #############################################################
# ### NOTE: DO NOT DELETE COMMENTED CODE,TO BE USED LATER #####
# #############################################################


# ##########ADD,SUB OPS################
# def smpc_basic_op(
#     op_str: str,
#     nr_parties: int,
#     self_id: UID,
#     other_id: UID,
#     seed_id_locations: int,
#     node: Any,
# ) -> List[SMPCActionMessage]:
#     # relative
#     from ..... import Tensor

#     """Generator for SMPC public/private operations add/sub"""

#     generator = np.random.default_rng(seed_id_locations)
#     result_id = UID(UUID(bytes=generator.bytes(16)))
#     other = node.store[other_id].data

#     actions = []
#     if isinstance(other, (ShareTensor, Tensor)):
#         # All parties should add the other share if empty list
#         actions.append(
#             SMPCActionMessage(
#                 f"mpc_{op_str}",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )
#     else:
#         actions.append(
#             SMPCActionMessage(
#                 "mpc_noop",
#                 self_id=self_id,
#                 args_id=[],
#                 kwargs_id={},
#                 ranks_to_run_action=list(range(1, nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )

#         # Only rank 0 (the first party) would do the add/sub for the public value
#         actions.append(
#             SMPCActionMessage(
#                 f"mpc_{op_str}",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 ranks_to_run_action=[0],
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )

#     return actions


# def get_action_generator_from_op(
#     operation_str: str, nr_parties: int
# ) -> Callable[[UID, UID, int, Any], Any]:
#     """ "
#     Get the generator for the operation provided by the argument
#     Arguments:
#         operation_str (str): the name of the operation

#     """
#     return functools.partial(MAP_FUNC_TO_ACTION[operation_str], nr_parties)


# # Given an SMPC Action map it to an action constructor
# MAP_FUNC_TO_ACTION: Dict[
#     str, Callable[[int, UID, UID, int, Any], List[SMPCActionMessage]]
# ] = {
#     "__add__": functools.partial(smpc_basic_op, "add"),
#     "__sub__": functools.partial(smpc_basic_op, "sub"),
#     "__mul__": smpc_mul,  # type: ignore
#     "bit_decomposition": bit_decomposition,  # type: ignore
#     # "__gt__": smpc_gt,  # type: ignore TODO: this should be added back when we have only one action
# }


# # Map given an action map it to a function that should be run on the shares"
# _MAP_ACTION_TO_FUNCTION: Dict[str, Callable[..., Any]] = {
#     "mpc_add": functools.partial(apply_function, op_str="add"),
#     "mpc_sub": functools.partial(apply_function, op_str="sub"),
#     "mpc_mul": functools.partial(apply_function, op_str="mul"),
#     "spdz_mask": spdz_mask,
#     "spdz_multiply": spdz_multiply,
#     "local_decomposition": local_decomposition,
#     "mpc_noop": deepcopy,
# }


# ###################PRIVATE MUL#############3
# def smpc_mul(
#     nr_parties: int,
#     self_id: UID,
#     other_id: UID,
#     seed_id_locations: Optional[int] = None,
#     node: Optional[Any] = None,
# ) -> SMPCActionSeqBatchMessage:
#     """Generator for the smpc_mul with a public value"""
#     # relative
#     from ..... import Tensor

#     if seed_id_locations is None or node is None:
#         raise ValueError(
#             f"The values seed_id_locations{seed_id_locations}, Node:{node} should not be None"
#         )
#     generator = np.random.default_rng(seed_id_locations)
#     result_id = UID(UUID(bytes=generator.bytes(16)))
#     _self = node.store[self_id].data
#     other = node.store[other_id].data

#     actions = []
#     if isinstance(other, (ShareTensor, Tensor)):

#         if isinstance(other, ShareTensor):
#             ring_size = other.ring_size
#         else:
#             ring_size = other.child.child.ring_size

#         mask_result = UID(UUID(bytes=generator.bytes(16)))
#         eps_id = UID(UUID(bytes=generator.bytes(16)))
#         delta_id = UID(UUID(bytes=generator.bytes(16)))
#         a_shape = tuple(_self.shape)
#         b_shape = tuple(other.shape)

#         a_share, b_share, c_share = crypto_store_retrieve_object(
#             "beaver_mul",
#             a_shape=a_shape,
#             b_shape=b_shape,
#             ring_size=ring_size,
#             remove=True,
#         )

#         actions.append(
#             SMPCActionMessage(
#                 "spdz_mask",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 kwargs={
#                     "eps_id": eps_id,
#                     "delta_id": delta_id,
#                     "a_share": a_share,
#                     "b_share": b_share,
#                     "c_share": c_share,
#                 },
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=mask_result,
#                 address=node.address,
#             )
#         )

#         actions.append(
#             SMPCActionMessage(
#                 "spdz_multiply",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 kwargs={
#                     "eps_id": eps_id,
#                     "delta_id": delta_id,
#                     "a_share": a_share,
#                     "b_share": b_share,
#                     "c_share": c_share,
#                 },
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )

#     else:
#         # All ranks should multiply by that public value
#         actions.append(
#             SMPCActionMessage(
#                 "mpc_mul",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )
#     batch = SMPCActionSeqBatchMessage(smpc_actions=actions, address=node.address)
#     return batch


# ###################### BIT DECOMPOSITION ####################
# def bit_decomposition(
#     nr_parties: int,
#     self_id: UID,
#     ring_size: UID,
#     bitwise: UID,
#     seed_id_locations: int,
#     node: Any,
# ) -> List[SMPCActionMessage]:
#     generator = np.random.default_rng(seed_id_locations)
#     result_id = UID(UUID(bytes=generator.bytes(16)))

#     actions = []

#     actions.append(
#         SMPCActionMessage(
#             "local_decomposition",
#             self_id=self_id,
#             args_id=[ring_size, bitwise],
#             kwargs_id={},
#             kwargs={"seed_id_locations": str(seed_id_locations)},
#             ranks_to_run_action=list(range(nr_parties)),
#             result_id=result_id,
#             address=node.address,
#         )
#     )

#     return actions


# ###########################COMPARISON#####################
#
# def smpc_gt(
#     nr_parties: int,
#     self_id: UID,
#     other_id: UID,
#     seed_id_locations: int,
#     node: Any,
#     client: Any,
# ) -> List[SMPCActionMessage]:
#     """Generator for the smpc_mul with a public value"""
#     generator = np.random.default_rng(seed_id_locations)

#     result_id = UID(UUID(bytes=generator.bytes(16)))
#     sub_result = UID(UUID(bytes=generator.bytes(16)))

#     x = node.store.get(self_id).data  # noqa
#     y = node.store.get(other_id).data

#     if not isinstance(y, ShareTensor):
#         raise ValueError("Only private compare works at the moment")

#     actions = []
#     actions.append(
#         SMPCActionMessage(
#             "mpc_sub",
#             self_id=self_id,
#             args_id=[other_id],
#             kwargs_id={},
#             ranks_to_run_action=list(range(nr_parties)),
#             result_id=sub_result,
#             address=client.address,
#         )
#     )

#     actions.append(
#         SMPCActionMessage(
#             "bit_decomposition",
#             self_id=sub_result,
#             args_id=[],
#             # TODO: This value needs to be changed to something else and probably used
#             # directly the przs_generator from ShareTensor - check bit_decomposition function
#             kwargs_id={},
#             ranks_to_run_action=list(range(nr_parties)),
#             result_id=result_id,
#             address=client.address,
#         )
#     )
#     return actions

# stdlib
from copy import deepcopy
from functools import reduce
from typing import Any
from typing import Dict
from typing import Optional
from typing import Union
from uuid import UUID

# third party
import numpy as np

# relative
from ....common.uid import UID
from ....store.storeable_object import StorableObject
from ....tensor.autodp.phi_tensor import PhiTensor
from ....tensor.smpc import context
from ....tensor.smpc import utils
from ....tensor.smpc.share_tensor import ShareTensor
from ....tensor.smpc.utils import count_wraps
from ...abstract.node import AbstractNode
from .beaver_action import BeaverAction
from .greenlets_switch import beaver_retrieve_object
from .greenlets_switch import crypto_store_retrieve_object


def get_id_at_location_from_op(seed: int, operation_str: str) -> UID:
    generator = np.random.default_rng(seed)
    return UID(UUID(bytes=generator.bytes(16)))


def private_mul(x: ShareTensor, y: ShareTensor, op_str: str) -> ShareTensor:
    """Performs SMPC Private Multiplication using Beaver Triples.

    Args:
        x (ShareTensor): input share tensor
        y (ShareTensor): input share tensor

    Returns:
        res (ShareTensor): Result of the operation.
    """
    seed_id_locations = context.SMPC_CONTEXT.get("seed_id_locations", None)
    if seed_id_locations is None:
        raise ValueError(
            f"Input seed : {seed_id_locations} for private multiplication should not None"
        )
    generator = np.random.default_rng(seed_id_locations)
    _ = UID(
        UUID(bytes=generator.bytes(16))
    )  # Ignore first one as it is used for result.
    eps_id = UID(UUID(bytes=generator.bytes(16)))
    delta_id = UID(UUID(bytes=generator.bytes(16)))
    ring_size = utils.get_ring_size(x.ring_size, y.ring_size)
    a_shape = tuple(x.shape)
    b_shape = tuple(y.shape)

    # TODO: Make beaver retrieval context less, this might fail when there are several
    # parallel multiplications.
    a_share, b_share, c_share = crypto_store_retrieve_object(
        f"beaver_{op_str}",
        a_shape=a_shape,
        b_shape=b_shape,
        ring_size=ring_size,
        remove=True,
    )

    node = context.SMPC_CONTEXT.get("node", None)
    # SMPC Multiplication

    # Phase 1: Communication Phase (Beaver dispatch)
    spdz_mask(x, y, eps_id, delta_id, a_share, b_share, node)

    # Phase 2: Share Reconstruction Phase:
    res = spdz_multiply(x, y, op_str, eps_id, delta_id, a_share, b_share, c_share, node)

    return res


def spdz_mask(
    x: ShareTensor,
    y: ShareTensor,
    eps_id: UID,
    delta_id: UID,
    a_share: ShareTensor,
    b_share: ShareTensor,
    node: Optional[AbstractNode] = None,
) -> None:

    if node is None:
        raise ValueError("Node context should be passed to spdz mask")

    clients = ShareTensor.login_clients(parties_info=x.parties_info)

    eps = x - a_share  # beaver intermediate values.
    delta = y - b_share

    client_id_map = {client.id: client for client in clients}
    curr_client = client_id_map[node.id]  # type: ignore
    beaver_action = BeaverAction(
        values=[eps, delta],
        locations=[eps_id, delta_id],
        address=curr_client.address,
    )
    beaver_action.execute_action(node, None)

    for _, client in enumerate(clients):
        if client != curr_client:
            beaver_action.address = client.address
            client.send_immediate_msg_without_reply(msg=beaver_action)


def spdz_multiply(
    x: ShareTensor,
    y: ShareTensor,
    op_str: str,
    eps_id: UID,
    delta_id: UID,
    a_share: ShareTensor,
    b_share: ShareTensor,
    c_share: ShareTensor,
    node: Optional[Any] = None,
) -> ShareTensor:

    nr_parties = x.nr_parties
    ring_size = x.ring_size

    eps = beaver_retrieve_object(node, eps_id, nr_parties)  # type: ignore
    delta = beaver_retrieve_object(node, delta_id, nr_parties)  # type: ignore

    eps: ShareTensor = sum(eps.data)  # type: ignore
    delta: ShareTensor = sum(delta.data)  # type: ignore

    op = ShareTensor.get_op(ring_size, op_str)
    add_op = ShareTensor.get_op(ring_size, "add")

    eps_b = op(eps.child, b_share.child)  # type: ignore
    delta_a = op(a_share.child, delta.child)  # type: ignore

    tensor = reduce(add_op, [c_share.child, eps_b, delta_a])
    if x.rank == 0:
        eps_delta = op(eps.child, delta.child)  # type: ignore
        tensor = add_op(tensor, eps_delta)

    share = x.copy_tensor()
    share.child = tensor

    return share


def public_divide(x: ShareTensor, y: Union[int, np.integer]) -> ShareTensor:
    """Performs SMPC Public Division.

    Args:
        x (ShareTensor): input share tensor
        y (Union[int, np.integer]): input share tensor

    Returns:
        res (ShareTensor): Result of the operation.
    """
    seed_id_locations = context.FPT_CONTEXT.get("seed_id_locations", None)
    if seed_id_locations is None:
        raise ValueError(
            f"Input seed : {seed_id_locations} for public  division should not None"
        )
    generator = np.random.default_rng(seed_id_locations)
    # SKIPPING first 3 location as they are used for multiplication.
    for _ in range(3):
        _ = UID(
            UUID(bytes=generator.bytes(16))
        )  # Ignore first one as it is used for result.
    z_id = UID(UUID(bytes=generator.bytes(16)))  # id for result of x+r

    ring_size = x.ring_size
    shape = tuple(x.shape)

    # TODO: Make  retrieval context less, this might fail when there are several
    # parallel division.
    r_sh, theta_r_sh = crypto_store_retrieve_object(
        "beaver_wraps",
        shape=shape,
        ring_size=ring_size,
        remove=True,
    )

    node = context.SMPC_CONTEXT.get("node", None)
    # SMPC Public Division

    # Phase 1: Communication Phase (Beaver dispatch)
    divide_mask(x, r_sh, z_id, node)

    # Phase 2: Share Corretion Phase:
    theta_x = divide_wrap_correction(x, y, z_id, r_sh, theta_r_sh, node)

    x.child = np.trunc(x.child / y).astype(x.child.dtype)
    # To avoid out-of-bounds when y is small
    res = x - theta_x * 4 * ((x.ring_size // 4) // y)

    return res


def divide_mask(
    x: ShareTensor,
    r: ShareTensor,
    z_id: UID,
    node: Optional[AbstractNode] = None,
) -> None:

    if node is None:
        raise ValueError("Node context should be passed to spdz mask")

    clients = ShareTensor.login_clients(parties_info=x.parties_info)

    z = x + r

    client_id_map = {client.id: client for client in clients}
    curr_client = client_id_map[node.id]  # type: ignore
    beaver_action = BeaverAction(
        values=[z],
        locations=[z_id],
        address=curr_client.address,
    )
    beaver_action.execute_action(node, None)

    for _, client in enumerate(clients):
        if client != curr_client:
            beaver_action.address = client.address
            client.send_immediate_msg_without_reply(msg=beaver_action)


def divide_wrap_correction(
    x: ShareTensor,
    y: Union[int, np.integer],
    z_id: UID,
    r_share: ShareTensor,
    theta_r_sh: ShareTensor,
    node: Optional[AbstractNode] = None,
) -> ShareTensor:
    """Privately computes the number of wraparounds for a set a shares.
    Adapted From Crypten

    To do so, we note that:
        [theta_x] = theta_z + [beta_xr] - [theta_r] - [eta_xr]
    Where:
        [theta_x] is the wraps for a variable x
        [beta_xr] is the differential wraps for variables x and r
        [eta_xr]  is the plaintext wraps for variables x and r
    Note: Since [eta_xr] = 0 with probability 1 - |x| / Q for modulus Q, we
    can make the assumption that [eta_xr] = 0 with high probability.

    Args:
        x (ShareTensor): shares for which we want to compute the number of wraparounds
        y (Union[int, np.integer]): the number/tensor by which we divide
        r_share (ShareTensor): share for a random variable "r"
        theta_r_sh (ShareTensor): share for the number of wraparounds for "r"
        z_id (UID): UID which contains the z(z=x+r_share) from all parties
        node (Optional[Any]) : current node context.

    Returns:
        ShareTensor representing the number of wraparounds
    """
    nr_parties = x.nr_parties
    theta_x = x.copy_tensor()

    z_shares = beaver_retrieve_object(node, z_id, nr_parties).data  # type: ignore

    beta_xr = count_wraps([x.child, r_share.child])

    theta_x.child = beta_xr - theta_r_sh.child
    theta_z = count_wraps([share.child for share in z_shares])

    # TODO: We neglect calculation of Etaxr as it involves a comparision which bottlnecks
    # the computation, we assume Etaxr =0 , the probability of an error in the division
    # is low when we make this assumption.
    theta_x = theta_x + theta_z

    return theta_x


def _decomposition(x: ShareTensor, ring_size: int, bitwise: bool) -> None:
    seed_id_locations = context.SMPC_CONTEXT.get("seed_id_locations", None)
    node = context.SMPC_CONTEXT.get("node", None)
    read_permissions = context.SMPC_CONTEXT.get("read_permissions", None)
    if seed_id_locations is None or node is None or read_permissions is None:
        raise ValueError(
            f"Input values seed,node,read_permissions : {seed_id_locations,node,read_permissions}"
            + " for decomposition should not None"
        )

    local_decomposition(
        x, ring_size, bitwise, seed_id_locations, node, read_permissions
    )


def local_decomposition(
    x: ShareTensor,
    ring_size: int,
    bitwise: bool,
    seed_id_locations: int,
    node: Any,
    read_permissions: Dict[Any, Any],
) -> None:
    """Performs local decomposition to generate shares of shares.

    Args:
        x (ShareTensor) : input ShareTensor.
        ring_size (str) : Ring size to generate decomposed shares in.
        bitwise (bool): Perform bit level decomposition on bits if set.

    Returns:
        List[List[ShareTensor]]: Decomposed shares in the given ring size.
    """
    generator = np.random.default_rng(seed_id_locations)
    # Skip the first ID ,as it is used for None return type in run class method.
    _ = UID(UUID(bytes=generator.bytes(16)))

    tensor_values = context.tensor_values if context.tensor_values else None
    context.tensor_values = None

    rank = x.rank
    nr_parties = x.nr_parties
    numpy_type = utils.RING_SIZE_TO_TYPE[ring_size]
    shape = x.shape
    zero = np.zeros(shape, numpy_type)

    input_shares = []

    if bitwise:
        ring_bits = utils.get_nr_bits(x.ring_size)  # for bit-wise decomposition
        input_shares = [x.bit_extraction(idx) for idx in range(ring_bits)]
    else:
        input_shares.append(x)

    for share in input_shares:

        for i in range(nr_parties):
            id_at_location = UID(UUID(bytes=generator.bytes(16)))
            sh = x.copy_tensor()
            sh.ring_size = ring_size
            if rank != i:
                sh.child = deepcopy(zero)
            else:
                sh.child = deepcopy(share.child.astype(numpy_type))

            if tensor_values is not None:
                if isinstance(tensor_values.child, PhiTensor):
                    # Remove it when we move PC to share tensor.
                    if ring_size != 2:  # type: ignore
                        sh.child = tensor_values.child.child.encode(sh.child)
                    tensor_values.child.child.child = sh
                else:
                    tensor_values.child = sh
                data = tensor_values
            else:
                data = sh

            store_obj = StorableObject(
                id=id_at_location,
                data=data,
                read_permissions=read_permissions,
            )

            node.store[id_at_location] = store_obj


# Function mapped with seed in RunClassMethodSMPC
ACTION_FUNCTIONS = ["__add__", "__sub__", "__mul__", "bit_decomposition"]

# #############################################################
# ### NOTE: DO NOT DELETE COMMENTED CODE,TO BE USED LATER #####
# #############################################################


# ##########ADD,SUB OPS################
# def smpc_basic_op(
#     op_str: str,
#     nr_parties: int,
#     self_id: UID,
#     other_id: UID,
#     seed_id_locations: int,
#     node: Any,
# ) -> List[SMPCActionMessage]:
#     # relative
#     from ..... import Tensor

#     """Generator for SMPC public/private operations add/sub"""

#     generator = np.random.default_rng(seed_id_locations)
#     result_id = UID(UUID(bytes=generator.bytes(16)))
#     other = node.store[other_id].data

#     actions = []
#     if isinstance(other, (ShareTensor, Tensor)):
#         # All parties should add the other share if empty list
#         actions.append(
#             SMPCActionMessage(
#                 f"mpc_{op_str}",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )
#     else:
#         actions.append(
#             SMPCActionMessage(
#                 "mpc_noop",
#                 self_id=self_id,
#                 args_id=[],
#                 kwargs_id={},
#                 ranks_to_run_action=list(range(1, nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )

#         # Only rank 0 (the first party) would do the add/sub for the public value
#         actions.append(
#             SMPCActionMessage(
#                 f"mpc_{op_str}",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 ranks_to_run_action=[0],
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )

#     return actions


# def get_action_generator_from_op(
#     operation_str: str, nr_parties: int
# ) -> Callable[[UID, UID, int, Any], Any]:
#     """ "
#     Get the generator for the operation provided by the argument
#     Arguments:
#         operation_str (str): the name of the operation

#     """
#     return functools.partial(MAP_FUNC_TO_ACTION[operation_str], nr_parties)


# # Given an SMPC Action map it to an action constructor
# MAP_FUNC_TO_ACTION: Dict[
#     str, Callable[[int, UID, UID, int, Any], List[SMPCActionMessage]]
# ] = {
#     "__add__": functools.partial(smpc_basic_op, "add"),
#     "__sub__": functools.partial(smpc_basic_op, "sub"),
#     "__mul__": smpc_mul,  # type: ignore
#     "bit_decomposition": bit_decomposition,  # type: ignore
#     # "__gt__": smpc_gt,  # type: ignore TODO: this should be added back when we have only one action
# }


# # Map given an action map it to a function that should be run on the shares"
# _MAP_ACTION_TO_FUNCTION: Dict[str, Callable[..., Any]] = {
#     "mpc_add": functools.partial(apply_function, op_str="add"),
#     "mpc_sub": functools.partial(apply_function, op_str="sub"),
#     "mpc_mul": functools.partial(apply_function, op_str="mul"),
#     "spdz_mask": spdz_mask,
#     "spdz_multiply": spdz_multiply,
#     "local_decomposition": local_decomposition,
#     "mpc_noop": deepcopy,
# }


# ###################PRIVATE MUL#############3
# def smpc_mul(
#     nr_parties: int,
#     self_id: UID,
#     other_id: UID,
#     seed_id_locations: Optional[int] = None,
#     node: Optional[Any] = None,
# ) -> SMPCActionSeqBatchMessage:
#     """Generator for the smpc_mul with a public value"""
#     # relative
#     from ..... import Tensor

#     if seed_id_locations is None or node is None:
#         raise ValueError(
#             f"The values seed_id_locations{seed_id_locations}, Node:{node} should not be None"
#         )
#     generator = np.random.default_rng(seed_id_locations)
#     result_id = UID(UUID(bytes=generator.bytes(16)))
#     _self = node.store[self_id].data
#     other = node.store[other_id].data

#     actions = []
#     if isinstance(other, (ShareTensor, Tensor)):

#         if isinstance(other, ShareTensor):
#             ring_size = other.ring_size
#         else:
#             ring_size = other.child.child.ring_size

#         mask_result = UID(UUID(bytes=generator.bytes(16)))
#         eps_id = UID(UUID(bytes=generator.bytes(16)))
#         delta_id = UID(UUID(bytes=generator.bytes(16)))
#         a_shape = tuple(_self.shape)
#         b_shape = tuple(other.shape)

#         a_share, b_share, c_share = crypto_store_retrieve_object(
#             "beaver_mul",
#             a_shape=a_shape,
#             b_shape=b_shape,
#             ring_size=ring_size,
#             remove=True,
#         )

#         actions.append(
#             SMPCActionMessage(
#                 "spdz_mask",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 kwargs={
#                     "eps_id": eps_id,
#                     "delta_id": delta_id,
#                     "a_share": a_share,
#                     "b_share": b_share,
#                     "c_share": c_share,
#                 },
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=mask_result,
#                 address=node.address,
#             )
#         )

#         actions.append(
#             SMPCActionMessage(
#                 "spdz_multiply",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 kwargs={
#                     "eps_id": eps_id,
#                     "delta_id": delta_id,
#                     "a_share": a_share,
#                     "b_share": b_share,
#                     "c_share": c_share,
#                 },
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )

#     else:
#         # All ranks should multiply by that public value
#         actions.append(
#             SMPCActionMessage(
#                 "mpc_mul",
#                 self_id=self_id,
#                 args_id=[other_id],
#                 kwargs_id={},
#                 ranks_to_run_action=list(range(nr_parties)),
#                 result_id=result_id,
#                 address=node.address,
#             )
#         )
#     batch = SMPCActionSeqBatchMessage(smpc_actions=actions, address=node.address)
#     return batch


# ###################### BIT DECOMPOSITION ####################
# def bit_decomposition(
#     nr_parties: int,
#     self_id: UID,
#     ring_size: UID,
#     bitwise: UID,
#     seed_id_locations: int,
#     node: Any,
# ) -> List[SMPCActionMessage]:
#     generator = np.random.default_rng(seed_id_locations)
#     result_id = UID(UUID(bytes=generator.bytes(16)))

#     actions = []

#     actions.append(
#         SMPCActionMessage(
#             "local_decomposition",
#             self_id=self_id,
#             args_id=[ring_size, bitwise],
#             kwargs_id={},
#             kwargs={"seed_id_locations": str(seed_id_locations)},
#             ranks_to_run_action=list(range(nr_parties)),
#             result_id=result_id,
#             address=node.address,
#         )
#     )

#     return actions


# ###########################COMPARISON#####################
#
# def smpc_gt(
#     nr_parties: int,
#     self_id: UID,
#     other_id: UID,
#     seed_id_locations: int,
#     node: Any,
#     client: Any,
# ) -> List[SMPCActionMessage]:
#     """Generator for the smpc_mul with a public value"""
#     generator = np.random.default_rng(seed_id_locations)

#     result_id = UID(UUID(bytes=generator.bytes(16)))
#     sub_result = UID(UUID(bytes=generator.bytes(16)))

#     x = node.store.get(self_id).data  # noqa
#     y = node.store.get(other_id).data

#     if not isinstance(y, ShareTensor):
#         raise ValueError("Only private compare works at the moment")

#     actions = []
#     actions.append(
#         SMPCActionMessage(
#             "mpc_sub",
#             self_id=self_id,
#             args_id=[other_id],
#             kwargs_id={},
#             ranks_to_run_action=list(range(nr_parties)),
#             result_id=sub_result,
#             address=client.address,
#         )
#     )

#     actions.append(
#         SMPCActionMessage(
#             "bit_decomposition",
#             self_id=sub_result,
#             args_id=[],
#             # TODO: This value needs to be changed to something else and probably used
#             # directly the przs_generator from ShareTensor - check bit_decomposition function
#             kwargs_id={},
#             ranks_to_run_action=list(range(nr_parties)),
#             result_id=result_id,
#             address=client.address,
#         )
#     )
#     return actions

# stdlib # third party # relative Performs SMPC Private Multiplication using Beaver Triples.      Args:         x (ShareTensor): input share tensor         y (ShareTensor): input share tensor      Returns:         res (ShareTensor): Result of the operation. # Ignore first one as it is used for result. # TODO: Make beaver retrieval context less, this might fail when there are several # parallel multiplications. # SMPC Multiplication # Phase 1: Communication Phase (Beaver dispatch) # Phase 2: Share Reconstruction Phase: # beaver intermediate values. # type: ignore # type: ignore # type: ignore # type: ignore # type: ignore # type: ignore # type: ignore # type: ignore Performs SMPC Public Division.      Args:         x (ShareTensor): input share tensor         y (Union[int, np.integer]): input share tensor      Returns:         res (ShareTensor): Result of the operation. # SKIPPING first 3 location as they are used for multiplication. # Ignore first one as it is used for result. # id for result of x+r # TODO: Make  retrieval context less, this might fail when there are several # parallel division. # SMPC Public Division # Phase 1: Communication Phase (Beaver dispatch) # Phase 2: Share Corretion Phase: # To avoid out-of-bounds when y is small # type: ignore Privately computes the number of wraparounds for a set a shares.     Adapted From Crypten      To do so, we note that:         [theta_x] = theta_z + [beta_xr] - [theta_r] - [eta_xr]     Where:         [theta_x] is the wraps for a variable x         [beta_xr] is the differential wraps for variables x and r         [eta_xr]  is the plaintext wraps for variables x and r     Note: Since [eta_xr] = 0 with probability 1 - |x| / Q for modulus Q, we     can make the assumption that [eta_xr] = 0 with high probability.      Args:         x (ShareTensor): shares for which we want to compute the number of wraparounds         y (Union[int, np.integer]): the number/tensor by which we divide         r_share (ShareTensor): share for a random variable "r"         theta_r_sh (ShareTensor): share for the number of wraparounds for "r"         z_id (UID): UID which contains the z(z=x+r_share) from all parties         node (Optional[Any]) : current node context.      Returns:         ShareTensor representing the number of wraparounds # type: ignore # TODO: We neglect calculation of Etaxr as it involves a comparision which bottlnecks # the computation, we assume Etaxr =0 , the probability of an error in the division # is low when we make this assumption. Performs local decomposition to generate shares of shares.      Args:         x (ShareTensor) : input ShareTensor.         ring_size (str) : Ring size to generate decomposed shares in.         bitwise (bool): Perform bit level decomposition on bits if set.      Returns:         List[List[ShareTensor]]: Decomposed shares in the given ring size. # Skip the first ID ,as it is used for None return type in run class method. # for bit-wise decomposition # Remove it when we move PC to share tensor. # type: ignore # Function mapped with seed in RunClassMethodSMPC # ############################################################# # ### NOTE: DO NOT DELETE COMMENTED CODE,TO BE USED LATER ##### # ############################################################# # ##########ADD,SUB OPS################ # def smpc_basic_op( #     op_str: str, #     nr_parties: int, #     self_id: UID, #     other_id: UID, #     seed_id_locations: int, #     node: Any, # ) -> List[SMPCActionMessage]: #     # relative #     from ..... import Tensor #     """Generator for SMPC public/private operations add/sub""" #     generator = np.random.default_rng(seed_id_locations) #     result_id = UID(UUID(bytes=generator.bytes(16))) #     other = node.store[other_id].data #     actions = [] #     if isinstance(other, (ShareTensor, Tensor)): #         # All parties should add the other share if empty list #         actions.append( #             SMPCActionMessage( #                 f"mpc_{op_str}", #                 self_id=self_id, #                 args_id=[other_id], #                 kwargs_id={}, #                 ranks_to_run_action=list(range(nr_parties)), #                 result_id=result_id, #                 address=node.address, #             ) #         ) #     else: #         actions.append( #             SMPCActionMessage( #                 "mpc_noop", #                 self_id=self_id, #                 args_id=[], #                 kwargs_id={}, #                 ranks_to_run_action=list(range(1, nr_parties)), #                 result_id=result_id, #                 address=node.address, #             ) #         ) #         # Only rank 0 (the first party) would do the add/sub for the public value #         actions.append( #             SMPCActionMessage( #                 f"mpc_{op_str}", #                 self_id=self_id, #                 args_id=[other_id], #                 kwargs_id={}, #                 ranks_to_run_action=[0], #                 result_id=result_id, #                 address=node.address, #             ) #         ) #     return actions # def get_action_generator_from_op( #     operation_str: str, nr_parties: int # ) -> Callable[[UID, UID, int, Any], Any]: #     """ " #     Get the generator for the operation provided by the argument #     Arguments: #         operation_str (str): the name of the operation #     """ #     return functools.partial(MAP_FUNC_TO_ACTION[operation_str], nr_parties) # # Given an SMPC Action map it to an action constructor # MAP_FUNC_TO_ACTION: Dict[ #     str, Callable[[int, UID, UID, int, Any], List[SMPCActionMessage]] # ] = { #     "__add__": functools.partial(smpc_basic_op, "add"), #     "__sub__": functools.partial(smpc_basic_op, "sub"), #     "__mul__": smpc_mul,  # type: ignore #     "bit_decomposition": bit_decomposition,  # type: ignore #     # "__gt__": smpc_gt,  # type: ignore TODO: this should be added back when we have only one action # } # # Map given an action map it to a function that should be run on the shares" # _MAP_ACTION_TO_FUNCTION: Dict[str, Callable[..., Any]] = { #     "mpc_add": functools.partial(apply_function, op_str="add"), #     "mpc_sub": functools.partial(apply_function, op_str="sub"), #     "mpc_mul": functools.partial(apply_function, op_str="mul"), #     "spdz_mask": spdz_mask, #     "spdz_multiply": spdz_multiply, #     "local_decomposition": local_decomposition, #     "mpc_noop": deepcopy, # } # ###################PRIVATE MUL#############3 # def smpc_mul( #     nr_parties: int, #     self_id: UID, #     other_id: UID, #     seed_id_locations: Optional[int] = None, #     node: Optional[Any] = None, # ) -> SMPCActionSeqBatchMessage: #     """Generator for the smpc_mul with a public value""" #     # relative #     from ..... import Tensor #     if seed_id_locations is None or node is None: #         raise ValueError( #             f"The values seed_id_locations{seed_id_locations}, Node:{node} should not be None" #         ) #     generator = np.random.default_rng(seed_id_locations) #     result_id = UID(UUID(bytes=generator.bytes(16))) #     _self = node.store[self_id].data #     other = node.store[other_id].data #     actions = [] #     if isinstance(other, (ShareTensor, Tensor)): #         if isinstance(other, ShareTensor): #             ring_size = other.ring_size #         else: #             ring_size = other.child.child.ring_size #         mask_result = UID(UUID(bytes=generator.bytes(16))) #         eps_id = UID(UUID(bytes=generator.bytes(16))) #         delta_id = UID(UUID(bytes=generator.bytes(16))) #         a_shape = tuple(_self.shape) #         b_shape = tuple(other.shape) #         a_share, b_share, c_share = crypto_store_retrieve_object( #             "beaver_mul", #             a_shape=a_shape, #             b_shape=b_shape, #             ring_size=ring_size, #             remove=True, #         ) #         actions.append( #             SMPCActionMessage( #                 "spdz_mask", #                 self_id=self_id, #                 args_id=[other_id], #                 kwargs_id={}, #                 kwargs={ #                     "eps_id": eps_id, #                     "delta_id": delta_id, #                     "a_share": a_share, #                     "b_share": b_share, #                     "c_share": c_share, #                 }, #                 ranks_to_run_action=list(range(nr_parties)), #                 result_id=mask_result, #                 address=node.address, #             ) #         ) #         actions.append( #             SMPCActionMessage( #                 "spdz_multiply", #                 self_id=self_id, #                 args_id=[other_id], #                 kwargs_id={}, #                 kwargs={ #                     "eps_id": eps_id, #                     "delta_id": delta_id, #                     "a_share": a_share, #                     "b_share": b_share, #                     "c_share": c_share, #                 }, #                 ranks_to_run_action=list(range(nr_parties)), #                 result_id=result_id, #                 address=node.address, #             ) #         ) #     else: #         # All ranks should multiply by that public value #         actions.append( #             SMPCActionMessage( #                 "mpc_mul", #                 self_id=self_id, #                 args_id=[other_id], #                 kwargs_id={}, #                 ranks_to_run_action=list(range(nr_parties)), #                 result_id=result_id, #                 address=node.address, #             ) #         ) #     batch = SMPCActionSeqBatchMessage(smpc_actions=actions, address=node.address) #     return batch # ###################### BIT DECOMPOSITION #################### # def bit_decomposition( #     nr_parties: int, #     self_id: UID, #     ring_size: UID, #     bitwise: UID, #     seed_id_locations: int, #     node: Any, # ) -> List[SMPCActionMessage]: #     generator = np.random.default_rng(seed_id_locations) #     result_id = UID(UUID(bytes=generator.bytes(16))) #     actions = [] #     actions.append( #         SMPCActionMessage( #             "local_decomposition", #             self_id=self_id, #             args_id=[ring_size, bitwise], #             kwargs_id={}, #             kwargs={"seed_id_locations": str(seed_id_locations)}, #             ranks_to_run_action=list(range(nr_parties)), #             result_id=result_id, #             address=node.address, #         ) #     ) #     return actions # ###########################COMPARISON##################### # # def smpc_gt( #     nr_parties: int, #     self_id: UID, #     other_id: UID, #     seed_id_locations: int, #     node: Any, #     client: Any, # ) -> List[SMPCActionMessage]: #     """Generator for the smpc_mul with a public value""" #     generator = np.random.default_rng(seed_id_locations) #     result_id = UID(UUID(bytes=generator.bytes(16))) #     sub_result = UID(UUID(bytes=generator.bytes(16))) #     x = node.store.get(self_id).data  # noqa #     y = node.store.get(other_id).data #     if not isinstance(y, ShareTensor): #         raise ValueError("Only private compare works at the moment") #     actions = [] #     actions.append( #         SMPCActionMessage( #             "mpc_sub", #             self_id=self_id, #             args_id=[other_id], #             kwargs_id={}, #             ranks_to_run_action=list(range(nr_parties)), #             result_id=sub_result, #             address=client.address, #         ) #     ) #     actions.append( #         SMPCActionMessage( #             "bit_decomposition", #             self_id=sub_result, #             args_id=[], #             # TODO: This value needs to be changed to something else and probably used #             # directly the przs_generator from ShareTensor - check bit_decomposition function #             kwargs_id={}, #             ranks_to_run_action=list(range(nr_parties)), #             result_id=result_id, #             address=client.address, #         ) #     ) #     return actions