pub mod derived_traits;
pub mod upgrade;
use aligned_vec::{ABox, AVec};
use num_complex::Complex;
use std::convert::Infallible;
use std::fmt::Display;
use std::marker::PhantomData;
pub use derived_traits::{Version, VersionsDispatch};
pub use upgrade::Upgrade;
use serde::de::DeserializeOwned;
use serde::Serialize;
pub use tfhe_versionable_derive::{NotVersioned, Version, Versionize, VersionsDispatch};
pub trait Versionize {
type Versioned<'vers>: Serialize
where
Self: 'vers;
fn versionize(&self) -> Self::Versioned<'_>;
type VersionedOwned: Serialize + DeserializeOwned;
fn versionize_owned(&self) -> Self::VersionedOwned;
}
pub trait VersionizeVec: Sized {
type VersionedSlice<'vers>: Serialize
where
Self: 'vers;
fn versionize_slice(slice: &[Self]) -> Self::VersionedSlice<'_>;
type VersionedVec: Serialize + DeserializeOwned;
fn versionize_vec(slice: &[Self]) -> Self::VersionedVec;
}
#[derive(Debug)]
pub enum UnversionizeError {
Upgrade {
from_vers: String,
into_vers: String,
message: String,
},
Conversion { from_type: String, message: String },
}
impl Display for UnversionizeError {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self {
Self::Upgrade {
from_vers,
into_vers,
message,
} => write!(
f,
"Failed to upgrade from {from_vers} into {into_vers}: {message}"
),
Self::Conversion { from_type, message } => {
write!(f, "Failed to convert from {from_type}: {message}")
}
}
}
}
impl UnversionizeError {
pub fn upgrade(from_vers: &str, into_vers: &str, message: &str) -> Self {
Self::Upgrade {
from_vers: from_vers.to_string(),
into_vers: into_vers.to_string(),
message: message.to_string(),
}
}
pub fn conversion(from_type: &str, message: &str) -> Self {
Self::Conversion {
from_type: from_type.to_string(),
message: message.to_string(),
}
}
}
impl From<Infallible> for UnversionizeError {
fn from(_value: Infallible) -> Self {
panic!("Infallible error type should never be reached")
}
}
pub trait Unversionize: Versionize + Sized {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError>;
}
pub trait UnversionizeVec: VersionizeVec {
fn unversionize_vec(versioned: Self::VersionedVec) -> Result<Vec<Self>, UnversionizeError>;
}
pub trait NotVersioned: Versionize {}
impl<T: NotVersioned + Serialize + DeserializeOwned + Clone> VersionizeVec for T {
type VersionedSlice<'vers> = &'vers [T] where T: 'vers;
fn versionize_slice(slice: &[Self]) -> Self::VersionedSlice<'_> {
slice
}
type VersionedVec = Vec<T>;
fn versionize_vec(slice: &[Self]) -> Self::VersionedVec {
slice.to_vec()
}
}
impl<T: NotVersioned + Serialize + DeserializeOwned + Clone> UnversionizeVec for T {
fn unversionize_vec(versioned: Self::VersionedVec) -> Result<Vec<Self>, UnversionizeError> {
Ok(versioned)
}
}
macro_rules! impl_scalar_versionize {
($t:ty) => {
impl Versionize for $t {
type Versioned<'vers> = $t;
type VersionedOwned = $t;
fn versionize(&self) -> Self::Versioned<'_> {
*self
}
fn versionize_owned(&self) -> Self::VersionedOwned {
*self
}
}
impl Unversionize for $t {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok(versioned)
}
}
impl NotVersioned for $t {}
impl NotVersioned for Vec<$t> {}
};
}
impl_scalar_versionize!(bool);
impl_scalar_versionize!(u8);
impl_scalar_versionize!(u16);
impl_scalar_versionize!(u32);
impl_scalar_versionize!(u64);
impl_scalar_versionize!(u128);
impl_scalar_versionize!(usize);
impl_scalar_versionize!(i8);
impl_scalar_versionize!(i16);
impl_scalar_versionize!(i32);
impl_scalar_versionize!(i64);
impl_scalar_versionize!(i128);
impl_scalar_versionize!(f32);
impl_scalar_versionize!(f64);
impl_scalar_versionize!(char);
impl<T: Versionize> Versionize for Box<T> {
type Versioned<'vers> = T::Versioned<'vers> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
self.as_ref().versionize()
}
type VersionedOwned = Box<T::VersionedOwned>;
fn versionize_owned(&self) -> Self::VersionedOwned {
Box::new(T::versionize_owned(self))
}
}
impl<T: Unversionize> Unversionize for Box<T> {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok(Box::new(T::unversionize(*versioned)?))
}
}
impl<T: VersionizeVec> Versionize for Vec<T> {
type Versioned<'vers> = T::VersionedSlice<'vers> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
T::versionize_slice(self)
}
type VersionedOwned = T::VersionedVec;
fn versionize_owned(&self) -> Self::VersionedOwned {
T::versionize_vec(self)
}
}
impl<T: VersionizeVec + Clone> Versionize for [T] {
type Versioned<'vers> = T::VersionedSlice<'vers> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
T::versionize_slice(self)
}
type VersionedOwned = T::VersionedVec;
fn versionize_owned(&self) -> Self::VersionedOwned {
T::versionize_vec(self)
}
}
impl<T: UnversionizeVec> Unversionize for Vec<T> {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
T::unversionize_vec(versioned)
}
}
impl Versionize for String {
type Versioned<'vers> = &'vers str;
fn versionize(&self) -> Self::Versioned<'_> {
self.as_ref()
}
type VersionedOwned = Self;
fn versionize_owned(&self) -> Self::VersionedOwned {
self.clone()
}
}
impl Unversionize for String {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok(versioned)
}
}
impl NotVersioned for String {}
impl Versionize for str {
type Versioned<'vers> = &'vers str;
fn versionize(&self) -> Self::Versioned<'_> {
self
}
type VersionedOwned = String;
fn versionize_owned(&self) -> Self::VersionedOwned {
self.to_string()
}
}
impl NotVersioned for str {}
impl<T: Versionize> Versionize for Option<T> {
type Versioned<'vers> = Option<T::Versioned<'vers>> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
self.as_ref().map(|val| val.versionize())
}
type VersionedOwned = Option<T::VersionedOwned>;
fn versionize_owned(&self) -> Self::VersionedOwned {
self.as_ref().map(|val| val.versionize_owned())
}
}
impl<T: Unversionize> Unversionize for Option<T> {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
versioned.map(|val| T::unversionize(val)).transpose()
}
}
impl<T: NotVersioned> NotVersioned for Option<T> {}
impl<T> Versionize for PhantomData<T> {
type Versioned<'vers> = Self
where
Self: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
*self
}
type VersionedOwned = Self;
fn versionize_owned(&self) -> Self::VersionedOwned {
*self
}
}
impl<T> Unversionize for PhantomData<T> {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok(versioned)
}
}
impl<T> NotVersioned for PhantomData<T> {}
impl<T: Versionize> Versionize for Complex<T> {
type Versioned<'vers> = Complex<T::Versioned<'vers>> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
Complex {
re: self.re.versionize(),
im: self.im.versionize(),
}
}
type VersionedOwned = Complex<T::VersionedOwned>;
fn versionize_owned(&self) -> Self::VersionedOwned {
Complex {
re: self.re.versionize_owned(),
im: self.im.versionize_owned(),
}
}
}
impl<T: Unversionize> Unversionize for Complex<T> {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok(Complex {
re: T::unversionize(versioned.re)?,
im: T::unversionize(versioned.im)?,
})
}
}
impl<T: NotVersioned> NotVersioned for Complex<T> {}
impl<T: Versionize> Versionize for ABox<T> {
type Versioned<'vers> = T::Versioned<'vers> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
self.as_ref().versionize()
}
type VersionedOwned = Box<T::VersionedOwned>;
fn versionize_owned(&self) -> Self::VersionedOwned {
Box::new(T::versionize_owned(self))
}
}
impl<T: Unversionize> Unversionize for ABox<T>
where
T::VersionedOwned: Clone,
{
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok(ABox::new(0, T::unversionize((*versioned).to_owned())?))
}
}
impl<T: VersionizeVec> Versionize for AVec<T> {
type Versioned<'vers> = T::VersionedSlice<'vers> where T: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
T::versionize_slice(self)
}
type VersionedOwned = T::VersionedVec;
fn versionize_owned(&self) -> Self::VersionedOwned {
T::versionize_vec(self)
}
}
impl<T: UnversionizeVec> Unversionize for AVec<T> {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
T::unversionize_vec(versioned).map(|unver| AVec::from_iter(0, unver))
}
}
impl<T: NotVersioned + Clone + Serialize + DeserializeOwned> NotVersioned for AVec<T> {}
impl<T: Versionize, U: Versionize> Versionize for (T, U) {
type Versioned<'vers> = (T::Versioned<'vers>, U::Versioned<'vers>) where T: 'vers, U: 'vers;
fn versionize(&self) -> Self::Versioned<'_> {
(self.0.versionize(), self.1.versionize())
}
type VersionedOwned = (T::VersionedOwned, U::VersionedOwned);
fn versionize_owned(&self) -> Self::VersionedOwned {
(self.0.versionize_owned(), self.1.versionize_owned())
}
}
impl<T: Unversionize, U: Unversionize> Unversionize for (T, U) {
fn unversionize(versioned: Self::VersionedOwned) -> Result<Self, UnversionizeError> {
Ok((T::unversionize(versioned.0)?, U::unversionize(versioned.1)?))
}
}
impl<T: NotVersioned, U: NotVersioned> NotVersioned for (T, U) {}