Implement Topics

.github/workflows/build.yml

@@ -50,4 +50,4 @@ jobs:
       - name: Get latest version of stable rust
         run: rustup update stable
       - name: Check rustdoc links
-        run: RUSTDOCFLAGS="--deny broken_intra_doc_links" cargo doc --verbose --workspace --no-deps --document-private-items
+        run: RUSTDOCFLAGS="--deny rustdoc::broken_intra_doc_links" cargo doc --verbose --workspace --no-deps --document-private-items

.gitignore

@@ -8,3 +8,6 @@ Cargo.lock
 
 # VIM swap files
 *.sw[op]
+
+# VS Code settings files
+/.vscode/

Cargo.toml

@@ -40,6 +40,7 @@ lru = "0.7.1"
 hashlink = "0.7.0"
 delay_map = "0.1.1"
 more-asserts = "0.2.2"
+base64 = "0.13.0"
 
 [dev-dependencies]
 rand_07 = { package = "rand", version = "0.7" }

examples/find_nodes.rs

@@ -175,7 +175,7 @@ async fn main() {
                 match discv5.find_node(target_random_node_id).await {
                     Err(e) => warn!("Find Node result failed: {:?}", e),
                     Ok(v) => {
-                        // found a list of ENR's print their NodeIds
+                        // found a list of ENRs print their NodeIds
                         let node_ids = v.iter().map(|enr| enr.node_id()).collect::<Vec<_>>();
                         info!("Nodes found: {}", node_ids.len());
                         for node_id in node_ids {
@@ -191,8 +191,10 @@ async fn main() {
                 }
                 match discv5_ev {
                     Discv5Event::Discovered(enr) => info!("Enr discovered {}", enr),
+                    Discv5Event::DiscoveredPeerTopic(enr, topic_hash) => info!("Enr discovered {} for topic {}", enr, topic_hash),
                     Discv5Event::EnrAdded { enr, replaced: _ } => info!("Enr added {}", enr),
                     Discv5Event::NodeInserted { node_id, replaced: _ } => info!("Node inserted {}", node_id),
+                    Discv5Event::NodeInsertedTopic { node_id, replaced: _, topic_hash } => info!("Node inserted {} in topic hash {} kbucket", node_id, topic_hash),
                     Discv5Event::SessionEstablished(enr, _) => info!("Session established {}", enr),
                     Discv5Event::SocketUpdated(addr) => info!("Socket updated {}", addr),
                     Discv5Event::TalkRequest(_) => info!("Talk request received"),