From 944bd3a9da9c14153247b483ba2cfe1457fc84d2 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sun, 25 Oct 2026 20:33:40 +0100
Subject: late messages don't flip peer's epoch back

---
 src/swarm/blob.rs | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'src/swarm/blob.rs')

diff --git a/src/swarm/blob.rs b/src/swarm/blob.rs
index 8c891ae..42cfbf3 100644
--- a/src/swarm/blob.rs
+++ b/src/swarm/blob.rs
@@ -171,8 +171,10 @@ async fn prepare(state: &AppState, id: BlobId) -> Option<Arc<Prepared>> {
 }
 
 async fn reply(state: &AppState, peer: &str, id: BlobId, body: BlobBody) {
+    let (epoch, epoch_seq) = state.epoch_stamp().await;
     let message = ParsedMessage::Blob(BlobMessage {
-        epoch: state.local_epoch(),
+        epoch,
+        epoch_seq,
         id,
         body,
     });
@@ -223,8 +225,10 @@ impl Drop for Registration<'_> {
 }
 
 async fn request(state: &AppState, peer: &str, id: BlobId, chunks: Vec<u32>) {
+    let (epoch, epoch_seq) = state.epoch_stamp().await;
     let message = ParsedMessage::Blob(BlobMessage {
-        epoch: state.local_epoch(),
+        epoch,
+        epoch_seq,
         id,
         body: BlobBody::Request { chunks },
     });
-- 
cgit v1.3.1