diff options
Diffstat (limited to 'node/node.cpp')
| -rw-r--r-- | node/node.cpp | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/node/node.cpp b/node/node.cpp index 2e5fd32..02ddb3e 100644 --- a/node/node.cpp +++ b/node/node.cpp @@ -128,6 +128,37 @@ void Node::handle_node_secretkey(cmix_proto::SecretKey const& secret) void Node::handle_node_prepre(cmix_proto::PrePre const& pre) { if(network_settings.is_first) { + cmix_proto::PreMix premix; + for(int i = 0; i < pre.m_er_size(); ++i) { + GroupElement random_r = api.array_to_element(pre.r_er(i).data(), pre.r_er(i).size(), true); + GroupElement message_r = api.array_to_element(pre.m_er(i).data(), pre.m_er(i).size(), true); + + GroupElement random_s; + GroupElement message_s; + + api.encrypt(&random_s, &message_s, precomputation_data[precomputation_data[i].new_location].s, network_key); + + GroupElement random_pirs = api.multiply(random_r, random_s, true); + GroupElement message_pirs = api.multiply(message_r, message_s, true); + + unsigned char* data; + size_t len; + + api.element_to_array(&data, &len, random_pirs); + premix.set_r_epirs(precomputation_data[i].new_location, data, len); + api.free_buffer(data); + + api.element_to_array(&data, &len, message_pirs); + premix.set_m_epirs(precomputation_data[i].new_location, data, len); + api.free_buffer(data); + + api.free_group_element(random_r); + api.free_group_element(message_r); + api.free_group_element(random_s); + api.free_group_element(message_s); + } + + next_node.async_send(premix); } else { std::vector<size_t> permutation(clients.size()); |