use crate::error;
use crate::frame::Version;
use crate::query;
use num::BigInt;
use std::io::{Cursor, Write};
pub trait Serialize {
fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, version: Version);
fn serialize_to_vec(&self, version: Version) -> Vec<u8> {
let mut buf = vec![];
self.serialize(&mut Cursor::new(&mut buf), version);
buf
}
}
pub trait FromBytes {
fn from_bytes(bytes: &[u8]) -> error::Result<Self>
where
Self: Sized;
}
pub trait FromCursor {
fn from_cursor(cursor: &mut Cursor<&[u8]>, version: Version) -> error::Result<Self>
where
Self: Sized;
}
pub trait IntoQueryValues {
fn into_query_values(self) -> query::QueryValues;
}
pub trait TryFromRow: Sized {
fn try_from_row(row: crate::types::rows::Row) -> error::Result<Self>;
}
pub trait TryFromUdt: Sized {
fn try_from_udt(udt: crate::types::udt::Udt) -> error::Result<Self>;
}
impl<const S: usize> Serialize for [u8; S] {
fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, _version: Version) {
let _ = cursor.write(self);
}
}
impl Serialize for &[u8] {
#[inline]
fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, _version: Version) {
let _ = cursor.write(self);
}
}
impl Serialize for Vec<u8> {
#[inline]
fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, _version: Version) {
let _ = cursor.write(self);
}
}
impl Serialize for BigInt {
#[inline]
fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, _version: Version) {
let _ = cursor.write(&self.to_signed_bytes_be());
}
}
macro_rules! impl_serialized {
($t:ty) => {
impl Serialize for $t {
#[inline]
fn serialize(&self, cursor: &mut Cursor<&mut Vec<u8>>, _version: Version) {
let _ = cursor.write(&self.to_be_bytes());
}
}
};
}
impl_serialized!(i8);
impl_serialized!(i16);
impl_serialized!(i32);
impl_serialized!(i64);
impl_serialized!(u8);
impl_serialized!(u16);
impl_serialized!(u32);
impl_serialized!(u64);