Bump deps

core/Cargo.toml

@@ -57,7 +57,7 @@ web-sys = { version = "0.3.60", features = ["Storage"], optional = true }
 [target."cfg(target_arch = \"wasm32\")".dependencies]
 getrandom = "0.2.7"
 wasm-bindgen = "0.2.83"
-wasm-bindgen-futures = "0.4.32"
+wasm-bindgen-futures = "0.4.33"
 chrono = { version = "0.4.22", default-features = false, features = [] }
 
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]

store/Cargo.toml

@@ -48,7 +48,7 @@ exocore-transport = {version = "0.1.23", path = "../transport", default-features
 byteorder = { version = "1.4.3", optional = true }
 crc = { version = "3.0.0", optional = true }
 extsort = { version = "0.4.2", optional = true }
-lru = { version = "0.7.8", optional = true }
+lru = { version = "0.8.0", optional = true }
 serde = { version = "1.0.144", optional = true }
 serde_derive = { version = "1.0.144", optional = true }
 serde_json = { version = "1.0.85", optional = true }

store/src/local/mutation_index/entity_cache.rs

@@ -1,4 +1,4 @@
-use std::sync::Mutex;
+use std::{num::NonZeroUsize, sync::Mutex};
 
 use lru::LruCache;
 
@@ -17,7 +17,7 @@ pub struct EntityMutationsCache {
 }
 
 impl EntityMutationsCache {
-    pub fn new(size: usize) -> EntityMutationsCache {
+    pub fn new(size: NonZeroUsize) -> EntityMutationsCache {
         EntityMutationsCache {
             cache: Mutex::new(LruCache::new(size)),
         }

store/src/local/mutation_index/mod.rs

@@ -1,6 +1,8 @@
 use std::{
     borrow::Borrow,
     collections::BTreeMap,
+    convert::TryInto,
+    num::NonZeroUsize,
     ops::Deref,
     path::Path,
     result::Result,
@@ -104,14 +106,19 @@ impl MutationIndex {
             index.writer(config.indexer_heap_size_bytes)?
         };
 
+        let entity_cache_size: NonZeroUsize = config
+            .entity_mutations_cache_size
+            .try_into()
+            .map_err(|err| Error::Other(anyhow!("Invalid entity mutations cache size: {}", err)))?;
+
         Ok(MutationIndex {
             config,
             index,
             index_reader,
             index_writer: Mutex::new(index_writer),
             schema,
             storage: Storage::Disk,
-            entity_cache: EntityMutationsCache::new(config.entity_mutations_cache_size as usize),
+            entity_cache: EntityMutationsCache::new(entity_cache_size),
             full_text_boost: 1.0,
             schema_registry,
         })
@@ -141,14 +148,19 @@ impl MutationIndex {
             index.writer(config.indexer_heap_size_bytes)?
         };
 
+        let entity_cache_size: NonZeroUsize = config
+            .entity_mutations_cache_size
+            .try_into()
+            .map_err(|err| Error::Other(anyhow!("Invalid entity mutations cache size: {}", err)))?;
+
         Ok(MutationIndex {
             config,
             index,
             index_reader,
             index_writer: Mutex::new(index_writer),
             schema,
             storage: Storage::Memory,
-            entity_cache: EntityMutationsCache::new(config.entity_mutations_cache_size as usize),
+            entity_cache: EntityMutationsCache::new(entity_cache_size),
             full_text_boost: 1.0,
             schema_registry,
         })