From e4bb57e5f44c599c7bc0f96bfddf59fe1fcaa7d1 Mon Sep 17 00:00:00 2001
From: dawn <90008@gaze.systems>
Date: Sun, 19 Apr 2026 02:41:30 +0300
Subject: [PATCH] read latest seq from db instead of using current_seq in when
 polling if we error

---
 src/bin/mirror.rs | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/src/bin/mirror.rs b/src/bin/mirror.rs
index d3d68ad..86e43f9 100644
--- a/src/bin/mirror.rs
+++ b/src/bin/mirror.rs
@@ -150,6 +150,7 @@ pub async fn run(
         // the poll -> stream task: poll until we're caught up, then switch to stream.
         // on stream disconnect, fall back to polling to resync.
         let send_page_bg = send_page.clone();
+        let db_for_poll = db.clone();
         tasks.spawn(async move {
             let mut current_seq = latest_seq;
             loop {
@@ -214,6 +215,25 @@ pub async fn run(
                     Ok(Err(e)) => tracing::warn!("stream error: {e}, resyncing via poll"),
                     Err(e) => tracing::warn!("stream task join error: {e}"),
                 }
+
+                // rest current_seq to what's actually in the DB. current_seq tracks
+                // pages forwarded to seq_pages_to_fjall, which may be ahead of what
+                // was actually stored (ops can be dropped by VERIFY=true). polling
+                // from the in-memory current_seq would permanently skip those ops.
+                let db = db_for_poll.clone();
+                match tokio::task::spawn_blocking(move || db.get_latest()).await {
+                    Ok(Ok(Some((seq, _)))) => {
+                        if seq < current_seq {
+                            tracing::info!(
+                                "resetting poll cursor from {current_seq} to db latest {seq} to avoid skipping dropped ops"
+                            );
+                            current_seq = seq;
+                        }
+                    }
+                    Ok(Ok(None)) => {}
+                    Ok(Err(e)) => tracing::warn!("failed to read db latest for poll reset: {e}"),
+                    Err(e) => tracing::warn!("spawn_blocking failed for poll reset: {e}"),
+                }
             }
         });
 
-- 
2.51.2