fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-04-30 05:02:16 +00:00
Code Issues Projects Releases Wiki Activity

#10 Serialize array of records via protobuf

Browse Source
This commit is contained in:
folex 2020-04-30 12:17:04 +03:00 committed by GitHub
commit 5a8a294f84
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
protocols/kad/src/dht.proto
View File

@ -1,6 +1,10 @@
syntax = "proto3"; syntax = "proto3";
package dht.pb; package dht.pb;
message Records {
repeated Record records = 1;
}
// Record represents a dht record that contains a value // Record represents a dht record that contains a value
// for a key value pair // for a key value pair
message Record { message Record {

1
protocols/kad/src/lib.rs
View File

@ -50,6 +50,7 @@ pub use behaviour::{Kademlia, KademliaConfig, KademliaEvent, Quorum};
pub use protocol::KadConnectionType; pub use protocol::KadConnectionType;
pub use query::QueryId; pub use query::QueryId;
pub use record::{store, ProviderRecord, Record}; pub use record::{store, ProviderRecord, Record};
pub use dht_proto::{Record as ProtoRecord, Records as ProtoRecords};
use std::num::NonZeroUsize; use std::num::NonZeroUsize;

4
protocols/kad/src/protocol.rs
View File

@ -539,7 +539,7 @@ fn proto_to_resp_msg(message: proto::Message) -> Result<KadResponseMsg, io::Erro
} }
} }
fn record_from_proto(record: proto::Record) -> Result<Record, io::Error> { pub fn record_from_proto(record: proto::Record) -> Result<Record, io::Error> {
let key = record::Key::from(record.key); let key = record::Key::from(record.key);
let value = record.value; let value = record.value;
@ -562,7 +562,7 @@ fn record_from_proto(record: proto::Record) -> Result<Record, io::Error> {
Ok(Record { key, value, publisher, expires }) Ok(Record { key, value, publisher, expires })
} }
fn record_to_proto(record: Record) -> proto::Record { pub fn record_to_proto(record: Record) -> proto::Record {
proto::Record { proto::Record {
key: record.key.to_vec(), key: record.key.to_vec(),
value: record.value, value: record.value,

2
protocols/kad/src/record.rs
View File

@ -70,7 +70,7 @@ impl From<Multihash> for Key {
} }
/// A record stored in the DHT. /// A record stored in the DHT.
#[derive(Clone, Debug, Eq, PartialEq)] #[derive(Clone, Debug, Eq, PartialEq, Hash)]
pub struct Record { pub struct Record {
/// Key of the record. /// Key of the record.
pub key: Key, pub key: Key,