systemd-journal-sdk-core 0.7.0

use super::mmap::MemoryMap;
use crate::error::{JournalError, Result};
use crate::file::JournalFile;
use std::num::{NonZeroU64, NonZeroUsize};
use std::sync::Arc;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum Direction {
    Forward,
    Backward,
}

/// A reference to a single array of offsets in the journal file
#[derive(Clone, Copy)]
#[cfg_attr(feature = "allocative", derive(allocative::Allocative))]
pub struct Node {
    offset: NonZeroU64,
    next_offset: Option<NonZeroU64>,
    capacity: NonZeroUsize,
    // Number of items remaining in this array and subsequent arrays
    remaining_items: NonZeroUsize,
}

impl Node {
    /// Create a new offset array reference
    fn new<M: MemoryMap>(
        journal_file: &JournalFile<M>,
        offset: NonZeroU64,
        remaining_items: NonZeroUsize,
    ) -> Result<Self> {
        let array = journal_file.offset_array_ref(offset)?;
        let capacity =
            NonZeroUsize::new(array.capacity()).ok_or(JournalError::EmptyOffsetArrayNode)?;

        Ok(Self {
            offset,
            next_offset: array.header.next_offset_array,
            capacity,
            remaining_items,
        })
    }

    /// Get the offset of this array in the file
    pub fn offset(&self) -> NonZeroU64 {
        self.offset
    }

    /// Get the maximum number of items this array can hold
    pub fn capacity(&self) -> NonZeroUsize {
        self.capacity
    }

    /// Get the number of items available in this array
    pub fn len(&self) -> NonZeroUsize {
        self.capacity.min(self.remaining_items)
    }

    /// Check if this array has a next array in the chain
    pub fn has_next(&self) -> bool {
        self.next_offset.is_some() && self.remaining_items > self.len()
    }

    /// Get the next array in the chain, if any
    pub fn next<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<Self>> {
        if !self.has_next() {
            return Ok(None);
        }

        let next_offset = self.next_offset.unwrap();
        let remaining_items = {
            let n = self.remaining_items.get().saturating_sub(self.len().get());
            NonZeroUsize::new(n).ok_or(JournalError::EmptyOffsetArrayNode)?
        };
        let node = Self::new(journal_file, next_offset, remaining_items);

        Some(node).transpose()
    }

    /// Get an item at the specified index
    pub fn get<M: MemoryMap>(
        &self,
        journal_file: &JournalFile<M>,
        index: usize,
    ) -> Result<Option<NonZeroU64>> {
        if index >= self.len().get() {
            return Err(JournalError::InvalidOffsetArrayIndex);
        }

        let array = journal_file.offset_array_ref(self.offset)?;
        array.get(index, self.remaining_items.get())
    }

    /// Returns the first index where the predicate returns false, or array length if
    /// the predicate is true for all elements
    pub fn partition_point<M, F>(
        &self,
        journal_file: &JournalFile<M>,
        left: usize,
        right: usize,
        predicate: F,
    ) -> Result<usize>
    where
        M: MemoryMap,
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let mut left = left;
        let mut right = right;

        debug_assert!(left <= right);
        debug_assert!(right <= self.len().get());

        while left != right {
            let mid = left.midpoint(right);
            let Some(offset) = self.get(journal_file, mid)? else {
                return Err(JournalError::InvalidOffset);
            };

            if predicate(offset)? {
                left = mid + 1;
            } else {
                right = mid;
            }
        }

        Ok(left)
    }

    /// Find the forward or backward (depending on direction) position that matches the predicate.
    pub fn directed_partition_point<M, F>(
        &self,
        journal_file: &JournalFile<M>,
        left: usize,
        right: usize,
        predicate: F,
        direction: Direction,
    ) -> Result<Option<usize>>
    where
        M: MemoryMap,
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let index = self.partition_point(journal_file, left, right, predicate)?;

        Ok(match direction {
            Direction::Forward => {
                if index < self.len().get() {
                    Some(index)
                } else {
                    None
                }
            }
            Direction::Backward => {
                if index > 0 {
                    Some(index - 1)
                } else {
                    None
                }
            }
        })
    }
}

impl std::fmt::Debug for Node {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let next_offset = self.next_offset.map(|x| x.get()).unwrap_or(0);

        f.debug_struct("Node")
            .field("offset", &format!("0x{:x}", self.offset))
            .field("next_offset", &format!("0x{:x}", next_offset))
            .field("capacity", &self.capacity)
            .field("len", &self.len())
            .field("remaining_items", &self.remaining_items)
            .finish()
    }
}

/// A linked list of offset arrays
#[derive(Copy, Clone)]
#[cfg_attr(feature = "allocative", derive(allocative::Allocative))]
pub struct List {
    head_offset: NonZeroU64,
    total_items: NonZeroUsize,
}

impl std::fmt::Debug for List {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("List")
            .field("head_offset", &format!("0x{:x}", self.head_offset))
            .field("total_items", &self.total_items)
            .finish()
    }
}

impl List {
    /// Create a new list from head offset and total items
    pub fn new(head_offset: NonZeroU64, total_items: NonZeroUsize) -> Self {
        Self {
            head_offset,
            total_items,
        }
    }

    /// Get the head array of this chain
    pub fn head<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Node> {
        Node::new(journal_file, self.head_offset, self.total_items)
    }

    /// Get the tail array of this list by traversing from head to tail
    pub fn tail<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Node> {
        let mut current = self.head(journal_file)?;

        while let Some(next) = current.next(journal_file)? {
            current = next;
        }

        Ok(current)
    }

    fn node_chain<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Arc<[Node]>> {
        let mut nodes = Vec::new();
        let mut current = self.head(journal_file)?;

        loop {
            nodes.push(current);
            let Some(next) = current.next(journal_file)? else {
                break;
            };
            current = next;
        }

        Ok(Arc::from(nodes))
    }

    /// Get a cursor at the first position in the chain
    pub fn cursor_head(self) -> Cursor {
        Cursor::at_head(self)
    }

    /// Get a cursor at the last position in the chain
    pub fn cursor_tail<M: MemoryMap>(self, journal_file: &JournalFile<M>) -> Result<Cursor> {
        Cursor::at_tail(journal_file, self)
    }

    /// Finds the first/last array item position where the predicate function becomes false
    /// in a chain of offset arrays.
    ///
    /// # Parameters
    /// * `predicate` - Function that takes an array item value and returns true if the search should continue.
    /// * `direction` - Direction of the search (Forward or Backward)
    fn cursor_at_node_index(self, node: &Node, index: usize) -> Cursor {
        Cursor::at_cached_position(self, *node, index, None, None)
    }

    fn node_partition_cursor<M, F>(
        self,
        journal_file: &JournalFile<M>,
        node: &Node,
        predicate: &F,
        direction: Direction,
    ) -> Result<Option<(Cursor, usize)>>
    where
        M: MemoryMap,
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let left = 0;
        let right = node.len().get();
        let Some(index) =
            node.directed_partition_point(journal_file, left, right, predicate, direction)?
        else {
            return Ok(None);
        };

        let cursor = self.cursor_at_node_index(node, index);
        Ok(Some((cursor, index)))
    }

    fn backward_search_must_continue(node: &Node, index: usize) -> bool {
        index == node.len().get() - 1 && node.has_next()
    }

    pub fn directed_partition_point<M, F>(
        self,
        journal_file: &JournalFile<M>,
        predicate: F,
        direction: Direction,
    ) -> Result<Option<Cursor>>
    where
        M: MemoryMap,
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let mut last_cursor: Option<Cursor> = None;
        let mut node = self.head(journal_file)?;

        loop {
            if let Some((cursor, index)) =
                self.node_partition_cursor(journal_file, &node, &predicate, direction)?
            {
                match direction {
                    Direction::Forward => {
                        return Ok(Some(cursor));
                    }
                    Direction::Backward => {
                        last_cursor = Some(cursor);
                        if !Self::backward_search_must_continue(&node, index) {
                            return Ok(last_cursor);
                        }
                    }
                }
            } else if direction == Direction::Backward {
                return Ok(last_cursor);
            }

            if let Some(nd) = node.next(journal_file)? {
                node = nd;
            } else {
                break;
            }
        }

        if direction == Direction::Backward {
            return Ok(last_cursor);
        }

        Ok(None)
    }

    /// Collect all offsets in the entire list into the given vector
    pub fn collect_offsets<M: MemoryMap>(
        &self,
        journal_file: &JournalFile<M>,
        offsets: &mut Vec<NonZeroU64>,
    ) -> Result<()> {
        offsets.reserve(self.total_items.get());

        let mut node = self.head(journal_file)?;

        loop {
            {
                let array = journal_file.offset_array_ref(node.offset())?;
                let remaining_items = node.remaining_items.get();
                array.collect_offsets(0, remaining_items, offsets)?;
            }

            match node.next(journal_file)? {
                Some(next) => node = next,
                None => break,
            }
        }

        Ok(())
    }
}

/// A cursor pointing to a specific position within an offset array chain
#[derive(Clone)]
#[cfg_attr(feature = "allocative", derive(allocative::Allocative))]
pub struct Cursor {
    list: List,
    array_offset: NonZeroU64,
    array_index: usize,
    remaining_items: NonZeroUsize,
    node: Option<Node>,
    node_index: Option<usize>,
    node_chain: Option<Arc<[Node]>>,
    cached_value: Option<NonZeroU64>,
}

impl Cursor {
    pub fn head(&self) -> Self {
        if let Some(chain) = &self.node_chain {
            if let Some(node) = chain.first().copied() {
                return Self {
                    list: self.list,
                    array_offset: node.offset,
                    array_index: 0,
                    remaining_items: node.remaining_items,
                    node: Some(node),
                    node_index: Some(0),
                    node_chain: Some(Arc::clone(chain)),
                    cached_value: None,
                };
            }
        }
        Self::at_head(self.list)
    }

    /// Create a cursor at the head of the chain
    pub fn at_head(list: List) -> Self {
        Self {
            list,
            array_offset: list.head_offset,
            array_index: 0,
            remaining_items: list.total_items,
            node: None,
            node_index: None,
            node_chain: None,
            cached_value: None,
        }
    }

    /// Create a cursor at the tail of the chain
    pub fn at_tail<M: MemoryMap>(journal_file: &JournalFile<M>, list: List) -> Result<Self> {
        let chain = list.node_chain(journal_file)?;
        let node_index = chain
            .len()
            .checked_sub(1)
            .ok_or(JournalError::EmptyOffsetArrayList)?;
        let current_array = chain[node_index];

        Ok(Self {
            list,
            array_offset: current_array.offset,
            array_index: current_array.len().get() - 1,
            remaining_items: current_array.len(),
            node: Some(current_array),
            node_index: Some(node_index),
            node_chain: Some(chain),
            cached_value: None,
        })
    }

    /// Create a cursor at a specific position
    pub fn at_position<M: MemoryMap>(
        journal_file: &JournalFile<M>,
        offset_array_list: List,
        array_offset: NonZeroU64,
        array_index: usize,
        remaining_items: NonZeroUsize,
    ) -> Result<Self> {
        debug_assert!(offset_array_list.total_items >= remaining_items);

        // Verify the array exists
        let array = Node::new(journal_file, array_offset, remaining_items)?;

        // Verify the index is valid
        if array_index >= array.len().get() {
            return Err(JournalError::InvalidOffsetArrayIndex);
        }

        Ok(Self::at_cached_position(
            offset_array_list,
            array,
            array_index,
            None,
            None,
        ))
    }

    fn at_cached_position(
        list: List,
        node: Node,
        array_index: usize,
        node_index: Option<usize>,
        node_chain: Option<Arc<[Node]>>,
    ) -> Self {
        Self {
            list,
            array_offset: node.offset,
            array_index,
            remaining_items: node.remaining_items,
            node: Some(node),
            node_index,
            node_chain,
            cached_value: None,
        }
    }

    /// Get the current array this cursor points to
    pub fn node<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Node> {
        if let Some(node) = self.node {
            return Ok(node);
        }
        Node::new(journal_file, self.array_offset, self.remaining_items)
    }

    pub fn value<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<NonZeroU64>> {
        if let Some(value) = self.cached_value {
            return Ok(Some(value));
        }
        self.node(journal_file)?.get(journal_file, self.array_index)
    }

    pub(crate) fn materialize_value<M: MemoryMap>(
        mut self,
        journal_file: &JournalFile<M>,
    ) -> Result<Option<(Self, NonZeroU64)>> {
        if let Some(value) = self.cached_value {
            return Ok(Some((self, value)));
        }

        let node = self.node(journal_file)?;
        let Some(value) = node.get(journal_file, self.array_index)? else {
            return Ok(None);
        };
        self.node = Some(node);
        self.cached_value = Some(value);
        Ok(Some((self, value)))
    }

    fn node_chain_position<M: MemoryMap>(
        &self,
        journal_file: &JournalFile<M>,
    ) -> Result<(Arc<[Node]>, usize)> {
        if let (Some(chain), Some(index)) = (&self.node_chain, self.node_index) {
            return Ok((Arc::clone(chain), index));
        }

        let chain = self.list.node_chain(journal_file)?;
        let Some(index) = chain
            .iter()
            .position(|node| node.offset == self.array_offset)
        else {
            return Err(JournalError::InvalidOffsetArrayOffset);
        };
        Ok((chain, index))
    }

    /// Move to the next position
    pub fn next<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<Self>> {
        let array_node = self.node(journal_file)?;

        // Same-node movement keeps the cached node metadata and avoids
        // rereading the offset-array object until the value itself is needed.
        if self.array_index + 1 < array_node.len().get() {
            // Next item is in the same array
            return Ok(Some(Self {
                list: self.list,
                array_offset: self.array_offset,
                array_index: self.array_index + 1,
                remaining_items: self.remaining_items,
                node: Some(array_node),
                node_index: self.node_index,
                node_chain: self.node_chain.as_ref().map(Arc::clone),
                cached_value: None,
            }));
        }

        if !array_node.has_next() {
            return Ok(None);
        }

        let (next_array, node_index, node_chain) =
            if let (Some(chain), Some(index)) = (&self.node_chain, self.node_index) {
                let next_index = index + 1;
                let Some(next_array) = chain.get(next_index).copied() else {
                    return Err(JournalError::InvalidOffsetArrayOffset);
                };
                (next_array, Some(next_index), Some(Arc::clone(chain)))
            } else {
                let next_array = array_node
                    .next(journal_file)?
                    .ok_or(JournalError::InvalidOffsetArrayOffset)?;
                (next_array, None, None)
            };

        Ok(Some(Self {
            list: self.list,
            array_offset: next_array.offset,
            array_index: 0,
            remaining_items: next_array.remaining_items,
            node: Some(next_array),
            node_index,
            node_chain,
            cached_value: None,
        }))
    }

    /// Move to the previous position
    pub fn previous<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<Self>> {
        if self.array_index > 0 {
            // Previous item is in the same array
            let array_node = self.node(journal_file)?;
            return Ok(Some(Self {
                list: self.list,
                array_offset: self.array_offset,
                array_index: self.array_index - 1,
                remaining_items: self.remaining_items,
                node: Some(array_node),
                node_index: self.node_index,
                node_chain: self.node_chain.as_ref().map(Arc::clone),
                cached_value: None,
            }));
        }

        if self.array_offset == self.list.head_offset {
            return Ok(None);
        }

        let (chain, index) = self.node_chain_position(journal_file)?;
        let previous_index = index
            .checked_sub(1)
            .ok_or(JournalError::InvalidOffsetArrayOffset)?;
        let previous_node = chain[previous_index];

        Ok(Some(Self {
            list: self.list,
            array_offset: previous_node.offset,
            array_index: previous_node.len().get() - 1,
            remaining_items: previous_node.remaining_items,
            node: Some(previous_node),
            node_index: Some(previous_index),
            node_chain: Some(chain),
            cached_value: None,
        }))
    }

    pub fn collect_offsets<M: MemoryMap>(
        &self,
        journal_file: &JournalFile<M>,
        offsets: &mut Vec<NonZeroU64>,
    ) -> Result<()> {
        let mut node = self.node(journal_file)?;

        // Copy from position in the current array
        {
            let array = journal_file.offset_array_ref(node.offset())?;
            let remaining_items = node.remaining_items.get();
            array.collect_offsets(self.array_index, remaining_items, offsets)?;
        }

        // Copy from subsequent arrays
        while let Some(next_node) = node.next(journal_file)? {
            let array = journal_file.offset_array_ref(next_node.offset())?;
            let remaining_items = next_node.remaining_items.get();
            array.collect_offsets(0, remaining_items, offsets)?;
            node = next_node;
        }

        Ok(())
    }
}

impl std::fmt::Debug for Cursor {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("Cursor")
            .field("array_offset", &format!("0x{:x}", self.array_offset))
            .field("array_index", &self.array_index)
            .field("remaining_items", &self.remaining_items)
            .finish()
    }
}

#[derive(Debug, Clone)]
#[cfg_attr(feature = "allocative", derive(allocative::Allocative))]
pub struct InlinedCursor {
    inlined_offset: NonZeroU64,
    cursor: Option<Cursor>,
    at_inlined_offset: bool,
}

impl InlinedCursor {
    pub fn new(inlined_offset: NonZeroU64, cursor: Option<Cursor>) -> Self {
        Self {
            inlined_offset,
            cursor,
            at_inlined_offset: true,
        }
    }

    pub fn head(&self) -> Self {
        Self {
            inlined_offset: self.inlined_offset,
            cursor: self.cursor.as_ref().map(Cursor::head),
            at_inlined_offset: true,
        }
    }

    pub fn tail<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Self> {
        // Start with a copy of the current cursor
        let mut result = self.clone();

        // If we have an entry array list cursor, move it to the tail
        if let Some(cursor) = self.cursor.as_ref() {
            result.cursor = Some(cursor.list.cursor_tail(journal_file)?);
            result.at_inlined_offset = false;
        }

        Ok(result)
    }

    fn next<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<Self>> {
        // Case 1: We're at the inlined entry, move to the first array entry
        if self.at_inlined_offset {
            if self.cursor.is_some() {
                return Ok(Some(Self {
                    inlined_offset: self.inlined_offset,
                    cursor: self.cursor.clone(),
                    at_inlined_offset: false,
                }));
            } else {
                return Ok(None);
            }
        }

        // Case 2: We're already in the entry array
        if let Some(current_cursor) = self.cursor.as_ref() {
            let next_cursor = current_cursor.next(journal_file)?;

            if next_cursor.is_some() {
                return Ok(Some(Self {
                    inlined_offset: self.inlined_offset,
                    cursor: next_cursor,
                    at_inlined_offset: false,
                }));
            } else {
                return Ok(None);
            }
        }

        // No more entries
        Ok(None)
    }

    fn previous<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<Self>> {
        if self.at_inlined_offset {
            return Ok(None);
        }

        if let Some(current_cursor) = self.cursor.as_ref() {
            // Try to move to the previous position in the array
            if let Some(prev_cursor) = current_cursor.previous(journal_file)? {
                // We can move back within the array
                let mut ic = self.clone();
                ic.cursor = Some(prev_cursor);
                return Ok(Some(ic));
            } else {
                // We're at the first array position, move to the inlined entry
                let mut ic = self.clone();
                ic.at_inlined_offset = true;
                return Ok(Some(ic));
            }
        }

        unreachable!();
    }

    pub fn value<M: MemoryMap>(&self, journal_file: &JournalFile<M>) -> Result<Option<NonZeroU64>> {
        // Case 1: We're at the inlined entry
        if self.at_inlined_offset {
            return Ok(Some(self.inlined_offset));
        }

        // Case 2: We're in the entry array
        if let Some(cursor) = self.cursor.as_ref() {
            return cursor.value(journal_file);
        }

        unreachable!();
    }

    pub fn next_until<M: MemoryMap>(
        &mut self,
        journal_file: &JournalFile<M>,
        offset: NonZeroU64,
    ) -> Result<Option<NonZeroU64>> {
        let Some(current_offset) = self.value(journal_file)? else {
            return Ok(None);
        };

        if current_offset >= offset {
            return Ok(Some(current_offset));
        }

        while let Some(ic) = self.next(journal_file)? {
            *self = ic;

            let Some(current_offset) = self.value(journal_file)? else {
                break;
            };

            if current_offset >= offset {
                return Ok(Some(current_offset));
            }
        }

        Ok(None)
    }

    pub fn previous_until<M: MemoryMap>(
        &mut self,
        journal_file: &JournalFile<M>,
        offset: NonZeroU64,
    ) -> Result<Option<NonZeroU64>> {
        let Some(current_offset) = self.value(journal_file)? else {
            return Ok(None);
        };

        if current_offset <= offset {
            return Ok(Some(current_offset));
        }

        while let Some(ic) = self.previous(journal_file)? {
            *self = ic;

            let Some(current_offset) = self.value(journal_file)? else {
                break;
            };

            if current_offset <= offset {
                return Ok(Some(current_offset));
            }
        }

        Ok(None)
    }

    pub fn directed_partition_point<M, F>(
        &self,
        journal_file: &JournalFile<M>,
        predicate: F,
        direction: Direction,
    ) -> Result<Option<Self>>
    where
        M: MemoryMap,
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let inlined_match = self.inlined_partition_candidate(&predicate, direction)?;
        let array_match = self.array_partition_candidate(journal_file, predicate, direction)?;

        match (inlined_match, array_match) {
            (Some(best), Some(array)) => {
                Self::best_directed_match(journal_file, best, array, direction).map(Some)
            }
            (Some(best), None) => Ok(Some(best)),
            (None, Some(array)) => Ok(Some(array)),
            (None, None) => Ok(None),
        }
    }

    fn inlined_partition_candidate<F>(
        &self,
        predicate: &F,
        direction: Direction,
    ) -> Result<Option<Self>>
    where
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let predicate_matches = predicate(self.inlined_offset)?;
        match direction {
            Direction::Forward if !predicate_matches => Ok(Some(self.head())),
            Direction::Backward if predicate_matches => Ok(Some(self.head())),
            _ => Ok(None),
        }
    }

    fn array_partition_candidate<M, F>(
        &self,
        journal_file: &JournalFile<M>,
        predicate: F,
        direction: Direction,
    ) -> Result<Option<Self>>
    where
        M: MemoryMap,
        F: Fn(NonZeroU64) -> Result<bool>,
    {
        let Some(cursor) = self.cursor.as_ref() else {
            return Ok(None);
        };
        let Some(cursor) =
            cursor
                .list
                .directed_partition_point(journal_file, predicate, direction)?
        else {
            return Ok(None);
        };

        Ok(Some(Self {
            inlined_offset: self.inlined_offset,
            cursor: Some(cursor),
            at_inlined_offset: false,
        }))
    }

    fn best_directed_match<M: MemoryMap>(
        journal_file: &JournalFile<M>,
        best: Self,
        candidate: Self,
        direction: Direction,
    ) -> Result<Self> {
        let best_offset = best.value(journal_file)?;
        let candidate_offset = candidate.value(journal_file)?;
        let candidate_is_better = match direction {
            Direction::Forward => candidate_offset < best_offset,
            Direction::Backward => candidate_offset > best_offset,
        };
        if candidate_is_better {
            Ok(candidate)
        } else {
            Ok(best)
        }
    }

    pub fn collect_offsets<M: MemoryMap>(
        &self,
        journal_file: &JournalFile<M>,
        offsets: &mut Vec<NonZeroU64>,
    ) -> Result<()> {
        // Handle the inline offset first if we're at it
        if self.at_inlined_offset {
            offsets.push(self.inlined_offset);

            // If we have a cursor, collect all offsets from the beginning
            if let Some(cursor) = self.cursor.as_ref() {
                cursor.list.collect_offsets(journal_file, offsets)?;
            }
        } else if let Some(cursor) = self.cursor.as_ref() {
            // We're somewhere in the array chain, collect from current position
            cursor.collect_offsets(journal_file, offsets)?;
        }

        Ok(())
    }
}