macltok

public

Star0

Fork 0

Watch0

74 commits 3 branches 0 tags 0 releases3.0 MiB

Commit `06c73391cbae`

tarball

atagen <boss@atagen.co>2026-10-25 10:26 UTC

2 files changed+9-10

history: lean on the non-replacing flush fence

Timeline::flush_history now applies what the room cache already queued instead of replacing the timeline, so completions keep receipts, the read marker and row ids. A gap that has already joined now answers NotFound from the sdk, so only an Unavailable first answer is free of a page.

Modified file: docs/segmented-history.md+6 additions−4 deletions@@ -36,7 +36,8 @@ with phase `Bridging` as the fill starts and once more as it settles.
   when accessible history ends first, `Cancelled`
 - `Paused` with a `failure`, and the gap row goes `Failed`
 
-a gap that is already joined or unavailable answers at once and counts no page.
+a gap that is already unavailable answers at once and counts no page. one that
+has already joined is gone, so filling it answers `EventNotFound`.
 
 ## one operation per room
 
@@ -54,9 +55,10 @@ gaps appear in `TimelineState.items` as `TimelineItem::HistoryGap`, between the
 sections they separate. a row keeps its id while its lifecycle changes, and is
 removed once the gap joins. joined gaps never appear.
 
-history lands as `TimelineChanged` diffs, not a `TimelineReset`. the sdk
-currently replays the whole live timeline when it applies committed history,
-so those diffs can span the timeline until it gets a non-replacing fence.
+history lands as incremental `TimelineChanged` diffs, never a `TimelineReset`.
+before answering, the room fences on `Timeline::flush_history`, which applies
+what the cache already queued without replacing the timeline, so receipts, the
+read marker and row ids survive.
 
 a command's answer comes after its outcome is published, and after the mirror
 has applied it when one is attached.

Modified file: src/engine/repair.rs+3 additions−6 deletions@@ -307,14 +307,11 @@ async fn fill_gap(
                 HistoryGapFillOutcome::Busy => return Err(room_busy()),
                 HistoryGapFillOutcome::Updated { gap, events } => (gap, events),
             };
-            // the sdk answers an already joined or unavailable gap without asking the server.
-            // an empty first page that settles the gap looks the same and goes uncounted too
+            // the sdk answers an already unavailable gap without asking the server, and a joined
+            // one with NotFound. an empty first page that hits the end looks the same, uncounted
             let settled_before = report.pages == 0
                 && events == 0
-                && matches!(
-                    gap.status,
-                    HistoryGapStatus::Joined | HistoryGapStatus::Unavailable
-                );
+                && gap.status == HistoryGapStatus::Unavailable;
             if !settled_before {
                 report.pages += 1;
                 committed = true;

macltok

Commit 06c73391cbae

Commit `06c73391cbae`