wtx 0.28.0

A collection of different transport implementations and related tools focused primarily on web technologies.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use crate::{
  database::client::mysql::{
    MysqlError,
    mysql_protocol::{
      MysqlProtocol, decode_wrapper_protocol::DecodeWrapperProtocol, lenenc::Lenenc,
    },
  },
  misc::{Decode, Usize},
};

pub(crate) struct LenencContent<'bytes>(pub(crate) &'bytes [u8]);

impl<'de, DO, E> Decode<'de, MysqlProtocol<DO, E>> for LenencContent<'de>
where
  E: From<crate::Error>,
{
  #[inline]
  fn decode(aux: &mut (), dw: &mut DecodeWrapperProtocol<'de, '_, DO>) -> Result<Self, E> {
    let len = Lenenc::decode(aux, dw)?;
    let Some((lhs, rhs)) = dw.bytes.split_at_checked(*Usize::try_from(len.0)?) else {
      return Err(E::from(MysqlError::InvalidLenencContentBytes.into()));
    };
    *dw.bytes = rhs;
    Ok(Self(lhs))
  }
}