Updates to new integer encoding API

Author: SirCipher

runtime/swimos_rocks_store/src/server/mod.rs

@@ -199,17 +199,17 @@ impl StoreKey {
         match self {
             StoreKey::Map { lane_id, key } => {
                 writer.write_all(&[MAP_TAG])?;
-                writer.write_all(lane_id.encode_fixed_light())?;
+                writer.write_all(&lane_id.encode_fixed_light())?;
                 if let Some(key) = key {
                     writer.write_all(&[KEY])?;
                     let len = u64::try_from(key.len()).expect("Length does not fit into u64");
-                    writer.write_all(len.encode_fixed_light())?;
+                    writer.write_all(&len.encode_fixed_light())?;
                     writer.write_all(key)?;
                 }
             }
             StoreKey::Value { lane_id } => {
                 writer.write_all(&[VAL_TAG])?;
-                writer.write_all(lane_id.encode_fixed_light())?;
+                writer.write_all(&lane_id.encode_fixed_light())?;
             }
         }
         Ok(())
@@ -238,7 +238,7 @@ impl StoreKey {
         W: Write,
     {
         writer.write_all(&[MAP_TAG])?;
-        writer.write_all(lane_id.encode_fixed_light())?;
+        writer.write_all(&lane_id.encode_fixed_light())?;
         writer.write_all(&[UBOUND])?;
         Ok(())
     }

runtime/swimos_rocks_store/src/server/tests.rs

@@ -24,7 +24,7 @@ fn serialize_value_key() {
     assert_eq!(bytes.len(), 9);
     assert_eq!(bytes[0], VAL_TAG);
 
-    assert_eq!(u64::decode_fixed(&bytes[1..]), lane_id)
+    assert_eq!(u64::decode_fixed(&bytes[1..]), Some(lane_id))
 }
 
 #[test]
@@ -40,9 +40,9 @@ fn serialize_map_key() {
     assert_eq!(bytes.len(), 26);
     assert_eq!(bytes[0], MAP_TAG);
 
-    assert_eq!(u64::decode_fixed(&bytes[1..9]), lane_id);
+    assert_eq!(u64::decode_fixed(&bytes[1..9]), Some(lane_id));
     assert_eq!(bytes[9], KEY);
-    assert_eq!(u64::decode_fixed(&bytes[10..18]), 8);
+    assert_eq!(u64::decode_fixed(&bytes[10..18]), Some(8));
 
     assert_eq!(&bytes[18..], key_bytes);
 }
@@ -56,7 +56,7 @@ fn serialize_map_lbound() {
     assert_eq!(bytes.len(), 9);
     assert_eq!(bytes[0], MAP_TAG);
 
-    assert_eq!(u64::decode_fixed(&bytes[1..9]), lane_id);
+    assert_eq!(u64::decode_fixed(&bytes[1..9]), Some(lane_id));
 }
 
 #[test]
@@ -67,6 +67,6 @@ fn serialize_map_ubound() {
     assert_eq!(bytes.len(), 10);
     assert_eq!(bytes[0], MAP_TAG);
 
-    assert_eq!(u64::decode_fixed(&bytes[1..9]), lane_id);
+    assert_eq!(u64::decode_fixed(&bytes[1..9]), Some(lane_id));
     assert_eq!(bytes[9], UBOUND);
 }