substrate-data 0.4.0

//! [`Decoder`]: reads the binary form — as a [`Value`] (`decoder_value`),
//! borrowed as a [`ValueRef`] (`decoder_ref`), or step by step by a schema
//! reading itself (`decoder_straight`). This file holds what they share: the
//! header, the numbers, the string table.

use super::shape::{Shapes, Walk};
use crate::binary::{
    DecodeError, LEGACY_VERSION, MAGIC, MAX_DEPTH, NEW_STRING, STR_INDEX_COUNT, STREAM_LEN_BYTES,
    VERSION, read_varint, tag,
};
use crate::model::value::{KindName, Value};
use crate::sync::Arc;

/// Strings a decoder makes room for at once: a message's keys and values.
pub(in crate::wire::binary) const STRINGS_START: usize = 16;

/// Bytes of a float, and of a 32-bit one.
pub(in crate::wire::binary) const F64_BYTES: usize = 8;
pub(in crate::wire::binary) const F32_BYTES: usize = 4;

/// Bytes a map entry takes at least: its key and its value's tag.
pub(in crate::wire::binary) const MAP_ENTRY_MIN: usize = 2;

/// Reads the binary form. The step-by-step reads ([`Decoder::int`],
/// [`Decoder::map`] …) answer `None` for anything but what
/// [`crate::Schema::encode`] writes there — the schema then reads the
/// slow way, which says what's wrong.
#[derive(Debug)]
pub struct Decoder<'b> {
    pub(in crate::wire::binary) b: &'b [u8],
    pub(in crate::wire::binary) i: usize,
    pub(in crate::wire::binary) strings: Vec<&'b str>,
    /// Map keys made so far, by table index: each key is allocated once.
    pub(in crate::wire::binary) keys: Vec<Option<Arc<str>>>,
    /// Reference kinds checked so far, by table index of their string.
    pub(in crate::wire::binary) kinds: Vec<Option<KindName>>,
    pub(in crate::wire::binary) depth: usize,
    /// Whether the tags of version 2 are accepted (a version 1 document is
    /// read with only the tags it was written with).
    pub(in crate::wire::binary) v2: bool,
    /// The map shapes defined so far (version 2).
    pub(in crate::wire::binary) shapes: Shapes,
    /// The shaped maps being read step by step, innermost last.
    pub(in crate::wire::binary) frames: Vec<Walk>,
}

impl<'b> Decoder<'b> {
    /// After the header: the root value next. Versions 1 and 2 are read;
    /// a version 1 document may use only the tags it was written with.
    ///
    /// # Errors
    ///
    /// [`DecodeError`] when the header isn't `SDAT` and a version this reads.
    pub fn open(bytes: &'b [u8]) -> Result<Self, DecodeError> {
        let mut d = Decoder::body(bytes);
        d.v2 = false;
        if !bytes.starts_with(MAGIC) {
            return Err(d.error("not Substrate Data (no `SDAT` header)"));
        }
        d.i = MAGIC.len();
        let version = d.byte()?;
        match version {
            VERSION => d.v2 = true,
            LEGACY_VERSION => {}
            _ => {
                return Err(d.error(format!(
                    "Substrate Data version {version}, this reads versions {LEGACY_VERSION} and {VERSION}"
                )));
            }
        }
        Ok(d)
    }

    /// A body with no header ([`crate::Stream`]'s, a frame's tagged value):
    /// its strings and shapes its own, every tag of version 2 read.
    pub(crate) fn body(bytes: &'b [u8]) -> Self {
        Decoder {
            b: bytes,
            i: 0,
            strings: Vec::with_capacity(STRINGS_START),
            keys: Vec::new(),
            kinds: Vec::new(),
            depth: 0,
            v2: true,
            shapes: Shapes::default(),
            frames: Vec::new(),
        }
    }

    /// A body inside this one: the same version, its tables its own.
    pub(in crate::wire::binary) fn inner(&self, bytes: &'b [u8]) -> Self {
        let mut d = Decoder::body(bytes);
        d.v2 = self.v2;
        d.depth = self.depth;
        d
    }

    /// A stream's body: its bytes, read past.
    pub(in crate::wire::binary) fn stream_body(&mut self) -> Result<&'b [u8], DecodeError> {
        let len = u32::from_le_bytes(self.fixed::<STREAM_LEN_BYTES>()?) as usize;
        self.take(len)
    }

    /// A stream's values, decoded as a list.
    pub(in crate::wire::binary) fn stream_values(&mut self) -> Result<Vec<Value>, DecodeError> {
        let body = self.stream_body()?;
        let mut d = self.inner(body);
        let n = d.count(1)?;
        let mut items = Vec::with_capacity(n);
        for _ in 0..n {
            items.push(d.value()?);
        }
        d.end()?;
        Ok(items)
    }

    /// Whether every byte was read.
    #[must_use]
    pub fn at_end(&self) -> bool {
        self.i == self.b.len()
    }

    pub(in crate::wire::binary) fn end(&self) -> Result<(), DecodeError> {
        if self.at_end() {
            Ok(())
        } else {
            Err(self.error("bytes after the value"))
        }
    }

    pub(in crate::wire::binary) fn error(&self, message: impl Into<String>) -> DecodeError {
        DecodeError {
            message: message.into(),
            offset: self.i,
        }
    }

    pub(in crate::wire::binary) fn byte(&mut self) -> Result<u8, DecodeError> {
        let b = *self
            .b
            .get(self.i)
            .ok_or_else(|| self.error("unexpected end"))?;
        self.i += 1;
        Ok(b)
    }

    pub(in crate::wire::binary) fn varint(&mut self) -> Result<u64, DecodeError> {
        read_varint(self.b, &mut self.i)
            .ok_or_else(|| self.error("a varint cut short or longer than 64 bits"))
    }

    /// A length, checked against what's left: each of the `count` things takes at least `min` bytes.
    pub(in crate::wire::binary) fn count(&mut self, min: usize) -> Result<usize, DecodeError> {
        let n = self.varint()?;
        let left = self.b.len() - self.i;
        match usize::try_from(n) {
            Ok(n) if n <= left / min.max(1) => Ok(n),
            _ => Err(self.error(format!("length {n} past the end ({left} bytes left)"))),
        }
    }

    pub(in crate::wire::binary) fn fixed<const N: usize>(
        &mut self,
    ) -> Result<[u8; N], DecodeError> {
        let bytes = self
            .b
            .get(self.i..self.i + N)
            .ok_or_else(|| self.error("unexpected end"))?;
        self.i += N;
        bytes.try_into().map_err(|_| self.error("unexpected end"))
    }

    /// `len` bytes.
    pub(in crate::wire::binary) fn take(&mut self, len: usize) -> Result<&'b [u8], DecodeError> {
        let end = self
            .i
            .checked_add(len)
            .filter(|&e| e <= self.b.len())
            .ok_or_else(|| self.error("bytes past the end"))?;
        let out = &self.b[self.i..end];
        self.i = end;
        Ok(out)
    }

    /// A packed list of floats `N` bytes wide: each one's bytes, read in place (no alignment asked).
    pub(in crate::wire::binary) fn packed_floats<const N: usize>(
        &mut self,
    ) -> Result<std::slice::Iter<'b, [u8; N]>, DecodeError> {
        let n = self.count(N)?;
        let bytes = self.take(n * N)?;
        Ok(bytes.as_chunks::<N>().0.iter())
    }

    /// A length and that many bytes.
    pub(in crate::wire::binary) fn length_bytes(&mut self) -> Result<&'b [u8], DecodeError> {
        let len =
            usize::try_from(self.varint()?).map_err(|_| self.error("a length beyond memory"))?;
        self.take(len)
    }

    /// A string: new (read, and added to the table) or the table's.
    pub(in crate::wire::binary) fn string(&mut self) -> Result<&'b str, DecodeError> {
        let i = self.string_index()?;
        Ok(self.strings[i])
    }

    /// The string a tag of its own names (`tag - STR_INDEX` in the table).
    pub(in crate::wire::binary) fn indexed(&self, t: u8) -> Result<&'b str, DecodeError> {
        let i = usize::from(t - tag::STR_INDEX);
        self.strings
            .get(i)
            .copied()
            .ok_or_else(|| self.error(format!("string {i} isn't in the table")))
    }

    /// Whether `t` is a tag that names a table string by itself.
    pub(in crate::wire::binary) fn is_indexed(&self, t: u8) -> bool {
        self.v2 && t.wrapping_sub(tag::STR_INDEX) < STR_INDEX_COUNT
    }

    /// Whether `t` is a tag that is an int by itself.
    pub(in crate::wire::binary) fn is_inline_int(&self, t: u8) -> bool {
        self.v2 && t >= tag::INT_INLINE
    }

    pub(in crate::wire::binary) fn string_index(&mut self) -> Result<usize, DecodeError> {
        let v = self.varint()?;
        if v & NEW_STRING == 0 {
            let i = (v >> 1) as usize;
            return if i < self.strings.len() {
                Ok(i)
            } else {
                Err(self.error(format!("string {i} isn't in the table")))
            };
        }
        let len = usize::try_from(v >> 1).map_err(|_| self.error("a length beyond memory"))?;
        let at = self.i;
        let s = crate::utf8::from_utf8(self.take(len)?).map_err(|_| DecodeError {
            message: "a string isn't UTF-8".into(),
            offset: at,
        })?;
        self.strings.push(s);
        Ok(self.strings.len() - 1)
    }

    /// The key at table index `i`: shared with every other map that has it.
    pub(in crate::wire::binary) fn shared_key_at(&mut self, i: usize) -> Arc<str> {
        if self.keys.len() <= i {
            self.keys.resize(i + 1, None);
        }
        self.keys[i]
            .get_or_insert_with(|| self.strings[i].into())
            .clone()
    }

    pub(in crate::wire::binary) fn deeper(&mut self) -> Result<(), DecodeError> {
        self.depth += 1;
        if self.depth > MAX_DEPTH {
            return Err(self.error(format!("nested deeper than {MAX_DEPTH} levels")));
        }
        Ok(())
    }
}