t/crdt-enc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: simplify supported version handling

Browse Source
This commit is contained in:
Thomas Heck
2021-02-15 21:24:26 +01:00
parent 3629c7b9bf
commit a3cec213cc
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crdt-enc/src/lib.rs
View File

@@ -31,7 +31,7 @@ use ::uuid::Uuid;
const CURRENT_VERSION: Uuid = Uuid::from_u128(0xe834d789_101b_4634_9823_9de990a9051f);
// needs to be sorted!
const SUPPORTED_VERSIONS: [Uuid; 1] = [
const SUPPORTED_VERSIONS: &[Uuid] = &[
Uuid::from_u128(0xe834d789_101b_4634_9823_9de990a9051f), // current
];
@@ -264,7 +264,7 @@ where
.context("failed getting local meta")?;
let local_meta: LocalMeta = match local_meta {
Some(local_meta) => {
local_meta.ensure_versions(&SUPPORTED_VERSIONS)?;
local_meta.ensure_versions(SUPPORTED_VERSIONS)?;
rmp_serde::from_read_ref(&local_meta)?
}
None => {
@@ -433,7 +433,7 @@ where
.map(|(name, state)| {
let key = key.clone();
async move {
state.ensure_versions(&SUPPORTED_VERSIONS)?;
state.ensure_versions(SUPPORTED_VERSIONS)?;
let clear_text = self
.cryptor
@@ -493,7 +493,7 @@ where
.map(|(actor, version, data)| {
let key = key.clone();
async move {
data.ensure_versions(&SUPPORTED_VERSIONS)?;
data.ensure_versions(SUPPORTED_VERSIONS)?;
let clear_text = self
.cryptor
.decrypt(key.key(), data.as_ref())
@@ -571,7 +571,7 @@ where
.context("failed loading remote meta while reading remote metas")?
.into_iter()
.map(|(name, vbox)| {
vbox.ensure_versions(&SUPPORTED_VERSIONS)?;
vbox.ensure_versions(SUPPORTED_VERSIONS)?;
let remote_meta: RemoteMeta = rmp_serde::from_read_ref(&vbox)?;

2
examples/test/src/main.rs
View File

@@ -6,7 +6,7 @@ use ::uuid::Uuid;
const CURRENT_DATA_VERSION: Uuid = Uuid::from_u128(0xaadfd5a6_6e19_4b24_a802_4fa27c72f20c);
const SUPPORTED_DATA_VERSIONS: [Uuid; 1] = [CURRENT_DATA_VERSION];
const SUPPORTED_DATA_VERSIONS: &[Uuid] = &[CURRENT_DATA_VERSION];
#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<()> {