config

Author: Migorithm

duva/src/adapters/op_logs/disk_based.rs

@@ -588,7 +588,7 @@ mod tests {
         file.read_to_end(&mut buf).unwrap();
 
         let (encoded, _): (WriteOperation, usize) =
-            bincode::decode_from_slice(&buf[1..], bincode::config::standard()).unwrap();
+            bincode::decode_from_slice(&buf[1..], SERDE_CONFIG).unwrap();
 
         assert_eq!(encoded.entry, request);
     }

duva/src/domains/caches/cache_objects/entry.rs

@@ -70,6 +70,8 @@ impl CacheEntry {
 
 #[cfg(test)]
 mod tests {
+    use crate::domains::query_io::SERDE_CONFIG;
+
     use super::*;
     use bincode::{decode_from_slice, encode_to_vec};
     use chrono::{DateTime, Utc};
@@ -82,10 +84,10 @@ mod tests {
         let original_value = CacheValue::new("test_value").with_expiry(expiry_time);
 
         // WHEN
-        let encoded = encode_to_vec(&original_value, bincode::config::standard()).unwrap();
+        let encoded = encode_to_vec(&original_value, SERDE_CONFIG).unwrap();
 
         let (decoded_value, _): (CacheValue, usize) =
-            decode_from_slice(&encoded, bincode::config::standard()).unwrap();
+            decode_from_slice(&encoded, SERDE_CONFIG).unwrap();
 
         // THEN - Verify the decoded value matches the original
         assert_eq!(decoded_value.value, original_value.value);
@@ -99,11 +101,11 @@ mod tests {
         let original_value = CacheValue::new("test_value_no_expiry");
 
         // Encode the value
-        let encoded = encode_to_vec(&original_value, bincode::config::standard()).unwrap();
+        let encoded = encode_to_vec(&original_value, SERDE_CONFIG).unwrap();
 
         // Decode the value back
         let (decoded_value, _): (CacheValue, usize) =
-            decode_from_slice(&encoded, bincode::config::standard()).unwrap();
+            decode_from_slice(&encoded, SERDE_CONFIG).unwrap();
 
         // Verify the decoded value matches the original
         assert_eq!(decoded_value.value, original_value.value);
@@ -120,11 +122,11 @@ mod tests {
             .with_expiry(DateTime::from_timestamp_millis(expiry_millis).unwrap());
 
         // Encode the entry
-        let encoded = encode_to_vec(&original_entry, bincode::config::standard()).unwrap();
+        let encoded = encode_to_vec(&original_entry, SERDE_CONFIG).unwrap();
 
         // Decode the entry back
         let (decoded_entry, _): (CacheEntry, usize) =
-            decode_from_slice(&encoded, bincode::config::standard()).unwrap();
+            decode_from_slice(&encoded, SERDE_CONFIG).unwrap();
 
         // Verify the decoded entry matches the original
         assert_eq!(decoded_entry.key(), original_entry.key());

duva/src/domains/caches/cache_objects/value.rs

@@ -74,15 +74,16 @@ impl THasExpiry for CacheValue {
 
 #[cfg(test)]
 mod tests {
+    use crate::domains::query_io::SERDE_CONFIG;
+
     use super::*;
     use bincode::{decode_from_slice, encode_to_vec};
 
     #[test]
     fn test_string_variant_encode_decode() {
         let original = CacheValue::new("hello");
-        let encoded = encode_to_vec(&original, bincode::config::standard()).unwrap();
-        let (decoded, _): (CacheValue, usize) =
-            decode_from_slice(&encoded, bincode::config::standard()).unwrap();
+        let encoded = encode_to_vec(&original, SERDE_CONFIG).unwrap();
+        let (decoded, _): (CacheValue, usize) = decode_from_slice(&encoded, SERDE_CONFIG).unwrap();
         assert_eq!(decoded, original);
         assert_eq!(decoded.value, TypedValue::String(Bytes::copy_from_slice(b"hello").into()));
     }
@@ -95,9 +96,8 @@ mod tests {
             q_list.rpush(i);
         }
         let original = CacheValue { value: TypedValue::List(q_list.clone()), expiry: None };
-        let encoded = encode_to_vec(&original, bincode::config::standard()).unwrap();
-        let (decoded, _): (CacheValue, usize) =
-            decode_from_slice(&encoded, bincode::config::standard()).unwrap();
+        let encoded = encode_to_vec(&original, SERDE_CONFIG).unwrap();
+        let (decoded, _): (CacheValue, usize) = decode_from_slice(&encoded, SERDE_CONFIG).unwrap();
         assert_eq!(decoded, original);
         assert_eq!(decoded.value, TypedValue::List(q_list));
     }