fix: encode bytebuf for SmartModuleWasm

infinyon · Oct 27, 2022 · 44ab15b · 44ab15b
1 parent 44b4643
commit 44ab15b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/crates/fluvio-controlplane-metadata/src/smartmodule/spec.rs b/crates/fluvio-controlplane-metadata/src/smartmodule/spec.rs
@@ -124,8 +124,12 @@ impl std::fmt::Debug for SmartModuleWasm {
 impl SmartModuleWasm {
     /// Create SmartModule from compressed Gzip format
     pub fn from_compressed_gzip(payload: Vec<u8>) -> Self {
+        let bytes = ByteBuf::default();
+
+        bytes.encode(&mut payload.clone(), 0).unwrap();
+
         SmartModuleWasm {
-            payload: ByteBuf::from(payload),
+            payload: bytes,
             format: SmartModuleWasmFormat::Binary,
         }
     }