fix test

Author: MarinPostma

libsql-wal/src/segment/current.rs

@@ -823,11 +823,7 @@ mod test {
                     return Ok(0);
                 }
 
-                let read_len = if offset as usize + buf.len() > inner.len() {
-                    offset as usize + buf.len() - inner.len()
-                } else {
-                    buf.len()
-                };
+                let read_len = buf.len().min(inner.len() - offset as usize);
                 buf[..read_len]
                     .copy_from_slice(&inner[offset as usize..offset as usize + read_len]);
                 Ok(read_len)
@@ -960,9 +956,12 @@ mod test {
             }
         }
 
+        dbg!();
         {
             let env = TestEnv::new_io_and_tmp(SyncFailBufferIo::default(), tmp.clone());
+        dbg!();
             let conn = env.open_conn("test");
+        dbg!();
             conn.query_row("select count(*) from test", (), |row| {
                 dbg!(row);
                 Ok(())

libsql-wal/src/segment/sealed.rs

@@ -282,14 +282,14 @@ impl<F: FileExt> SealedSegment<F> {
             builder.insert(k.to_be_bytes(), v as u64).unwrap();
         }
         builder.finish().unwrap();
-        let mut writer = writer.into_inner();
+        let writer = writer.into_inner();
         let index_size = writer.get_ref().get_ref().count();
         let index_checksum = digest.finalize();
-        writer.write_all(&index_checksum.to_le_bytes())?;
-        let (_, index_bytes) = writer
+        let (mut cursor, index_bytes) = writer
             .into_inner()
             .map_err(|e| e.into_parts().0)?
             .into_parts();
+        cursor.write_all(&index_checksum.to_le_bytes())?;
         header.index_offset = index_byte_offset.into();
         header.index_size = index_size.into();
         header.last_commited_frame_no = last_committed.into();

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
 profile = "default"
-channel = "1.78.0"
+channel = "1.80.0"