Add compression to wasm sent over the wire!

client/src/main.rs

@@ -135,8 +135,9 @@ impl Client {
                 }
                 PluginData::Download(data) => {
                     log::info!("Downloaded {}, saving...", name);
-                    plugin_cache.add_file(&name, &data)?;
-                    bytecode = data;
+                    let decompressed = cimvr_engine::decompress(&data).context("Decompressing wasm")?;
+                    plugin_cache.add_file(&name, &decompressed)?;
+                    bytecode = decompressed;
                 }
             }
 
@@ -188,6 +189,7 @@ impl Client {
                     // Load hotloaded plugins
                     for (name, bytecode) in recv.hotload {
                         log::info!("Reloading {}", name);
+                        let bytecode = cimvr_engine::decompress(&bytecode).context("Decompressing wasm")?;
                         self.engine.reload(name, &bytecode)?;
                     }
 

engine/Cargo.toml

@@ -15,3 +15,4 @@ ahash = "0.8.2"
 log = "0.4.17"
 notify = "5.0.0"
 xxhash-rust = { version = "0.8.5", features = ["xxh3"] }
+miniz_oxide = "0.7.1"

engine/src/lib.rs

@@ -358,3 +358,13 @@ impl Engine {
 pub fn calculate_digest(data: &[u8]) -> Digest {
     Digest(xxhash_rust::xxh3::xxh3_128(data))
 }
+
+/// Compress some data
+pub fn compress(data: &[u8]) -> Vec<u8> {
+    miniz_oxide::deflate::compress_to_vec(data, 6)
+}
+
+/// Decompress some data
+pub fn decompress(data: &[u8]) -> Result<Vec<u8>> {
+    miniz_oxide::inflate::decompress_to_vec(data).map_err(|e| format_err!("{:#}", e))
+}

server/src/main.rs

@@ -171,6 +171,7 @@ impl Server {
 
             // Remember which plugins were hotloaded, so that we can send code to
             // the clients!
+            let bytecode = cimvr_engine::compress(&bytecode);
             hotloaded.push((name, bytecode));
         }
 
@@ -190,7 +191,9 @@ impl Server {
                 if req.plugin_manifest.contains(&digest) {
                     response_plugins.push((name.clone(), PluginData::Cached(*digest)));
                 } else {
-                    response_plugins.push((name.clone(), PluginData::Download(code.clone())));
+                    // TODO: Do this only once!
+                    let bytecode = cimvr_engine::compress(&code);
+                    response_plugins.push((name.clone(), PluginData::Download(bytecode)));
                 }
             }