bson 3.1.0

use std::{
    borrow::{Borrow, Cow},
    convert::TryFrom,
    ops::Deref,
};

use crate::{
    raw::{doc_writer::DocWriter, CStr},
    Document,
};

use super::{bson::RawBson, iter::Iter, RawBsonRef, RawDocument, RawIter, Result};

/// An owned BSON document (akin to [`std::path::PathBuf`]), backed by a buffer of raw BSON bytes.
/// This can be created from a `Vec<u8>` or a [`crate::Document`].
///
/// Accessing elements within a [`RawDocumentBuf`] is similar to element access in
/// [`crate::Document`], but because the contents are parsed during iteration instead of at creation
/// time, format errors can happen at any time during use.
///
/// Iterating over a [`RawDocumentBuf`] yields either an error or a key-value pair that borrows from
/// the original document without making any additional allocations.
///
/// ```
/// # use bson::error::Error;
/// use bson::raw::RawDocumentBuf;
///
/// let doc = RawDocumentBuf::from_bytes(b"\x13\x00\x00\x00\x02hi\x00\x06\x00\x00\x00y'all\x00\x00".to_vec())?;
/// let mut iter = doc.iter();
/// let (key, value) = iter.next().unwrap()?;
/// assert_eq!(key, "hi");
/// assert_eq!(value.as_str(), Some("y'all"));
/// assert!(iter.next().is_none());
/// # Ok::<(), Error>(())
/// ```
///
/// This type implements [`Deref`] to [`RawDocument`], meaning that all methods on [`RawDocument`]
/// are available on [`RawDocumentBuf`] values as well. This includes [`RawDocument::get`] or any of
/// the type-specific getters, such as [`RawDocument::get_object_id`] or [`RawDocument::get_str`].
/// Note that accessing elements is an O(N) operation, as it requires iterating through the document
/// from the beginning to find the requested key.
///
/// ```
/// use bson::raw::RawDocumentBuf;
///
/// let doc = RawDocumentBuf::from_bytes(b"\x13\x00\x00\x00\x02hi\x00\x06\x00\x00\x00y'all\x00\x00".to_vec())?;
/// assert_eq!(doc.get_str("hi")?, "y'all");
/// # Ok::<(), Box<dyn std::error::Error>>(())
/// ```
#[derive(Clone, PartialEq)]
pub struct RawDocumentBuf {
    data: Vec<u8>,
}

impl RawDocumentBuf {
    /// Creates a new, empty [`RawDocumentBuf`].
    pub fn new() -> Self {
        let mut data = Vec::new();
        DocWriter::open(&mut data);
        Self { data }
    }

    /// Constructs a new [`RawDocumentBuf`], validating _only_ the
    /// following invariants:
    ///   * `data` is at least five bytes long (the minimum for a valid BSON document)
    ///   * the initial four bytes of `data` accurately represent the length of the bytes as
    ///     required by the BSON spec.
    ///   * the last byte of `data` is a 0
    ///
    /// Note that the internal structure of the bytes representing the
    /// BSON elements is _not_ validated at all by this method. If the
    /// bytes do not conform to the BSON spec, then method calls on
    /// the RawDocument will return Errors where appropriate.
    ///
    /// ```
    /// # use bson::raw::RawDocumentBuf;
    /// let doc = RawDocumentBuf::from_bytes(b"\x05\0\0\0\0".to_vec())?;
    /// # Ok::<(), bson::error::Error>(())
    /// ```
    pub fn from_bytes(data: Vec<u8>) -> Result<Self> {
        let _ = RawDocument::from_bytes(data.as_slice())?;
        Ok(Self { data })
    }

    /// Constructs a new [`RawDocumentBuf`], validating _only_ the
    /// following invariants:
    ///   * `data` is at least five bytes long (the minimum for a valid BSON document)
    ///   * the initial four bytes of `data` accurately represent the length of the bytes as
    ///     required by the BSON spec.
    ///   * the last byte of `data` is a 0
    ///
    /// Note that the internal structure of the bytes representing the
    /// BSON elements is _not_ validated at all by this method. If the
    /// bytes do not conform to the BSON spec, then method calls on
    /// the RawDocument will return Errors where appropriate.
    ///
    /// ```
    /// # use bson::raw::RawDocumentBuf;
    /// let doc = RawDocumentBuf::from_reader(b"\x05\0\0\0\0".as_slice())?;
    /// # Ok::<(), bson::error::Error>(())
    /// ```
    pub fn from_reader<R: std::io::Read>(reader: R) -> Result<Self> {
        let buf = crate::raw::reader_to_vec(reader)?;
        Self::from_bytes(buf)
    }

    /// Gets an iterator over the elements in the [`RawDocumentBuf`], which yields
    /// `Result<(&str, RawBson<'_>)>`.
    ///
    /// ```
    /// use bson::{doc, raw::RawDocumentBuf};
    ///
    /// let doc = RawDocumentBuf::try_from(&doc! { "ferris": true })?;
    ///
    /// for element in doc.iter() {
    ///     let (key, value) = element?;
    ///     assert_eq!(key, "ferris");
    ///     assert_eq!(value.as_bool(), Some(true));
    /// }
    /// # Ok::<(), bson::error::Error>(())
    /// ```
    ///
    /// # Note:
    ///
    /// There is no owning iterator for [`RawDocumentBuf`]. If you need ownership over
    /// elements that might need to allocate, you must explicitly convert
    /// them to owned types yourself.
    pub fn iter(&self) -> Iter<'_> {
        Iter::new(self)
    }

    /// Gets an iterator over the elements in the [`RawDocumentBuf`],
    /// which yields `Result<RawElement<'_>>` values. These hold a
    /// reference to the underlying document but do not explicitly
    /// resolve the values.
    ///
    /// This iterator, which underpins the implementation of the
    /// default iterator, produces `RawElement` objects that hold a
    /// view onto the document but do not parse out or construct
    /// values until the `.value()` or `.try_into()` methods are
    /// called.
    ///
    /// # Note:
    ///
    /// There is no owning iterator for [`RawDocumentBuf`]. If you
    /// need ownership over elements that might need to allocate, you
    /// must explicitly convert them to owned types yourself.
    pub fn iter_elements(&self) -> RawIter<'_> {
        RawIter::new(self)
    }

    /// Return the contained data as a `Vec<u8>`
    ///
    /// ```
    /// use bson::{doc, raw::RawDocumentBuf};
    ///
    /// let doc = RawDocumentBuf::try_from(&doc!{})?;
    /// assert_eq!(doc.into_bytes(), b"\x05\x00\x00\x00\x00".to_vec());
    /// # Ok::<(), bson::error::Error>(())
    /// ```
    pub fn into_bytes(self) -> Vec<u8> {
        self.data
    }

    /// Append a key value pair to the end of the document without checking to see if
    /// the key already exists.
    ///
    /// It is a user error to append the same key more than once to the same document, and it may
    /// result in errors when communicating with MongoDB.
    ///
    /// Keys can be a [`&CStr`](crate::raw::CStr) or [`CString`](crate::raw::CString).
    ///
    /// Values can be any type that can be converted to either borrowed or owned raw bson data; see
    /// the documentation for [BindRawBsonRef] for more details.
    /// ```
    /// # use bson::error::Error;
    /// use bson::{Document, doc, raw::{cstr, RawBsonRef, RawDocumentBuf}};
    ///
    /// let mut doc = RawDocumentBuf::new();
    /// // `&str` and `i32` both convert to `RawBsonRef`
    /// doc.append(cstr!("a string"), "some string");
    /// doc.append(cstr!("an integer"), 12_i32);
    ///
    /// let mut subdoc = RawDocumentBuf::new();
    /// subdoc.append(cstr!("a key"), true);
    /// doc.append(cstr!("a borrowed document"), &subdoc);
    /// doc.append(cstr!("an owned document"), subdoc);
    ///
    /// let expected = doc! {
    ///     "a string": "some string",
    ///     "an integer": 12_i32,
    ///     "a borrowed document": { "a key": true },
    ///     "an owned document": { "a key": true },
    /// };
    ///
    /// assert_eq!(Document::try_from(doc)?, expected);
    /// # Ok::<(), Error>(())
    /// ```
    pub fn append(&mut self, key: impl AsRef<CStr>, value: impl BindRawBsonRef) {
        self.data.pop();
        let key = key.as_ref();
        value.bind(|value_ref| {
            let mut writer = DocWriter::resume(&mut self.data, 0);
            writer.append_key(value_ref.element_type(), key);
            value_ref.append_to(writer.buffer());
        });
    }
}

impl<K: AsRef<CStr>, B: BindRawBsonRef> FromIterator<(K, B)> for RawDocumentBuf {
    fn from_iter<T: IntoIterator<Item = (K, B)>>(iter: T) -> Self {
        let mut buf = RawDocumentBuf::new();
        for (k, v) in iter {
            buf.append(k, v);
        }
        buf
    }
}

impl Default for RawDocumentBuf {
    fn default() -> Self {
        Self::new()
    }
}

#[cfg(feature = "serde")]
impl<'de> serde::Deserialize<'de> for RawDocumentBuf {
    fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
    where
        D: serde::Deserializer<'de>,
    {
        Ok(super::serde::OwnedOrBorrowedRawDocument::deserialize(deserializer)?.into_owned())
    }
}

#[cfg(feature = "serde")]
impl serde::Serialize for RawDocumentBuf {
    fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
    where
        S: serde::Serializer,
    {
        let doc: &RawDocument = self.deref();
        doc.serialize(serializer)
    }
}

impl std::fmt::Debug for RawDocumentBuf {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("RawDocumentBuf")
            .field("data", &hex::encode(&self.data))
            .finish()
    }
}

impl From<RawDocumentBuf> for Cow<'_, RawDocument> {
    fn from(rd: RawDocumentBuf) -> Self {
        Cow::Owned(rd)
    }
}

impl<'a> From<&'a RawDocumentBuf> for Cow<'a, RawDocument> {
    fn from(rd: &'a RawDocumentBuf) -> Self {
        Cow::Borrowed(rd.as_ref())
    }
}

impl TryFrom<&Document> for RawDocumentBuf {
    type Error = crate::error::Error;

    fn try_from(doc: &Document) -> std::result::Result<Self, Self::Error> {
        let mut out = vec![];
        doc.append_to(&mut out)?;
        RawDocumentBuf::from_bytes(out)
    }
}

impl TryFrom<Document> for RawDocumentBuf {
    type Error = crate::error::Error;

    fn try_from(doc: Document) -> std::result::Result<Self, Self::Error> {
        RawDocumentBuf::try_from(&doc)
    }
}

impl<'a> IntoIterator for &'a RawDocumentBuf {
    type IntoIter = Iter<'a>;
    type Item = Result<(&'a CStr, RawBsonRef<'a>)>;

    fn into_iter(self) -> Iter<'a> {
        self.iter()
    }
}

impl AsRef<RawDocument> for RawDocumentBuf {
    fn as_ref(&self) -> &RawDocument {
        RawDocument::new_unchecked(&self.data)
    }
}

impl Deref for RawDocumentBuf {
    type Target = RawDocument;

    fn deref(&self) -> &Self::Target {
        RawDocument::new_unchecked(&self.data)
    }
}

impl Borrow<RawDocument> for RawDocumentBuf {
    fn borrow(&self) -> &RawDocument {
        self.deref()
    }
}

/// Types that can be consumed to produce raw bson references valid for a limited lifetime.
/// Conceptually a union between `T: Into<RawBson>` and `T: Into<RawBsonRef>`; if your type
/// implements `Into<RawBsonRef>` it will automatically implement this, but if it
/// implements `Into<RawBson>` it will need to also define an impl of `BindRawBsonRef`:
/// ```
/// # use bson::raw::{BindRawBsonRef, BindValue, RawBson};
/// # struct MyType;
/// # impl Into<RawBson> for MyType {
/// #  fn into(self: Self) -> RawBson { todo!() }
/// # }
/// impl BindRawBsonRef for MyType {
///   type Target = BindValue<Self>;
/// }
/// ```
#[allow(missing_docs)]
pub trait BindRawBsonRef: Sized {
    type Target: BindHelper<Target = Self>;

    fn bind<F, R>(self, f: F) -> R
    where
        F: for<'a> FnOnce(RawBsonRef<'a>) -> R,
    {
        <Self::Target as BindHelper>::bind(self, f)
    }
}

#[doc(hidden)]
pub trait BindHelper {
    type Target;
    fn bind<F, R>(target: Self::Target, f: F) -> R
    where
        F: for<'b> FnOnce(RawBsonRef<'b>) -> R;
}

/// A struct to use as the `Target` of a [`BindRawBsonRef`] impl for custom types.
pub struct BindValue<A>(std::marker::PhantomData<A>);
#[doc(hidden)]
pub struct BindRef<A>(std::marker::PhantomData<A>);

impl<A: Into<RawBson>> BindHelper for BindValue<A> {
    type Target = A;

    fn bind<F, R>(target: Self::Target, f: F) -> R
    where
        F: for<'a> FnOnce(RawBsonRef<'a>) -> R,
    {
        f(target.into().as_raw_bson_ref())
    }
}

impl<'a, A: Into<RawBsonRef<'a>> + 'a> BindHelper for BindRef<A> {
    type Target = A;

    fn bind<F, R>(target: Self::Target, f: F) -> R
    where
        F: for<'b> FnOnce(RawBsonRef<'a>) -> R,
    {
        f(target.into())
    }
}

impl<'a, T: Into<RawBsonRef<'a>> + 'a> BindRawBsonRef for T {
    type Target = BindRef<T>;
}

impl BindRawBsonRef for RawBson {
    type Target = BindValue<Self>;
}

macro_rules! raw_bson_from_impls {
    ($($t:ty),+$(,)?) => {
        $(
            impl BindRawBsonRef for $t {
                type Target = BindValue<Self>;
            }
        )+
    };
}

raw_bson_from_impls! {
    &crate::binary::Vector,
    crate::Binary,
    crate::DbPointer,
    super::RawArrayBuf,
    RawDocumentBuf,
    super::RawJavaScriptCodeWithScope,
    crate::Regex,
    String,
    crate::binary::Vector,
}