wtx 0.43.1

A collection of different transport implementations and related tools focused primarily on web technologies.
Documentation 
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

use crate::{
  codec::Decode,
  collection::Vector,
  database::client::mysql::{
    MysqlError, MysqlStatement, Ty,
    protocol::{Protocol, decode_wrapper_protocol::DecodeWrapperProtocol, lenenc::Lenenc},
  },
  misc::Usize,
};
use core::ops::Range;

type Params<'any> = (&'any MysqlStatement<'any>, &'any mut Vector<(bool, Range<usize>)>);

#[derive(Debug)]
pub(crate) struct BinaryRowRes<'de>(pub(crate) &'de [u8]);

impl<'de, E> Decode<'de, Protocol<Params<'_>, E>> for BinaryRowRes<'de>
where
  E: From<crate::Error>,
{
  #[inline]
  fn decode(dw: &mut DecodeWrapperProtocol<'de, '_, Params<'_>>) -> Result<Self, E> {
    let initial = *dw.bytes;
    let [a, rest0 @ ..] = dw.bytes else {
      return Err(E::from(MysqlError::InvalidBinaryRowBytes.into()));
    };
    *dw.bytes = rest0;
    if *a != 0 {
      return Err(E::from(MysqlError::InvalidBinaryRowBytes.into()));
    }
    let bitmap_len = dw.other.0.columns_len.wrapping_add(9) / 8;
    let Some((bitmap, rest1)) = dw.bytes.split_at_checked(bitmap_len) else {
      return Err(E::from(MysqlError::InvalidBinaryRowBytes.into()));
    };
    *dw.bytes = rest1;
    dw.other.1.reserve(dw.other.0.columns_len)?;
    let mut idx: usize = bitmap_len.wrapping_add(1);
    for (column_idx, (column, _)) in dw.other.0.columns().iter().enumerate() {
      let column_null_idx = column_idx.wrapping_add(2);
      let byte_idx = column_null_idx / 8;
      let bit_idx = column_null_idx % 8;
      let is_null = bitmap.get(byte_idx).copied().unwrap_or_default() & (1u8 << bit_idx) != 0;
      if is_null {
        dw.other.1.push((true, idx..idx))?;
        continue;
      }
      let len = match column.ty_params.ty() {
        Ty::Double => 8,
        Ty::Float => 4,
        Ty::Long | Ty::Int24 => 4,
        Ty::LongLong => 8,
        Ty::Short | Ty::Year => 2,
        Ty::Tiny => 1,

        Ty::Bit
        | Ty::Blob
        | Ty::Decimal
        | Ty::Enum
        | Ty::Geometry
        | Ty::Json
        | Ty::LongBlob
        | Ty::MediumBlob
        | Ty::NewDecimal
        | Ty::Set
        | Ty::String
        | Ty::TinyBlob
        | Ty::VarChar
        | Ty::VarString => {
          let before = dw.bytes.len();
          let rslt = Usize::from(Lenenc::decode(dw)?.0).into_usize();
          let diff = before.wrapping_sub(dw.bytes.len());
          idx = idx.wrapping_add(diff);
          rslt
        }

        Ty::Date | Ty::Datetime | Ty::Time | Ty::Timestamp => {
          usize::from(dw.bytes.first().copied().unwrap_or_default()).wrapping_add(1)
        }

        Ty::Null => return Err(E::from(MysqlError::InvalidBinaryRowBytes.into())),
      };
      let begin = idx;
      idx = idx.wrapping_add(len);
      *dw.bytes = dw.bytes.get(len..).unwrap_or_default();
      dw.other.1.push((false, begin..idx))?;
    }
    Ok(Self(initial))
  }
}