IntenseWebs/LibreQoS
3
0
Fork 0
mirror of https://github.com/LibreQoE/LibreQoS.git synced 2025-02-25 18:55:32 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix warning

Browse Source
This commit is contained in:
Herbert Wolverson
2023-07-28 13:39:03 +00:00
parent 874a4bda5e
commit 0590d3055f
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/rust/long_term_stats/wasm_pipe/src/message.rs
View File

@@ -4,11 +4,11 @@ use wasm_pipe_types::{WasmRequest, WasmResponse};
#[derive(Error, Debug)]
pub enum MessageError {
#[error("Unable to decompress stream")]
DecompressError,
Decompress,
#[error("Unable to de-serialize CBOR into native type")]
DeserializeError,
Deserialize,
#[error("Unable to serialize CBOR from native type")]
SerializeError,
Serialize,
}
pub struct WsResponseMessage(pub WasmResponse);
@@ -19,9 +19,9 @@ impl WsResponseMessage {
let array = js_sys::Uint8Array::new(&buffer);
let raw = array.to_vec();
let decompressed = miniz_oxide::inflate::decompress_to_vec(&raw)
.map_err(|_| MessageError::DecompressError)?;
.map_err(|_| MessageError::Decompress)?;
let msg: WasmResponse =
serde_cbor::from_slice(&decompressed).map_err(|_| MessageError::DeserializeError)?;
serde_cbor::from_slice(&decompressed).map_err(|_| MessageError::Deserialize)?;
Ok(Self(msg))
}
}
@@ -34,7 +34,7 @@ impl WsRequestMessage {
}
pub fn serialize(&self) -> Result<Vec<u8>, MessageError> {
let cbor = serde_cbor::to_vec(&self.0).map_err(|_| MessageError::SerializeError)?;
let cbor = serde_cbor::to_vec(&self.0).map_err(|_| MessageError::Serialize)?;
Ok(miniz_oxide::deflate::compress_to_vec(&cbor, 8))
}
}