time blob messages

1 files changed, 2 insertions, 0 deletions

diff --git a/src/swarm/blob.rs b/src/swarm/blob.rs
index ce9a2bd..98dee66 100644
--- a/src/swarm/blob.rs
+++ b/src/swarm/blob.rs
@@ -278,6 +278,7 @@ async fn reply(state: &AppState, peer: &str, id: BlobId, body: BlobBody) {
         epoch_seq,
         id,
         body,
+        sent: state.clock.now_millis(),
     });
     if let Err(error) = state.transport.send_message(peer, &message).await {
         debug!(peer = %peer, blob = %id, error = %format!("{error:#}"), "Blob answer failed");
@@ -347,6 +348,7 @@ async fn request(
             chunks,
             delta: delta.cloned(),
         },
+        sent: state.clock.now_millis(),
     });
     if let Err(error) = state.transport.send_message(peer, &message).await {
         debug!(peer = %peer, blob = %id, error = %format!("{error:#}"), "Blob request failed");