From e9f0c59bcc4b33e64de0f3c7eb4935f04cef633e Mon Sep 17 00:00:00 2001
From: Jussi Saurio <jussi.saurio@gmail.com>
Date: Wed, 1 Oct 2025 12:45:30 +0300
Subject: [PATCH] fix/mvcc: set log offset to end of file after recovery
 finishes

otherwise we start overwriting existing log entries
---
 core/mvcc/database/mod.rs                   | 2 ++
 core/mvcc/persistent_storage/logical_log.rs | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/core/mvcc/database/mod.rs b/core/mvcc/database/mod.rs
index cfcf47fb8..486cfb923 100644
--- a/core/mvcc/database/mod.rs
+++ b/core/mvcc/database/mod.rs
@@ -1973,6 +1973,8 @@ impl<Clock: LogicalClock> MvStore<Clock> {
                     self.delete(tx_id, rowid)?;
                 }
                 StreamingResult::Eof => {
+                    // Set offset to the end so that next writes go to the end of the file
+                    self.storage.logical_log.write().unwrap().offset = reader.offset as u64;
                     break;
                 }
             }
diff --git a/core/mvcc/persistent_storage/logical_log.rs b/core/mvcc/persistent_storage/logical_log.rs
index e41092692..077a1fae5 100644
--- a/core/mvcc/persistent_storage/logical_log.rs
+++ b/core/mvcc/persistent_storage/logical_log.rs
@@ -14,7 +14,7 @@ use crate::{types::IOResult, File};
 
 pub struct LogicalLog {
     pub file: Arc<dyn File>,
-    offset: u64,
+    pub offset: u64,
 }
 
 /// Log's Header, this will be the 64 bytes in any logical log file.
@@ -231,7 +231,7 @@ enum StreamingState {
 pub struct StreamingLogicalLogReader {
     file: Arc<dyn File>,
     /// Offset to read from file
-    offset: usize,
+    pub offset: usize,
     /// Log Header
     header: Option<Arc<LogHeader>>,
     /// Cached buffer after io read