searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2024-11-30 00:34:26 +01:00
Code Issues Releases Wiki Activity

Merge pull request #223 from meilisearch/fix-update-serialization

Browse Source 
Fix updates serialization to use serde_json instead of bincode
This commit is contained in:
Clément Renault 2019-10-17 13:05:25 +02:00 committed by GitHub
commit 16f0914f09
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
meilidb-core/src/store/updates.rs
View File

@ -1,11 +1,31 @@
use zlmdb::types::{OwnedType, Serde}; use std::borrow::Cow;
use zlmdb::Result as ZResult; use zlmdb::types::OwnedType;
use zlmdb::{Result as ZResult, BytesEncode, BytesDecode};
use serde::{Serialize, Deserialize};
use crate::update::Update; use crate::update::Update;
use super::BEU64; use super::BEU64;
pub struct SerdeJson<T>(std::marker::PhantomData<T>);
impl<T> BytesEncode for SerdeJson<T> where T: Serialize {
type EItem = T;
fn bytes_encode(item: &Self::EItem) -> Option<Cow<[u8]>> {
serde_json::to_vec(item).map(Cow::Owned).ok()
}
}
impl<'a, T: 'a> BytesDecode<'a> for SerdeJson<T> where T: Deserialize<'a> + Clone {
type DItem = T;
fn bytes_decode(bytes: &'a [u8]) -> Option<Self::DItem> {
serde_json::from_slice(bytes).ok()
}
}
#[derive(Copy, Clone)] #[derive(Copy, Clone)]
pub struct Updates { pub struct Updates {
pub(crate) updates: zlmdb::Database<OwnedType<BEU64>, Serde<Update>>, pub(crate) updates: zlmdb::Database<OwnedType<BEU64>, SerdeJson<Update>>,
} }
impl Updates { impl Updates {