Testing VolatileStorage

crates/storage/Cargo.toml

@@ -14,7 +14,7 @@ sqlx = { workspace = true, optional = true }
 tempfile = { workspace = true }
 
 [dev-dependencies]
-tokio = { workspace = true, features = ["rt-multi-thread"] }
+tokio = { workspace = true, features = ["macros", "rt-multi-thread"] }
 
 [features]
 sqlite = ["dep:sqlx"]

crates/storage/src/inmemory.rs

@@ -23,3 +23,29 @@ impl VolatileStorage {
             .push(msg);
     }
 }
+
+#[cfg(test)]
+mod test_volatile {
+    use super::VolatileStorage;
+    use directip;
+
+    fn sample() -> directip::Message {
+        let msg = directip::mt::MTMessage::from_reader(
+            [
+                0x01, 0x00, 0x1c, 0x44, 0x00, 0x19, 0x00, 0x00, 0x27, 0x0f, 0x00, 0x01, 0x02, 0x03,
+                0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0a, 0x0b, 0x0c, 0x0d, 0x0e, 0xff, 0xff, 0xff,
+                0xff, 0xff, 0xf5,
+            ]
+            .as_slice(),
+        );
+        directip::Message::MT(msg.unwrap())
+    }
+
+    #[tokio::test]
+    async fn volatile() {
+        let storage = VolatileStorage::connect().unwrap();
+        storage.save(sample()).await;
+
+        assert_eq!(storage.data.read().unwrap().len(), 1);
+    }
+}