chore: fix timestamp

Author: gmelodie

interop/kad/nim-peer/src/nim_peer.nim

@@ -35,13 +35,12 @@ proc main() {.async.} =
     .build()
 
   let
-    goPeerId = PeerId.init(readFile("../go-peer/peer.id")).get()
-    goMa = MultiAddress.init("/ip4/127.0.0.1/tcp/4040").get()
+    peerId = PeerId.init(readFile("../rust-peer/peer.id")).get()
+    peerMa = MultiAddress.init("/ip4/127.0.0.1/tcp/4141").get()
     kad = KadDHT.new(
       switch,
-      bootstrapNodes = @[(goPeerId, @[goMa])],
+      bootstrapNodes = @[(peerId, @[peerMa])],
       config = KadDHTConfig.new(quorum = 1),
-      codec = "/test/kad/1.0.0",
     )
 
   switch.mount(kad)
@@ -67,7 +66,7 @@ proc main() {.async.} =
     quit(1)
 
 when isMainModule:
-  if waitFor(waitForService("127.0.0.1", Port(4040))):
+  if waitFor(waitForService("127.0.0.1", Port(4141))):
     waitFor(main())
   else:
     quit("timeout waiting for service", 1)

interop/kad/rust-peer/src/main.rs

@@ -1,4 +1,4 @@
-use std::error::Error;
+use std::{error::Error, fs};
 
 use futures::stream::StreamExt;
 use libp2p::{
@@ -14,7 +14,10 @@ use tracing_subscriber::EnvFilter;
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error>> {
     let _ = tracing_subscriber::fmt()
-        .with_env_filter(EnvFilter::from_default_env())
+        .with_env_filter(
+            EnvFilter::try_from_default_env()
+                .unwrap_or_else(|_| EnvFilter::new("debug,libp2p=debug")),
+        )
         .try_init();
 
     // We create a custom network behaviour that combines Kademlia and mDNS.
@@ -45,6 +48,10 @@ async fn main() -> Result<(), Box<dyn Error>> {
         })?
         .build();
 
+    let peer_id = *swarm.local_peer_id();
+    fs::write("peer.id", peer_id.to_string())?;
+    println!("Local PeerId: {peer_id}");
+
     swarm.behaviour_mut().kademlia.set_mode(Some(Mode::Server));
 
     swarm.listen_on("/ip4/0.0.0.0/tcp/4141".parse()?)?;

libp2p/protocols/kademlia/get.nim

@@ -48,9 +48,9 @@ proc dispatchGetVal(
     return
 
   let time = record.timeReceived.valueOr:
-    debug "GetValue returned record with no timeReceived",
+    debug "GetValue returned record with no timeReceived, using current time instead",
       msg = msg, reply = reply, conn = conn
-    return
+    TimeStamp($times.now().utc)
 
   received[peer] = Opt.some(EntryRecord(value: value, time: time))