diff options
| author | Dennis Brentjes <d.brentjes@gmail.com> | 2016-11-12 13:48:30 +0100 |
|---|---|---|
| committer | Dennis Brentjes <d.brentjes@gmail.com> | 2016-11-12 13:48:30 +0100 |
| commit | f93d52bbd0053574fb35d72b85c4b299dc1f3ee5 (patch) | |
| tree | 4a2120a162ce9161d70074fd9ffa3ed21d80a40e /node/node_client.cpp | |
| parent | 8ff9babe2da4a2efc8529e800a6093fbd0327286 (diff) | |
| download | cmix-f93d52bbd0053574fb35d72b85c4b299dc1f3ee5.tar.gz cmix-f93d52bbd0053574fb35d72b85c4b299dc1f3ee5.tar.bz2 cmix-f93d52bbd0053574fb35d72b85c4b299dc1f3ee5.zip | |
Fixes decryption share calculation, adds lots of debugging statements.
Diffstat (limited to 'node/node_client.cpp')
| -rw-r--r-- | node/node_client.cpp | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/node/node_client.cpp b/node/node_client.cpp index f60c48d..baf4251 100644 --- a/node/node_client.cpp +++ b/node/node_client.cpp @@ -10,7 +10,7 @@ void Node::handle_client_keyexchange(ClientConnections::key_type handle, cmix_pr nke.mutable_public_key()->resize(len); nke.mutable_value()->resize(len); - key_exchange_responder(&cmix_ctx, &d.shared_value.shared, &(*nke.mutable_public_key())[0], &(*nke.mutable_value())[0], ke.public_key().data(), ke.value().data()); + key_exchange_responder(&cmix_ctx, &d.shared_value, &(*nke.mutable_public_key())[0], &(*nke.mutable_value())[0], ke.public_key().data(), ke.value().data()); data[handle] = d; @@ -23,6 +23,14 @@ void Node::handle_client_bye(ClientConnections::key_type handle, cmix_proto::Bye clients.erase(handle); } +void Node::handle_client_usermessage(ClientConnections::key_type handle, cmix_proto::UserMessage const& um) { + if(!network_settings.is_first) { + BOOST_LOG_TRIVIAL(warning) << "Received a user message but I'm not the first node, ignoring."; + return; + } + messages[handle].push(um.m()); +} + void Node::handle_client_message(ClientConnections::key_type handle, cmix_proto::CMixMessage message) { switch(message.contents_case()) { @@ -36,6 +44,11 @@ void Node::handle_client_message(ClientConnections::key_type handle, cmix_proto: handle_client_bye(handle, message.bye()); return; } + case cmix_proto::CMixMessage::ContentsCase::kUsermessage: { + BOOST_LOG_TRIVIAL(trace) << "Handling user message"; + handle_client_usermessage(handle, message.usermessage()); + break; + } default: { BOOST_LOG_TRIVIAL(error) << "handle_client_message: CMixMessage contains unknown contents."; } |
