/rust/registry/src/index.crates.io-1949cf8c6b5b557f/sval_buffer-2.16.0/src/value.rs

Source
use crate::{
    std::{
        marker::PhantomData,
        mem,
        ops::{Deref, DerefMut, Range},
    },
    BinaryBuf, Error, TextBuf,
};

use sval_ref::ValueRef as _;

#[derive(Debug, Clone)]
struct BufMut<T, const N: usize> {
    #[cfg(feature = "alloc")]
    inner: crate::std::vec::Vec<T>,
    #[cfg(not(feature = "alloc"))]
    inner: array_vec::ArrayVec<T, N>,
}

impl<T, const N: usize> Default for BufMut<T, N> {
    fn default() -> Self {
        BufMut {
            inner: Default::default(),
        }
    }
}

impl<T, const N: usize> Deref for BufMut<T, N> {
    type Target = [T];

    fn deref(&self) -> &Self::Target {
        &self.inner
    }
}

impl<T, const N: usize> DerefMut for BufMut<T, N> {
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.inner
    }
}

impl<T, const N: usize> BufMut<T, N> {
    fn push(&mut self, value: T) -> Result<(), Error> {
        #[cfg(feature = "alloc")]
        {
            self.inner.push(value);

            Ok(())
        }
        #[cfg(not(feature = "alloc"))]
        {
            self.inner.push(value)
        }
    }

    fn pop(&mut self) -> Option<T> {
        self.inner.pop()
    }

    fn clear(&mut self) {
        self.inner.clear()
    }
}

#[derive(Debug, Clone)]
struct Buf<T, const N: usize> {
    #[cfg(feature = "alloc")]
    inner: crate::std::boxed::Box<[T]>,
    #[cfg(not(feature = "alloc"))]
    inner: array_vec::ArrayVec<T, N>,
}

impl<T, const N: usize> Deref for Buf<T, N> {
    type Target = [T];

    fn deref(&self) -> &Self::Target {
        &self.inner
    }
}

impl<T, const N: usize> DerefMut for Buf<T, N> {
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.inner
    }
}

impl<T, const N: usize> From<BufMut<T, N>> for Buf<T, N> {
    fn from(value: BufMut<T, N>) -> Self {
        #[cfg(feature = "alloc")]
        {
            Buf {
                inner: value.inner.into_boxed_slice(),
            }
        }
        #[cfg(not(feature = "alloc"))]
        {
            Buf { inner: value.inner }
        }
    }
}

/**
Buffer arbitrary values into a tree-like structure.

This type requires the `alloc` or `std` features, otherwise most methods
will fail.
*/
#[derive(Debug)]
pub struct ValueBuf<'sval> {
    parts: BufMut<ValuePart<'sval>, 1>,
    stack: BufMut<usize, 1>,
    is_in_text_or_binary: bool,
    err: Option<Error>,
    _marker: PhantomData<&'sval ()>,
}

/**
An immutable buffered value.

This type is more compact than `ValueBuf`.
*/
#[derive(Debug, Clone)]
pub struct Value<'sval> {
    parts: Buf<ValuePart<'sval>, 1>,
    _marker: PhantomData<&'sval ()>,
}

impl<'sval> Default for ValueBuf<'sval> {
    fn default() -> Self {
        ValueBuf::new()
    }
}

impl<'sval> ValueBuf<'sval> {
    /**
    Create a new empty value buffer.
    */
    pub fn new() -> Self {
        ValueBuf {
            parts: Default::default(),
            stack: Default::default(),
            is_in_text_or_binary: false,
            err: None,
            _marker: PhantomData,
        }
    }

    /**
    Buffer a value.

    This method will fail if the `alloc` feature is not enabled.
    */
    pub fn collect(v: &'sval (impl sval::Value + ?Sized)) -> Result<Self, Error> {
        let mut buf = ValueBuf::new();

        match v.stream(&mut buf) {
            Ok(()) => Ok(buf),
            Err(_) => Err(buf
                .into_err()
                .unwrap_or_else(|| Error::invalid_value("the value itself failed to stream"))),
        }
    }

    /**
    Whether or not the contents of the value buffer are complete.
    */
    pub fn is_complete(&self) -> bool {
        self.stack.len() == 0 && self.parts.len() > 0 && !self.is_in_text_or_binary
    }

    /**
    Clear this buffer so it can be re-used for future values.
    */
    pub fn clear(&mut self) {
        let ValueBuf {
            parts,
            stack,
            is_in_text_or_binary,
            err,
            _marker,
        } = self;

        parts.clear();
        stack.clear();
        *is_in_text_or_binary = false;
        *err = None;
    }

    /**
    Get an independent immutable value from this buffer.
    */
    pub fn to_value(&self) -> Value<'sval> {
        Value {
            parts: self.parts.clone().into(),
            _marker: PhantomData,
        }
    }

    /**
    Convert this buffer into an immutable value.
    */
    pub fn into_value(self) -> Value<'sval> {
        Value {
            parts: self.parts.into(),
            _marker: PhantomData,
        }
    }

    /**
    Fully buffer any borrowed data, returning a buffer that doesn't borrow anything.

    This method will fail if the `alloc` feature is not enabled.
    */
    pub fn into_owned(self) -> Result<ValueBuf<'static>, Error> {
        #[cfg(feature = "alloc")]
        {
            let ValueBuf {
                mut parts,
                mut stack,
                mut is_in_text_or_binary,
                mut err,
                _marker,
            } = self;

            // Re-assign all parts within the value in-place without re-allocating for them
            // This will take care of converted any actually borrowed data into owned
            for part in parts.iter_mut() {
                crate::assert_static(part.into_owned_in_place());
            }

            // SAFETY: `parts` no longer contains any data borrowed for `'sval`
            let mut parts = unsafe {
                mem::transmute::<BufMut<ValuePart<'sval>, 1>, BufMut<ValuePart<'static>, 1>>(parts)
            };

            crate::assert_static(&mut parts);
            crate::assert_static(&mut stack);
            crate::assert_static(&mut is_in_text_or_binary);
            crate::assert_static(&mut err);

            Ok(ValueBuf {
                parts,
                stack,
                is_in_text_or_binary,
                err,
                _marker: PhantomData,
            })
        }
        #[cfg(not(feature = "alloc"))]
        {
            Err(Error::no_alloc("owned value"))
        }
    }

    fn try_catch(
        &mut self,
        f: impl FnOnce(&mut ValueBuf<'sval>) -> Result<(), Error>,
    ) -> sval::Result {
        match f(self) {
            Ok(()) => Ok(()),
            Err(e) => self.fail(e),
        }
    }

    fn fail(&mut self, err: Error) -> sval::Result {
        self.err = Some(err);
        sval::error()
    }

    /**
    Take an error produced while attempting to buffer a value.

    This method may return `None` even if streaming failed if a value failed
    without ever calling into the buffer.
    */
    pub fn into_err(self) -> Option<Error> {
        self.err
    }
}

impl ValueBuf<'static> {
    /**
    Fully buffer a value, including any internal borrowed data.

    This method will fail if the `alloc` feature is not enabled.
    */
    pub fn collect_owned(v: impl sval::Value) -> Result<Self, Error> {
        let mut buf = ValueBuf::new();

        // Buffering the value as computed means any borrowed data will
        // have to be converted into owned anyways
        match sval::stream_computed(&mut buf, v) {
            Ok(()) => Ok(buf),
            Err(_) => Err(buf
                .into_err()
                .unwrap_or_else(|| Error::invalid_value("the value itself failed to stream"))),
        }
    }
}

impl<'sval> Value<'sval> {
    /**
    Buffer a value.

    This method will fail if the `alloc` feature is not enabled.
    */
    pub fn collect(v: &'sval (impl sval::Value + ?Sized)) -> Result<Self, Error> {
        ValueBuf::collect(v).map(|buf| buf.into_value())
    }

    /**
    Fully buffer this value, including any internal borrowed data.

    This method will fail if the `alloc` feature is not enabled.
    */
    pub fn into_owned(self) -> Result<Value<'static>, Error> {
        #[cfg(feature = "alloc")]
        {
            let Value { mut parts, _marker } = self;

            // Re-assign all parts within the value in-place without re-allocating for them
            // This will take care of converted any actually borrowed data into owned
            for part in parts.iter_mut() {
                crate::assert_static(part.into_owned_in_place());
            }

            // SAFETY: `parts` no longer contains any data borrowed for `'sval`
            let mut parts = unsafe {
                mem::transmute::<Buf<ValuePart<'sval>, 1>, Buf<ValuePart<'static>, 1>>(parts)
            };
            crate::assert_static(&mut parts);

            Ok(Value {
                parts,
                _marker: PhantomData,
            })
        }
        #[cfg(not(feature = "alloc"))]
        {
            Err(Error::no_alloc("owned value"))
        }
    }
}

impl Value<'static> {
    /**
    Fully buffer a value, including any internal borrowed data.

    This method will fail if the `alloc` feature is not enabled.
    */
    pub fn collect_owned(v: impl sval::Value) -> Result<Self, Error> {
        ValueBuf::collect_owned(v).map(|buf| buf.into_value())
    }
}

impl<'a> sval::Value for ValueBuf<'a> {
    fn stream<'sval, S: sval::Stream<'sval> + ?Sized>(&'sval self, stream: &mut S) -> sval::Result {
        self.stream_ref(stream)
    }
}

impl<'sval> sval_ref::ValueRef<'sval> for ValueBuf<'sval> {
    fn stream_ref<S: sval::Stream<'sval> + ?Sized>(&self, stream: &mut S) -> sval::Result {
        stream_ref(&self.parts, stream)
    }
}

impl<'a> sval::Value for Value<'a> {
    fn stream<'sval, S: sval::Stream<'sval> + ?Sized>(&'sval self, stream: &mut S) -> sval::Result {
        self.stream_ref(stream)
    }
}

impl<'sval> sval_ref::ValueRef<'sval> for Value<'sval> {
    fn stream_ref<S: sval::Stream<'sval> + ?Sized>(&self, stream: &mut S) -> sval::Result {
        stream_ref(&self.parts, stream)
    }
}

fn stream_ref<'a, 'sval, S: sval::Stream<'sval> + ?Sized>(
    parts: &'a [ValuePart<'sval>],
    stream: &mut S,
) -> sval::Result {
    // If the buffer is empty then stream null
    if parts.len() == 0 {
        return stream.null();
    }

    ValueSlice::new(parts).stream_ref(stream)
}

impl<'sval> sval::Stream<'sval> for ValueBuf<'sval> {
    fn null(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::Null))
    }

    fn bool(&mut self, value: bool) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::Bool(value)))
    }

    fn text_begin(&mut self, _: Option<usize>) -> sval::Result {
        self.try_catch(|buf| {
            buf.is_in_text_or_binary = true;
            buf.push_kind(ValueKind::Text(TextBuf::new()))
        })?;

        Ok(())
    }

    fn text_fragment(&mut self, fragment: &'sval str) -> sval::Result {
        self.try_catch(|buf| match buf.current_mut().kind {
            ValueKind::Text(ref mut text) => text.push_fragment(fragment),
            _ => Err(Error::outside_container("text")),
        })
    }

    fn text_fragment_computed(&mut self, fragment: &str) -> sval::Result {
        self.try_catch(|buf| match buf.current_mut().kind {
            ValueKind::Text(ref mut text) => text.push_fragment_computed(fragment),
            _ => Err(Error::outside_container("text")),
        })
    }

    fn text_end(&mut self) -> sval::Result {
        self.is_in_text_or_binary = false;

        Ok(())
    }

    fn binary_begin(&mut self, _: Option<usize>) -> sval::Result {
        self.try_catch(|buf| {
            buf.is_in_text_or_binary = true;
            buf.push_kind(ValueKind::Binary(BinaryBuf::new()))
        })
    }

    fn binary_fragment(&mut self, fragment: &'sval [u8]) -> sval::Result {
        self.try_catch(|buf| match buf.current_mut().kind {
            ValueKind::Binary(ref mut binary) => binary.push_fragment(fragment),
            _ => Err(Error::outside_container("binary")),
        })
    }

    fn binary_fragment_computed(&mut self, fragment: &[u8]) -> sval::Result {
        self.try_catch(|buf| match buf.current_mut().kind {
            ValueKind::Binary(ref mut binary) => binary.push_fragment_computed(fragment),
            _ => Err(Error::outside_container("binary")),
        })
    }

    fn binary_end(&mut self) -> sval::Result {
        self.is_in_text_or_binary = false;

        Ok(())
    }

    fn u8(&mut self, value: u8) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::U8(value)))
    }

    fn u16(&mut self, value: u16) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::U16(value)))
    }

    fn u32(&mut self, value: u32) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::U32(value)))
    }

    fn u64(&mut self, value: u64) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::U64(value)))
    }

    fn u128(&mut self, value: u128) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::U128(value)))
    }

    fn i8(&mut self, value: i8) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::I8(value)))
    }

    fn i16(&mut self, value: i16) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::I16(value)))
    }

    fn i32(&mut self, value: i32) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::I32(value)))
    }

    fn i64(&mut self, value: i64) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::I64(value)))
    }

    fn i128(&mut self, value: i128) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::I128(value)))
    }

    fn f32(&mut self, value: f32) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::F32(value)))
    }

    fn f64(&mut self, value: f64) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::F64(value)))
    }

    fn map_begin(&mut self, num_entries_hint: Option<usize>) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::Map {
                len: 0,
                num_entries_hint,
            })
        })
    }

    fn map_key_begin(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_begin(ValueKind::MapKey { len: 0 }))
    }

    fn map_key_end(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn map_value_begin(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_begin(ValueKind::MapValue { len: 0 }))
    }

    fn map_value_end(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn map_end(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn seq_begin(&mut self, num_entries_hint: Option<usize>) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::Seq {
                len: 0,
                num_entries_hint,
            })
        })
    }

    fn seq_value_begin(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_begin(ValueKind::SeqValue { len: 0 }))
    }

    fn seq_value_end(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn seq_end(&mut self) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn enum_begin(
        &mut self,
        tag: Option<&sval::Tag>,
        label: Option<&sval::Label>,
        index: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::Enum {
                len: 0,
                tag: tag.cloned(),
                index: index.cloned(),
                label: label
                    .map(|label| {
                        label
                            .try_to_owned()
                            .map_err(|_| Error::no_alloc("owned label"))
                    })
                    .transpose()?,
            })
        })
    }

    fn enum_end(
        &mut self,
        _: Option<&sval::Tag>,
        _: Option<&sval::Label>,
        _: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn tagged_begin(
        &mut self,
        tag: Option<&sval::Tag>,
        label: Option<&sval::Label>,
        index: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::Tagged {
                len: 0,
                tag: tag.cloned(),
                index: index.cloned(),
                label: label
                    .map(|label| {
                        label
                            .try_to_owned()
                            .map_err(|_| Error::no_alloc("owned label"))
                    })
                    .transpose()?,
            })
        })
    }

    fn tagged_end(
        &mut self,
        _: Option<&sval::Tag>,
        _: Option<&sval::Label>,
        _: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn tag(
        &mut self,
        tag: Option<&sval::Tag>,
        label: Option<&sval::Label>,
        index: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_kind(ValueKind::Tag {
                tag: tag.cloned(),
                index: index.cloned(),
                label: label
                    .map(|label| {
                        label
                            .try_to_owned()
                            .map_err(|_| Error::no_alloc("owned label"))
                    })
                    .transpose()?,
            })
        })
    }

    fn tag_hint(&mut self, tag: &sval::Tag) -> sval::Result {
        self.try_catch(|buf| buf.push_kind(ValueKind::TagHint { tag: tag.clone() }))
    }

    fn record_begin(
        &mut self,
        tag: Option<&sval::Tag>,
        label: Option<&sval::Label>,
        index: Option<&sval::Index>,
        num_entries: Option<usize>,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::Record {
                len: 0,
                tag: tag.cloned(),
                index: index.cloned(),
                label: label
                    .map(|label| {
                        label
                            .try_to_owned()
                            .map_err(|_| Error::no_alloc("owned label"))
                    })
                    .transpose()?,
                num_entries,
            })
        })
    }

    fn record_value_begin(&mut self, tag: Option<&sval::Tag>, label: &sval::Label) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::RecordValue {
                len: 0,
                tag: tag.cloned(),
                label: label
                    .try_to_owned()
                    .map_err(|_| Error::no_alloc("owned label"))?,
            })
        })
    }

    fn record_value_end(&mut self, _: Option<&sval::Tag>, _: &sval::Label) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn record_end(
        &mut self,
        _: Option<&sval::Tag>,
        _: Option<&sval::Label>,
        _: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn tuple_begin(
        &mut self,
        tag: Option<&sval::Tag>,
        label: Option<&sval::Label>,
        index: Option<&sval::Index>,
        num_entries: Option<usize>,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::Tuple {
                len: 0,
                tag: tag.cloned(),
                index: index.cloned(),
                label: label
                    .map(|label| {
                        label
                            .try_to_owned()
                            .map_err(|_| Error::no_alloc("owned label"))
                    })
                    .transpose()?,
                num_entries,
            })
        })
    }

    fn tuple_value_begin(&mut self, tag: Option<&sval::Tag>, index: &sval::Index) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::TupleValue {
                len: 0,
                tag: tag.cloned(),
                index: index.clone(),
            })
        })
    }

    fn tuple_value_end(&mut self, _: Option<&sval::Tag>, _: &sval::Index) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn tuple_end(
        &mut self,
        _: Option<&sval::Tag>,
        _: Option<&sval::Label>,
        _: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn record_tuple_begin(
        &mut self,
        tag: Option<&sval::Tag>,
        label: Option<&sval::Label>,
        index: Option<&sval::Index>,
        num_entries: Option<usize>,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::RecordTuple {
                len: 0,
                tag: tag.cloned(),
                index: index.cloned(),
                label: label
                    .map(|label| {
                        label
                            .try_to_owned()
                            .map_err(|_| Error::no_alloc("owned label"))
                    })
                    .transpose()?,
                num_entries,
            })
        })
    }

    fn record_tuple_value_begin(
        &mut self,
        tag: Option<&sval::Tag>,
        label: &sval::Label,
        index: &sval::Index,
    ) -> sval::Result {
        self.try_catch(|buf| {
            buf.push_begin(ValueKind::RecordTupleValue {
                len: 0,
                tag: tag.cloned(),
                label: label
                    .try_to_owned()
                    .map_err(|_| Error::no_alloc("owned label"))?,
                index: index.clone(),
            })
        })
    }

    fn record_tuple_value_end(
        &mut self,
        _: Option<&sval::Tag>,
        _: &sval::Label,
        _: &sval::Index,
    ) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }

    fn record_tuple_end(
        &mut self,
        _: Option<&sval::Tag>,
        _: Option<&sval::Label>,
        _: Option<&sval::Index>,
    ) -> sval::Result {
        self.try_catch(|buf| buf.push_end())
    }
}

/**
Buffer a value.
*/
pub fn stream_to_value<'sval>(
    v: &'sval (impl sval::Value + ?Sized),
) -> Result<ValueBuf<'sval>, Error> {
    ValueBuf::collect(v)
}

/**
Buffer an owned value.
*/
pub fn stream_to_value_owned(v: impl sval::Value) -> Result<ValueBuf<'static>, Error> {
    ValueBuf::collect_owned(v)
}

#[repr(transparent)]
struct ValueSlice<'sval>([ValuePart<'sval>]);

#[derive(Debug, Clone, PartialEq)]
struct ValuePart<'sval> {
    kind: ValueKind<'sval>,
}

#[derive(Debug, Clone, PartialEq)]
enum ValueKind<'sval> {
    Null,
    Bool(bool),
    U8(u8),
    U16(u16),
    U32(u32),
    U64(u64),
    U128(u128),
    I8(i8),
    I16(i16),
    I32(i32),
    I64(i64),
    I128(i128),
    F32(f32),
    F64(f64),
    Text(TextBuf<'sval>),
    Binary(BinaryBuf<'sval>),
    Map {
        len: usize,
        num_entries_hint: Option<usize>,
    },
    MapKey {
        len: usize,
    },
    MapValue {
        len: usize,
    },
    Seq {
        len: usize,
        num_entries_hint: Option<usize>,
    },
    SeqValue {
        len: usize,
    },
    Tag {
        tag: Option<sval::Tag>,
        label: Option<sval::Label<'static>>,
        index: Option<sval::Index>,
    },
    TagHint {
        tag: sval::Tag,
    },
    Enum {
        len: usize,
        tag: Option<sval::Tag>,
        label: Option<sval::Label<'static>>,
        index: Option<sval::Index>,
    },
    Tagged {
        len: usize,
        tag: Option<sval::Tag>,
        label: Option<sval::Label<'static>>,
        index: Option<sval::Index>,
    },
    Record {
        len: usize,
        tag: Option<sval::Tag>,
        label: Option<sval::Label<'static>>,
        index: Option<sval::Index>,
        num_entries: Option<usize>,
    },
    RecordValue {
        len: usize,
        tag: Option<sval::Tag>,
        label: sval::Label<'static>,
    },
    Tuple {
        len: usize,
        tag: Option<sval::Tag>,
        label: Option<sval::Label<'static>>,
        index: Option<sval::Index>,
        num_entries: Option<usize>,
    },
    TupleValue {
        len: usize,
        tag: Option<sval::Tag>,
        index: sval::Index,
    },
    RecordTuple {
        len: usize,
        tag: Option<sval::Tag>,
        label: Option<sval::Label<'static>>,
        index: Option<sval::Index>,
        num_entries: Option<usize>,
    },
    RecordTupleValue {
        len: usize,
        tag: Option<sval::Tag>,
        label: sval::Label<'static>,
        index: sval::Index,
    },
}

impl<'sval> ValueBuf<'sval> {
    fn push_kind(&mut self, kind: ValueKind<'sval>) -> Result<(), Error> {
        self.parts.push(ValuePart { kind })
    }

    fn push_begin(&mut self, kind: ValueKind<'sval>) -> Result<(), Error> {
        self.stack.push(self.parts.len())?;
        self.parts.push(ValuePart { kind })
    }

    fn push_end(&mut self) -> Result<(), Error> {
        let index = self
            .stack
            .pop()
            .ok_or_else(|| Error::invalid_value("unbalanced calls to `begin` and `end`"))?;

        let len = self.parts.len() - index - 1;

        *match &mut self.parts.get_mut(index).unwrap().kind {
            ValueKind::Map { len, .. } => len,
            ValueKind::MapKey { len } => len,
            ValueKind::MapValue { len } => len,
            ValueKind::Seq { len, .. } => len,
            ValueKind::SeqValue { len } => len,
            ValueKind::Enum { len, .. } => len,
            ValueKind::Tagged { len, .. } => len,
            ValueKind::Record { len, .. } => len,
            ValueKind::RecordValue { len, .. } => len,
            ValueKind::Tuple { len, .. } => len,
            ValueKind::TupleValue { len, .. } => len,
            ValueKind::RecordTuple { len, .. } => len,
            ValueKind::RecordTupleValue { len, .. } => len,
            ValueKind::Null
            | ValueKind::Bool(_)
            | ValueKind::U8(_)
            | ValueKind::U16(_)
            | ValueKind::U32(_)
            | ValueKind::U64(_)
            | ValueKind::U128(_)
            | ValueKind::I8(_)
            | ValueKind::I16(_)
            | ValueKind::I32(_)
            | ValueKind::I64(_)
            | ValueKind::I128(_)
            | ValueKind::F32(_)
            | ValueKind::F64(_)
            | ValueKind::Text(_)
            | ValueKind::Binary(_)
            | ValueKind::Tag { .. }
            | ValueKind::TagHint { .. } => {
                return Err(Error::invalid_value("can't end at this index"))
            }
        } = len;

        Ok(())
    }

    fn current_mut(&mut self) -> &mut ValuePart<'sval> {
        self.parts.last_mut().expect("missing current")
    }
}

impl<'sval> ValueSlice<'sval> {
    fn new<'a>(parts: &'a [ValuePart<'sval>]) -> &'a ValueSlice<'sval> {
        unsafe { mem::transmute::<&'a [ValuePart<'sval>], &'a ValueSlice<'sval>>(parts) }
    }

    fn get(&self, i: usize) -> Option<&ValuePart<'sval>> {
        self.0.get(i)
    }

    fn slice<'a>(&'a self, range: Range<usize>) -> &'a ValueSlice<'sval> {
        match self.0.get(range.clone()) {
            Some(_) => (),
            None => {
                panic!("{:?} is out of range for {:?}", range, &self.0);
            }
        }

        // SAFETY: `&[ValuePart]` and `&ValueSlice` have the same ABI
        unsafe { mem::transmute::<&'a [ValuePart<'sval>], &'a ValueSlice<'sval>>(&self.0[range]) }
    }
}

#[cfg(feature = "alloc")]
impl<'sval> ValuePart<'sval> {
    fn into_owned_in_place(&mut self) -> &mut ValuePart<'static> {
        let ValuePart { kind } = self;

        match kind {
            ValueKind::Text(ref mut text) => crate::assert_static(text.into_owned_in_place()),
            ValueKind::Binary(ref mut binary) => crate::assert_static(binary.into_owned_in_place()),
            ValueKind::Null => (),
            ValueKind::Bool(v) => crate::assert_static(v),
            ValueKind::U8(v) => crate::assert_static(v),
            ValueKind::U16(v) => crate::assert_static(v),
            ValueKind::U32(v) => crate::assert_static(v),
            ValueKind::U64(v) => crate::assert_static(v),
            ValueKind::U128(v) => crate::assert_static(v),
            ValueKind::I8(v) => crate::assert_static(v),
            ValueKind::I16(v) => crate::assert_static(v),
            ValueKind::I32(v) => crate::assert_static(v),
            ValueKind::I64(v) => crate::assert_static(v),
            ValueKind::I128(v) => crate::assert_static(v),
            ValueKind::F32(v) => crate::assert_static(v),
            ValueKind::F64(v) => crate::assert_static(v),
            ValueKind::Map {
                len,
                num_entries_hint,
            } => {
                crate::assert_static(len);
                crate::assert_static(num_entries_hint)
            }
            ValueKind::MapKey { len } => crate::assert_static(len),
            ValueKind::MapValue { len } => crate::assert_static(len),
            ValueKind::Seq {
                len,
                num_entries_hint,
            } => {
                crate::assert_static(len);
                crate::assert_static(num_entries_hint)
            }
            ValueKind::SeqValue { len } => crate::assert_static(len),
            ValueKind::Tag { tag, label, index } => {
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index)
            }
            ValueKind::TagHint { tag } => {
                crate::assert_static(tag);
            }
            ValueKind::Enum {
                len,
                tag,
                label,
                index,
            } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index)
            }
            ValueKind::Tagged {
                len,
                tag,
                label,
                index,
            } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index)
            }
            ValueKind::Record {
                len,
                tag,
                label,
                index,
                num_entries,
            } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index);
                crate::assert_static(num_entries)
            }
            ValueKind::RecordValue { len, tag, label } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label)
            }
            ValueKind::Tuple {
                len,
                tag,
                label,
                index,
                num_entries,
            } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index);
                crate::assert_static(num_entries)
            }
            ValueKind::TupleValue { len, tag, index } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(index)
            }
            ValueKind::RecordTuple {
                len,
                tag,
                label,
                index,
                num_entries,
            } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index);
                crate::assert_static(num_entries)
            }
            ValueKind::RecordTupleValue {
                len,
                tag,
                label,
                index,
            } => {
                crate::assert_static(len);
                crate::assert_static(tag);
                crate::assert_static(label);
                crate::assert_static(index)
            }
        }

        // SAFETY: `self` no longer contains any data borrowed for `'sval`
        unsafe { mem::transmute::<&mut ValuePart<'sval>, &mut ValuePart<'static>>(self) }
    }
}

impl<'a> sval::Value for ValueSlice<'a> {
    fn stream<'sval, S: sval::Stream<'sval> + ?Sized>(&'sval self, stream: &mut S) -> sval::Result {
        self.stream_ref(stream)
    }
}

impl<'sval> sval_ref::ValueRef<'sval> for ValueSlice<'sval> {
    fn stream_ref<'a, S: sval::Stream<'sval> + ?Sized>(&'a self, stream: &mut S) -> sval::Result {
        let mut i = 0;

        fn stream_value<'a, 'sval, S: sval::Stream<'sval> + ?Sized>(
            stream: &mut S,
            i: &mut usize,
            len: usize,
            value: &ValueSlice<'sval>,
            f: impl FnOnce(&mut S, &ValueSlice<'sval>) -> sval::Result,
        ) -> sval::Result {
            let value = value.slice({
                let start = *i + 1;
                let end = start + len;

                start..end
            });

            f(stream, value)?;

            *i += len;

            Ok(())
        }

        while let Some(part) = self.get(i) {
            let part: &ValuePart<'sval> = part;
            match &part.kind {
                ValueKind::Null => stream.null()?,
                ValueKind::Bool(v) => stream.bool(*v)?,
                ValueKind::U8(v) => stream.u8(*v)?,
                ValueKind::U16(v) => stream.u16(*v)?,
                ValueKind::U32(v) => stream.u32(*v)?,
                ValueKind::U64(v) => stream.u64(*v)?,
                ValueKind::U128(v) => stream.u128(*v)?,
                ValueKind::I8(v) => stream.i8(*v)?,
                ValueKind::I16(v) => stream.i16(*v)?,
                ValueKind::I32(v) => stream.i32(*v)?,
                ValueKind::I64(v) => stream.i64(*v)?,
                ValueKind::I128(v) => stream.i128(*v)?,
                ValueKind::F32(v) => stream.f32(*v)?,
                ValueKind::F64(v) => stream.f64(*v)?,
                ValueKind::Text(v) => sval_ref::stream_ref(stream, v)?,
                ValueKind::Binary(v) => sval_ref::stream_ref(stream, v)?,
                ValueKind::Map {
                    len,
                    num_entries_hint,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.map_begin(*num_entries_hint)?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.map_end()
                    })?;
                }
                ValueKind::MapKey { len } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.map_key_begin()?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.map_key_end()
                    })?;
                }
                ValueKind::MapValue { len } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.map_value_begin()?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.map_value_end()
                    })?;
                }
                ValueKind::Seq {
                    len,
                    num_entries_hint,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.seq_begin(*num_entries_hint)?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.seq_end()
                    })?;
                }
                ValueKind::SeqValue { len } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.seq_value_begin()?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.seq_value_end()
                    })?;
                }
                ValueKind::Tag { tag, label, index } => {
                    stream.tag(tag.as_ref(), label.as_ref(), index.as_ref())?;
                }
                ValueKind::TagHint { tag } => {
                    stream.tag_hint(tag)?;
                }
                ValueKind::Enum {
                    len,
                    tag,
                    label,
                    index,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.enum_begin(tag.as_ref(), label.as_ref(), index.as_ref())?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.enum_end(tag.as_ref(), label.as_ref(), index.as_ref())
                    })?;
                }
                ValueKind::Tagged {
                    len,
                    tag,
                    label,
                    index,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.tagged_begin(tag.as_ref(), label.as_ref(), index.as_ref())?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.tagged_end(tag.as_ref(), label.as_ref(), index.as_ref())
                    })?;
                }
                ValueKind::Record {
                    len,
                    tag,
                    label,
                    index,
                    num_entries,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.record_begin(
                            tag.as_ref(),
                            label.as_ref(),
                            index.as_ref(),
                            *num_entries,
                        )?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.record_end(tag.as_ref(), label.as_ref(), index.as_ref())
                    })?;
                }
                ValueKind::RecordValue { len, tag, label } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.record_value_begin(tag.as_ref(), label)?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.record_value_end(tag.as_ref(), label)
                    })?;
                }
                ValueKind::Tuple {
                    len,
                    tag,
                    label,
                    index,
                    num_entries,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.tuple_begin(
                            tag.as_ref(),
                            label.as_ref(),
                            index.as_ref(),
                            *num_entries,
                        )?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.tuple_end(tag.as_ref(), label.as_ref(), index.as_ref())
                    })?;
                }
                ValueKind::TupleValue { len, tag, index } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.tuple_value_begin(tag.as_ref(), index)?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.tuple_value_end(tag.as_ref(), index)
                    })?;
                }
                ValueKind::RecordTuple {
                    len,
                    tag,
                    label,
                    index,
                    num_entries,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.record_tuple_begin(
                            tag.as_ref(),
                            label.as_ref(),
                            index.as_ref(),
                            *num_entries,
                        )?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.record_tuple_end(tag.as_ref(), label.as_ref(), index.as_ref())
                    })?;
                }
                ValueKind::RecordTupleValue {
                    len,
                    tag,
                    label,
                    index,
                } => {
                    stream_value(stream, &mut i, *len, self, |stream, body| {
                        stream.record_tuple_value_begin(tag.as_ref(), label, index)?;
                        sval_ref::stream_ref(stream, body)?;
                        stream.record_tuple_value_end(tag.as_ref(), label, index)
                    })?;
                }
            }

            i += 1;
        }

        Ok(())
    }
}

#[cfg(not(feature = "alloc"))]
mod array_vec {
    use crate::{
        std::{
            fmt, mem,
            ops::{Deref, DerefMut},
        },
        Error,
    };

    pub(super) struct ArrayVec<T, const N: usize> {
        buf: [mem::MaybeUninit<T>; N],
        len: usize,
    }

    impl<T: Clone, const N: usize> Clone for ArrayVec<T, N> {
        fn clone(&self) -> Self {
            let mut buf = Self::default();

            for value in self.iter().cloned() {
                buf.push(value).unwrap();
            }

            buf
        }
    }

    impl<T, const N: usize> Default for ArrayVec<T, N> {
        fn default() -> Self {
            ArrayVec {
                // SAFETY: An array of uninitialized values is valid
                buf: unsafe {
                    mem::MaybeUninit::<[mem::MaybeUninit<T>; N]>::uninit().assume_init()
                },
                len: 0,
            }
        }
    }

    impl<T, const N: usize> Drop for ArrayVec<T, N> {
        fn drop(&mut self) {
            // SAFETY: Values up to `self.len` are initialized
            unsafe {
                crate::std::ptr::drop_in_place::<[T]>(&mut **self as *mut [T]);
            }
        }
    }

    impl<T: fmt::Debug, const N: usize> fmt::Debug for ArrayVec<T, N> {
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
            fmt::Debug::fmt(&**self, f)
        }
    }

    impl<T, const N: usize> Deref for ArrayVec<T, N> {
        type Target = [T];

        fn deref(&self) -> &Self::Target {
            let buf = &self.buf[..self.len];

            // SAFETY: Values up to `self.len` are initialized
            unsafe { &*(buf as *const [mem::MaybeUninit<T>] as *const [T]) }
        }
    }

    impl<T, const N: usize> DerefMut for ArrayVec<T, N> {
        fn deref_mut(&mut self) -> &mut Self::Target {
            let buf = &mut self.buf[..self.len];

            // SAFETY: Values up to `self.len` are initialized
            unsafe { &mut *(buf as *mut [mem::MaybeUninit<T>] as *mut [T]) }
        }
    }

    impl<T, const N: usize> ArrayVec<T, N> {
        pub(super) fn push(&mut self, value: T) -> Result<(), Error> {
            if self.len == N {
                return Err(Error::no_alloc("vec push"));
            }

            mem::MaybeUninit::write(&mut self.buf[self.len], value);
            self.len += 1;

            Ok(())
        }

        pub(super) fn pop(&mut self) -> Option<T> {
            match self.len.checked_sub(1) {
                Some(i) => {
                    self.len = i;

                    // SAFETY: The value at `i` is initialized and being moved out of
                    Some(unsafe { mem::MaybeUninit::assume_init_read(&self.buf[i]) })
                }
                None => None,
            }
        }

        pub(super) fn clear(&mut self) {
            *self = Default::default()
        }
    }

    #[cfg(test)]
    mod tests {
        use super::*;

        use alloc::rc::Rc;

        #[test]
        fn push_pop() {
            let mut vec = ArrayVec::<_, 2>::default();

            assert!(vec.pop().is_none());

            assert!(vec.push(1).is_ok());
            assert!(vec.push(2).is_ok());
            assert!(vec.push(3).is_err());

            assert_eq!(2, vec.pop().unwrap());
            assert_eq!(1, vec.pop().unwrap());
            assert!(vec.pop().is_none());

            assert!(vec.push(1).is_ok());

            assert_eq!(1, vec.pop().unwrap());
            assert!(vec.pop().is_none());
        }

        #[test]
        fn destructors() {
            let mut vec = ArrayVec::<_, 5>::default();

            let a = Rc::new(1);
            let b = Rc::new(2);

            vec.push(a.clone()).unwrap();
            vec.push(b.clone()).unwrap();

            assert_eq!(2, Rc::strong_count(&a));
            assert_eq!(2, Rc::strong_count(&b));

            drop(vec);

            assert_eq!(1, Rc::strong_count(&a));
            assert_eq!(1, Rc::strong_count(&b));
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    use sval::Stream as _;

    #[test]
    fn is_send_sync() {
        fn assert<T: Send + Sync>() {}

        assert::<ValueBuf>();
        assert::<Value>();
    }

    #[test]
    fn empty_is_complete() {
        assert!(!ValueBuf::new().is_complete());
    }

    #[test]
    fn primitive_is_complete() {
        assert!(ValueBuf::collect(&42).unwrap().is_complete());
    }

    #[test]
    fn text_is_complete() {
        let mut buf = ValueBuf::new();

        buf.text_begin(None).unwrap();

        assert!(!buf.is_complete());

        buf.text_end().unwrap();

        assert!(buf.is_complete());
    }

    #[test]
    fn binary_is_complete() {
        let mut buf = ValueBuf::new();

        buf.binary_begin(None).unwrap();

        assert!(!buf.is_complete());

        buf.binary_end().unwrap();

        assert!(buf.is_complete());
    }

    #[test]
    fn map_is_complete() {
        let mut buf = ValueBuf::new();

        buf.map_begin(None).unwrap();

        assert!(!buf.is_complete());

        buf.map_end().unwrap();

        assert!(buf.is_complete());
    }

    #[test]
    fn seq_is_complete() {
        let mut buf = ValueBuf::new();

        buf.seq_begin(None).unwrap();

        assert!(!buf.is_complete());

        buf.seq_end().unwrap();

        assert!(buf.is_complete());
    }

    #[test]
    fn empty() {
        use sval_test::{assert_tokens, Token::*};

        assert_tokens(&ValueBuf::new(), &[Null]);
    }

    #[test]
    fn buffer_primitive() {
        for (value, expected) in [
            (
                ValueBuf::collect(&true).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::Bool(true),
                }],
            ),
            (
                ValueBuf::collect(&1i8).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::I8(1),
                }],
            ),
            (
                ValueBuf::collect(&2i16).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::I16(2),
                }],
            ),
            (
                ValueBuf::collect(&3i32).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::I32(3),
                }],
            ),
            (
                ValueBuf::collect(&4i64).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::I64(4),
                }],
            ),
            (
                ValueBuf::collect(&5i128).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::I128(5),
                }],
            ),
            (
                ValueBuf::collect(&1u8).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::U8(1),
                }],
            ),
            (
                ValueBuf::collect(&2u16).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::U16(2),
                }],
            ),
            (
                ValueBuf::collect(&3u32).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::U32(3),
                }],
            ),
            (
                ValueBuf::collect(&4u64).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::U64(4),
                }],
            ),
            (
                ValueBuf::collect(&5u128).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::U128(5),
                }],
            ),
            (
                ValueBuf::collect(&3.14f32).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::F32(3.14),
                }],
            ),
            (
                ValueBuf::collect(&3.1415f64).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::F64(3.1415),
                }],
            ),
            (
                ValueBuf::collect("abc").unwrap(),
                vec![ValuePart {
                    kind: ValueKind::Text(TextBuf::from("abc")),
                }],
            ),
            (
                ValueBuf::collect(sval::BinarySlice::new(b"abc")).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::Binary(BinaryBuf::from(b"abc")),
                }],
            ),
            (
                ValueBuf::collect(sval::MapSlice::<&str, i32>::new(&[])).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::Map {
                        len: 0,
                        num_entries_hint: Some(0),
                    },
                }],
            ),
            (
                ValueBuf::collect(&[] as &[i32]).unwrap(),
                vec![ValuePart {
                    kind: ValueKind::Seq {
                        len: 0,
                        num_entries_hint: Some(0),
                    },
                }],
            ),
        ] {
            assert_eq!(expected, &*value.parts, "{:?}", value);
        }
    }

    #[test]
    fn buffer_empty_enum() {
        let mut buf = ValueBuf::new();

        buf.enum_begin(None, Some(&sval::Label::new("Enum")), None)
            .unwrap();
        buf.enum_end(None, Some(&sval::Label::new("Enum")), None)
            .unwrap();

        assert_eq!(
            &[ValuePart {
                kind: ValueKind::Enum {
                    len: 0,
                    tag: None,
                    label: Some(sval::Label::new("Enum")),
                    index: None
                }
            }],
            &*buf.parts
        );
    }

    #[test]
    fn buffer_empty_record() {
        let mut buf = ValueBuf::new();

        buf.record_begin(None, Some(&sval::Label::new("Record")), None, Some(0))
            .unwrap();
        buf.record_end(None, Some(&sval::Label::new("Record")), None)
            .unwrap();

        assert_eq!(
            &[ValuePart {
                kind: ValueKind::Record {
                    len: 0,
                    tag: None,
                    label: Some(sval::Label::new("Record")),
                    index: None,
                    num_entries: Some(0)
                }
            }],
            &*buf.parts
        );
    }

    #[test]
    fn buffer_empty_tuple() {
        let mut buf = ValueBuf::new();

        buf.tuple_begin(None, Some(&sval::Label::new("Tuple")), None, Some(0))
            .unwrap();
        buf.tuple_end(None, Some(&sval::Label::new("Tuple")), None)
            .unwrap();

        assert_eq!(
            &[ValuePart {
                kind: ValueKind::Tuple {
                    len: 0,
                    tag: None,
                    label: Some(sval::Label::new("Tuple")),
                    index: None,
                    num_entries: Some(0)
                }
            }],
            &*buf.parts
        );
    }

    #[test]
    fn buffer_reuse() {
        let mut buf = ValueBuf::new();

        buf.i32(42).unwrap();

        assert_eq!(
            &*Value::collect(&42i32).unwrap().parts,
            &*buf.to_value().parts
        );

        buf.clear();

        buf.bool(true).unwrap();

        assert_eq!(
            &*Value::collect(&true).unwrap().parts,
            &*buf.to_value().parts
        );
    }

    #[test]
    fn buffer_invalid() {
        struct Kaboom;

        impl sval::Value for Kaboom {
            fn stream<'sval, S: sval::Stream<'sval> + ?Sized>(
                &'sval self,
                _: &mut S,
            ) -> sval::Result {
                sval::error()
            }
        }

        // Ensure we don't panic
        let _ = Value::collect(&Kaboom);
        let _ = Value::collect_owned(&Kaboom);
    }
}

#[cfg(test)]
#[cfg(feature = "alloc")]
mod alloc_tests {
    use super::*;

    use crate::std::string::String;

    use sval::Stream as _;
    use sval_derive_macros::*;

    #[test]
    fn collect_owned() {
        let short_lived = String::from("abc");

        let buf = ValueBuf::collect_owned(&short_lived).unwrap();
        drop(short_lived);

        match buf.parts[0].kind {
            ValueKind::Text(ref text) => {
                assert!(text.as_borrowed_str().is_none());
                assert_eq!("abc", text.as_str());
            }
            _ => unreachable!(),
        }
    }

    #[test]
    fn into_owned() {
        let short_lived = String::from("abc");

        let buf = ValueBuf::collect(&short_lived).unwrap();
        let borrowed_ptr = buf.parts.as_ptr() as *const ();

        let owned = buf.into_owned().unwrap();
        let owned_ptr = owned.parts.as_ptr() as *const ();
        drop(short_lived);

        assert!(core::ptr::eq(borrowed_ptr, owned_ptr));

        match owned.parts[0].kind {
            ValueKind::Text(ref text) => {
                assert!(text.as_borrowed_str().is_none());
                assert_eq!("abc", text.as_str());
            }
            _ => unreachable!(),
        }
    }

    #[test]
    fn buffer_option() {
        let expected = vec![ValuePart {
            kind: ValueKind::Tag {
                tag: Some(sval::tags::RUST_OPTION_NONE),
                label: Some(sval::Label::new("None")),
                index: Some(sval::Index::new(0)),
            },
        }];

        assert_eq!(expected, &*ValueBuf::collect(&None::<i32>).unwrap().parts);

        let expected = vec![
            ValuePart {
                kind: ValueKind::Tagged {
                    len: 1,
                    tag: Some(sval::tags::RUST_OPTION_SOME),
                    label: Some(sval::Label::new("Some")),
                    index: Some(sval::Index::new(1)),
                },
            },
            ValuePart {
                kind: ValueKind::I32(42),
            },
        ];

        assert_eq!(expected, &*ValueBuf::collect(&Some(42i32)).unwrap().parts);
    }

    #[test]
    fn buffer_map() {
        let mut value = ValueBuf::new();

        value.map_begin(Some(2)).unwrap();

        value.map_key_begin().unwrap();
        value.i32(0).unwrap();
        value.map_key_end().unwrap();

        value.map_value_begin().unwrap();
        value.bool(false).unwrap();
        value.map_value_end().unwrap();

        value.map_key_begin().unwrap();
        value.i32(1).unwrap();
        value.map_key_end().unwrap();

        value.map_value_begin().unwrap();
        value.bool(true).unwrap();
        value.map_value_end().unwrap();

        value.map_end().unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::Map {
                    len: 8,
                    num_entries_hint: Some(2),
                },
            },
            ValuePart {
                kind: ValueKind::MapKey { len: 1 },
            },
            ValuePart {
                kind: ValueKind::I32(0),
            },
            ValuePart {
                kind: ValueKind::MapValue { len: 1 },
            },
            ValuePart {
                kind: ValueKind::Bool(false),
            },
            ValuePart {
                kind: ValueKind::MapKey { len: 1 },
            },
            ValuePart {
                kind: ValueKind::I32(1),
            },
            ValuePart {
                kind: ValueKind::MapValue { len: 1 },
            },
            ValuePart {
                kind: ValueKind::Bool(true),
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_seq() {
        let mut value = ValueBuf::new();

        value.seq_begin(Some(2)).unwrap();

        value.seq_value_begin().unwrap();
        value.bool(false).unwrap();
        value.seq_value_end().unwrap();

        value.seq_value_begin().unwrap();
        value.bool(true).unwrap();
        value.seq_value_end().unwrap();

        value.seq_end().unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::Seq {
                    len: 4,
                    num_entries_hint: Some(2),
                },
            },
            ValuePart {
                kind: ValueKind::SeqValue { len: 1 },
            },
            ValuePart {
                kind: ValueKind::Bool(false),
            },
            ValuePart {
                kind: ValueKind::SeqValue { len: 1 },
            },
            ValuePart {
                kind: ValueKind::Bool(true),
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_record() {
        let mut value = ValueBuf::new();

        value
            .record_begin(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
                Some(2),
            )
            .unwrap();

        value
            .record_value_begin(None, &sval::Label::new("a"))
            .unwrap();
        value.bool(false).unwrap();
        value
            .record_value_end(None, &sval::Label::new("a"))
            .unwrap();

        value
            .record_value_begin(None, &sval::Label::new("b"))
            .unwrap();
        value.bool(true).unwrap();
        value
            .record_value_end(None, &sval::Label::new("b"))
            .unwrap();

        value
            .record_end(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
            )
            .unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::Record {
                    len: 4,
                    tag: Some(sval::Tag::new("test")),
                    label: Some(sval::Label::new("A")),
                    index: Some(sval::Index::new(1)),
                    num_entries: Some(2),
                },
            },
            ValuePart {
                kind: ValueKind::RecordValue {
                    len: 1,
                    tag: None,
                    label: sval::Label::new("a"),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(false),
            },
            ValuePart {
                kind: ValueKind::RecordValue {
                    len: 1,
                    tag: None,
                    label: sval::Label::new("b"),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(true),
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_tuple() {
        let mut value = ValueBuf::new();

        value
            .tuple_begin(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
                Some(2),
            )
            .unwrap();

        value.tuple_value_begin(None, &sval::Index::new(0)).unwrap();
        value.bool(false).unwrap();
        value.tuple_value_end(None, &sval::Index::new(0)).unwrap();

        value.tuple_value_begin(None, &sval::Index::new(1)).unwrap();
        value.bool(true).unwrap();
        value.tuple_value_end(None, &sval::Index::new(1)).unwrap();

        value
            .tuple_end(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
            )
            .unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::Tuple {
                    len: 4,
                    tag: Some(sval::Tag::new("test")),
                    label: Some(sval::Label::new("A")),
                    index: Some(sval::Index::new(1)),
                    num_entries: Some(2),
                },
            },
            ValuePart {
                kind: ValueKind::TupleValue {
                    len: 1,
                    tag: None,
                    index: sval::Index::new(0),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(false),
            },
            ValuePart {
                kind: ValueKind::TupleValue {
                    len: 1,
                    tag: None,
                    index: sval::Index::new(1),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(true),
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_record_tuple() {
        let mut value = ValueBuf::new();

        value
            .record_tuple_begin(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
                Some(2),
            )
            .unwrap();

        value
            .record_tuple_value_begin(None, &sval::Label::new("a"), &sval::Index::new(0))
            .unwrap();
        value.bool(false).unwrap();
        value
            .record_tuple_value_end(None, &sval::Label::new("a"), &sval::Index::new(0))
            .unwrap();

        value
            .record_tuple_value_begin(None, &sval::Label::new("b"), &sval::Index::new(1))
            .unwrap();
        value.bool(true).unwrap();
        value
            .record_tuple_value_end(None, &sval::Label::new("b"), &sval::Index::new(1))
            .unwrap();

        value
            .record_tuple_end(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
            )
            .unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::RecordTuple {
                    len: 4,
                    tag: Some(sval::Tag::new("test")),
                    label: Some(sval::Label::new("A")),
                    index: Some(sval::Index::new(1)),
                    num_entries: Some(2),
                },
            },
            ValuePart {
                kind: ValueKind::RecordTupleValue {
                    len: 1,
                    tag: None,
                    label: sval::Label::new("a"),
                    index: sval::Index::new(0),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(false),
            },
            ValuePart {
                kind: ValueKind::RecordTupleValue {
                    len: 1,
                    tag: None,
                    label: sval::Label::new("b"),
                    index: sval::Index::new(1),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(true),
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_enum() {
        let mut value = ValueBuf::new();

        value
            .enum_begin(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
            )
            .unwrap();

        value
            .tag(
                None,
                Some(&sval::Label::new("B")),
                Some(&sval::Index::new(0)),
            )
            .unwrap();

        value
            .enum_end(
                Some(&sval::Tag::new("test")),
                Some(&sval::Label::new("A")),
                Some(&sval::Index::new(1)),
            )
            .unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::Enum {
                    len: 1,
                    tag: Some(sval::Tag::new("test")),
                    label: Some(sval::Label::new("A")),
                    index: Some(sval::Index::new(1)),
                },
            },
            ValuePart {
                kind: ValueKind::Tag {
                    tag: None,
                    label: Some(sval::Label::new("B")),
                    index: Some(sval::Index::new(0)),
                },
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_tag_hints() {
        let mut value = ValueBuf::new();

        value.tag_hint(&sval::Tag::new("test")).unwrap();

        value.seq_begin(Some(2)).unwrap();

        value.seq_value_begin().unwrap();
        value.tag_hint(&sval::Tag::new("test")).unwrap();
        value.bool(false).unwrap();
        value.seq_value_end().unwrap();

        value.seq_value_begin().unwrap();
        value.bool(true).unwrap();
        value.seq_value_end().unwrap();

        value.seq_end().unwrap();

        value.tag_hint(&sval::Tag::new("test")).unwrap();

        let expected = vec![
            ValuePart {
                kind: ValueKind::TagHint {
                    tag: sval::Tag::new("test"),
                },
            },
            ValuePart {
                kind: ValueKind::Seq {
                    len: 5,
                    num_entries_hint: Some(2),
                },
            },
            ValuePart {
                kind: ValueKind::SeqValue { len: 2 },
            },
            ValuePart {
                kind: ValueKind::TagHint {
                    tag: sval::Tag::new("test"),
                },
            },
            ValuePart {
                kind: ValueKind::Bool(false),
            },
            ValuePart {
                kind: ValueKind::SeqValue { len: 1 },
            },
            ValuePart {
                kind: ValueKind::Bool(true),
            },
            ValuePart {
                kind: ValueKind::TagHint {
                    tag: sval::Tag::new("test"),
                },
            },
        ];

        assert_eq!(expected, &*value.parts);
    }

    #[test]
    fn buffer_roundtrip() {
        for value_1 in [
            ValueBuf::collect(&42i32).unwrap(),
            ValueBuf::collect(&vec![
                vec![],
                vec![vec![1, 2, 3], vec![4]],
                vec![vec![5, 6], vec![7, 8, 9]],
            ])
            .unwrap(),
            ValueBuf::collect(&{
                #[derive(Value)]
                struct Record {
                    a: i32,
                    b: bool,
                }

                Record { a: 42, b: true }
            })
            .unwrap(),
            ValueBuf::collect(&{
                #[derive(Value)]
                struct Tuple(i32, bool);

                Tuple(42, true)
            })
            .unwrap(),
            ValueBuf::collect(&{
                #[derive(Value)]
                enum Enum {
                    A,
                }

                Enum::A
            })
            .unwrap(),
        ] {
            let value_2 = ValueBuf::collect(&value_1).unwrap();

            assert_eq!(&*value_1.parts, &*value_2.parts, "{:?}", value_1);
        }
    }
}

Coverage Report

Created: 2025-12-31 06:22

Line	Count	Source
1		use crate::{
2		std::{
3		marker::PhantomData,
4		mem,
5		ops::{Deref, DerefMut, Range},
6		},
7		BinaryBuf, Error, TextBuf,
8		};
9
10		use sval_ref::ValueRef as _;
11
12		#[derive(Debug, Clone)]
13		struct BufMut<T, const N: usize> {
14		#[cfg(feature = "alloc")]
15		inner: crate::std::vec::Vec<T>,
16		#[cfg(not(feature = "alloc"))]
17		inner: array_vec::ArrayVec<T, N>,
18		}
19
20		impl<T, const N: usize> Default for BufMut<T, N> {
21	0	fn default() -> Self {
22	0	BufMut {
23	0	inner: Default::default(),
24	0	}
25	0	} Unexecuted instantiation: <sval_buffer::value::BufMut<sval_buffer::value::ValuePart, 1> as core::default::Default>::default Unexecuted instantiation: <sval_buffer::value::BufMut<usize, 1> as core::default::Default>::default
26		}
27
28		impl<T, const N: usize> Deref for BufMut<T, N> {
29		type Target = [T];
30
31	0	fn deref(&self) -> &Self::Target {
32	0	&self.inner
33	0	} Unexecuted instantiation: <sval_buffer::value::BufMut<sval_buffer::value::ValuePart, 1> as core::ops::deref::Deref>::deref Unexecuted instantiation: <sval_buffer::value::BufMut<usize, 1> as core::ops::deref::Deref>::deref
34		}
35
36		impl<T, const N: usize> DerefMut for BufMut<T, N> {
37	0	fn deref_mut(&mut self) -> &mut Self::Target {
38	0	&mut self.inner
39	0	}