From 7c71ffddb2623f451b5e5138ca217a58b37bb5b0 Mon Sep 17 00:00:00 2001 From: Pierre Krieger Date: Sat, 14 Jul 2018 13:58:16 +0200 Subject: [PATCH] Remove exposed unimplemented!() in the Kad server (#298) --- kad/src/kad_server.rs | 10 ++++++++-- kad/src/protocol.rs | 2 +- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/kad/src/kad_server.rs b/kad/src/kad_server.rs index 79b4d402..199142af 100644 --- a/kad/src/kad_server.rs +++ b/kad/src/kad_server.rs @@ -383,10 +383,16 @@ where Box::new(future) } Some(EventSource::Remote(KadMsg::GetValueReq { .. })) => { - unimplemented!() // FIXME: + warn!("GET_VALUE requests are not implemented yet"); + let future = future::err(IoError::new(IoErrorKind::Other, + "GET_VALUE requests are not implemented yet")); + return Box::new(future); } Some(EventSource::Remote(KadMsg::PutValue { .. })) => { - unimplemented!() // FIXME: + warn!("PUT_VALUE requests are not implemented yet"); + let state = (events, kad_sink, responders_tx, send_back_queue, expected_pongs, finished); + let future = future::ok((None, state)); + return Box::new(future); } } })) diff --git a/kad/src/protocol.rs b/kad/src/protocol.rs index d42d3053..865c793b 100644 --- a/kad/src/protocol.rs +++ b/kad/src/protocol.rs @@ -227,7 +227,7 @@ fn msg_to_proto(kad_msg: KadMsg) -> protobuf_structs::dht::Message { msg.set_clusterLevelRaw(10); msg } - KadMsg::GetValueRes { .. } => unimplemented!(), + KadMsg::GetValueRes { .. } => unimplemented!(), // TODO: KadMsg::FindNodeReq { key } => { let mut msg = protobuf_structs::dht::Message::new(); msg.set_field_type(protobuf_structs::dht::Message_MessageType::FIND_NODE);