deser-core 0.10.1

use crate::State;
use crate::de::{Deserialize, DeserializeDriver, SinkHandle};
use crate::error::{Error, ErrorKind};

/// Deserializes values from an input.
///
/// This is implemented by the deserializers of the data formats (for
/// instance `deser_json::Deserializer`) and by other sources of values
/// (like the value type of `deser-value`).  A deserializer holds its input,
/// every call deserializes the next value.  Deserializers implement
/// [`drive`](Self::drive) which parses the input and feeds the events of a
/// value into a driver.  The provided methods create the driver:
///
/// * [`deserialize`](Self::deserialize) deserializes a value.
/// * [`deserialize_with`](Self::deserialize_with) deserializes a value and
///   allows configuring the driver first, for instance to add
///   [`Layer`](crate::de::Layer)s, to wrap the sink of the value or to
///   give it a [`Context`](crate::Context).
///
/// ```
/// use deser::de::{DeserializeDriver, Deserializer, Limits};
/// use deser::{Context, Error, Event};
///
/// /// A format which reads comma separated numbers as a sequence.
/// struct Numbers<'a>(&'a str);
///
/// impl<'de> Deserializer<'de> for Numbers<'de> {
///     fn drive(
///         &mut self,
///         driver: &mut DeserializeDriver<'_, 'de>,
///     ) -> Result<(), Error> {
///         driver.emit(Event::seq_start())?;
///         for item in self.0.split(',') {
///             let value: u64 = item.trim().parse().map_err(|_| {
///                 Error::new(deser::ErrorKind::Syntax, "invalid number")
///             })?;
///             driver.emit(value)?;
///         }
///         driver.emit(Event::SeqEnd)
///     }
/// }
///
/// let value: Vec<u32> = Numbers("1, 2, 3").deserialize().unwrap();
/// assert_eq!(value, [1, 2, 3]);
///
/// let limits = Context::with(Limits::builder().max_items(2).build());
/// let rv = Numbers("1, 2, 3")
///     .deserialize_with::<Vec<u32>, _>(|driver| driver.set_context(limits.clone()));
/// assert_eq!(rv.unwrap_err().to_string(), "LimitExceeded: too many items");
/// ```
pub trait Deserializer<'de> {
    /// Parses the input and feeds the events of a value into the driver.
    fn drive(&mut self, driver: &mut DeserializeDriver<'_, 'de>) -> Result<(), Error>;

    /// Deserializes a value.
    fn deserialize<T: Deserialize<'de>>(&mut self) -> Result<T, Error>
    where
        Self: Sized,
    {
        self.deserialize_with(|_| {})
    }

    /// Deserializes a value with a configured driver.
    ///
    /// The callback is invoked with the driver before the first event is
    /// emitted.
    fn deserialize_with<T, F>(&mut self, setup: F) -> Result<T, Error>
    where
        T: Deserialize<'de>,
        F: FnOnce(&mut DeserializeDriver<'_, 'de>),
        Self: Sized,
    {
        deserialize_value(|driver| {
            setup(driver);
            self.drive(driver)
        })
    }

    /// Updates an existing value with the next value.
    ///
    /// See [`Deserialize::deserialize_update`].  If this fails, the value
    /// might be partially updated.
    fn update<T: Deserialize<'de>>(&mut self, value: &mut T) -> Result<(), Error>
    where
        Self: Sized,
    {
        self.update_with(value, |_| {})
    }

    /// Updates an existing value with the next value after setting up the
    /// driver.
    ///
    /// This is like [`update`](Self::update) but the callback is invoked
    /// with the driver first, like with
    /// [`deserialize_with`](Self::deserialize_with).
    fn update_with<T, F>(&mut self, value: &mut T, setup: F) -> Result<(), Error>
    where
        T: Deserialize<'de>,
        F: FnOnce(&mut DeserializeDriver<'_, 'de>),
        Self: Sized,
    {
        let mut driver = DeserializeDriver::update(value);
        setup(&mut driver);
        self.drive(&mut driver)
    }
}

/// Deserializes a value with a function that drives a deserializer.
///
/// This creates a [`DeserializeDriver`] for the value, invokes `drive`
/// with it and returns the value.  It does the same as
/// [`Deserializer::deserialize`] and is how formats implement functions
/// like `from_str`: if `drive` calls a function that is not generic over
/// the value (which creates the format's deserializer and drives it), the
/// code of the format exists once rather than once per type.
///
/// If no value was deserialized, an [`EndOfFile`](ErrorKind::EndOfFile)
/// error is returned.
///
/// ```
/// use deser::de::{Deserialize, DeserializeDriver, Deserializer, deserialize_value};
/// use deser::{Error, ErrorKind, Event};
///
/// /// A format which reads comma separated numbers as a sequence.
/// struct Numbers<'a>(&'a str);
///
/// impl<'de> Deserializer<'de> for Numbers<'de> {
///     fn drive(&mut self, driver: &mut DeserializeDriver<'_, 'de>) -> Result<(), Error> {
///         driver.emit(Event::seq_start())?;
///         for item in self.0.split(',') {
///             let value: u64 = item
///                 .trim()
///                 .parse()
///                 .map_err(|_| Error::new(ErrorKind::Syntax, "invalid number"))?;
///             driver.emit(value)?;
///         }
///         driver.emit(Event::SeqEnd)
///     }
/// }
///
/// /// Deserializes a value from comma separated numbers.
/// pub fn from_str<'de, T: Deserialize<'de>>(s: &'de str) -> Result<T, Error> {
///     deserialize_value(|driver| drive_str(s, driver))
/// }
///
/// /// The part of `from_str` that does not depend on the type of the value.
/// fn drive_str<'de>(s: &'de str, driver: &mut DeserializeDriver<'_, 'de>) -> Result<(), Error> {
///     Numbers(s).drive(driver)
/// }
///
/// let value: Vec<u32> = from_str("1, 2, 3").unwrap();
/// assert_eq!(value, [1, 2, 3]);
/// ```
#[inline]
pub fn deserialize_value<'de, T: Deserialize<'de>>(
    drive: impl FnOnce(&mut DeserializeDriver<'_, 'de>) -> Result<(), Error>,
) -> Result<T, Error> {
    // only creating the sink and taking the value depend on the type, the
    // driver is created, run and dropped by a function that exists once.
    let mut out = None;
    let mut slot = Some(&mut out);
    let mut drive = Some(drive);
    drive_new(
        &mut |state| match slot.take() {
            Some(slot) => {
                // the top-level value is requested before it starts
                state.raw_requested = T::__private_raw();
                T::deserialize_into(slot, state)
            }
            None => called_twice(),
        },
        &mut |driver| match drive.take() {
            Some(drive) => drive(driver),
            None => called_twice(),
        },
    )?;
    out.ok_or_else(empty_input)
}

/// Creates a driver with the sink `make` creates and runs `drive` with it.
#[inline(never)]
fn drive_new<'out, 'de>(
    make: &mut dyn FnMut(&mut State) -> SinkHandle<'out, 'de>,
    drive: &mut dyn FnMut(&mut DeserializeDriver<'_, 'de>) -> Result<(), Error>,
) -> Result<(), Error> {
    let mut state = State::new();
    let sink = make(&mut state);
    drive(&mut DeserializeDriver::from_state(state, sink))
}

#[cold]
#[inline(never)]
fn called_twice() -> ! {
    panic!("deserialize_value called a function twice")
}

#[cold]
fn empty_input() -> Error {
    Error::new(ErrorKind::EndOfFile, "empty input")
}