Function ceiling_resolve_cell

nodedb-array/src/query/ceiling.rs:56–85

Resolve the Ceiling for a single cell coordinate. `tile_versions_newest_first` — `(TileId, raw_cell_bytes)` pairs ordered newest-first by `system_from_ms`. The caller is responsible for the ordering; this function additionally defends against misuse with a guard that skips entries where `tile_id.system_from_ms > params.system_as_of`. For each version the function applies: 1. System-time guard:

(
    tile_versions_newest_first: I,
    _coord: &[CoordValue],
    params: &CeilingParams,
)

///
/// If the iterator is exhausted without a match, returns `NotFound`.
pub fn ceiling_resolve_cell<'a, I>(
    tile_versions_newest_first: I,
    _coord: &[CoordValue],
    params: &CeilingParams,
) -> ArrayResult<CeilingResult>
where
    I: IntoIterator<Item = (TileId, &'a [u8])>,
{
    for (tile_id, bytes) in tile_versions_newest_first {
        if tile_id.system_from_ms > params.system_as_of {
            continue;
        }
        if is_cell_tombstone(bytes) {
            return Ok(CeilingResult::Tombstoned);
        }
        if is_cell_gdpr_erasure(bytes) {
            return Ok(CeilingResult::Erased);
        }
        let payload = CellPayload::decode(bytes).map_err(|e| ArrayError::SegmentCorruption {
            detail: format!("ceiling_resolve_cell: {e}"),
        })?;
        match params.valid_at_ms {
            Some(vt) if !(payload.valid_from_ms <= vt && vt < payload.valid_until_ms) => {
                continue;
            }
            _ => return Ok(CeilingResult::Live(payload)),
        }
    }
    Ok(CeilingResult::NotFound)
}

#[cfg(test)]
mod tests {