Starting to play with alternative DHT implementations

crates/bencode/src/lib.rs

@@ -5,3 +5,5 @@ mod serde_bencode_ser;
 pub use bencode_value::*;
 pub use serde_bencode_de::*;
 pub use serde_bencode_ser::*;
+
+pub use buffers::{ByteBuf, ByteString};

crates/buffers/Cargo.toml

@@ -7,4 +7,5 @@ edition = "2018"
 
 [dependencies]
 serde = {version = "1", features=["derive"]}
-clone_to_owned = {path="../clone_to_owned"}
+clone_to_owned = {path="../clone_to_owned"}
+hex = "0.4"

crates/dht/Cargo.toml

@@ -0,0 +1,12 @@
+[package]
+name = "dht"
+version = "0.1.0"
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+kad = "0.6"
+tokio = {version = "1", features = ["macros", "rt"]}
+hex = "0.4"
+bencode = {path = "../bencode"}

crates/dht/resources/query.js

@@ -0,0 +1,10 @@
+const DHT = require('bittorrent-dht')
+
+let dht = new DHT();
+let infoHash = process.env["INFOHASH"];
+
+dht.on('peer', function (peer, infoHash, from) {
+    console.log(peer.host + ':' + peer.port)
+})
+
+dht.lookup(infoHash)

crates/dht/src/lib.rs

@@ -0,0 +1,11 @@
+#[cfg(test)]
+mod tests {
+    use bencode::ByteBuf;
+
+    #[tokio::test]
+    async fn it_works() {
+        let data = b"64313a6164323a696432303abd7b477cfbcd10f30b705da20201e7101d8df155363a74617267657432303abd7b477cfbcd10f30b705da20201e7101d8df15565313a71393a66696e645f6e6f6465313a74323a0005313a79313a7165";
+        let data = hex::decode(data).unwrap();
+        dbg!(bencode::dyn_from_bytes::<ByteBuf>(data.as_slice()).unwrap());
+    }
+}