jmug/stoatchat
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

(bonfire): parse correct PayloadType

Browse Source
This commit is contained in:
Bob Bobs
2024-02-01 20:07:12 -07:00
parent 88c2232a6c
commit 3d3326e68a
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/bonfire/src/websocket.rs
View File

@@ -187,7 +187,7 @@ async fn listener(
}) else { }) else {
return; return;
}; };
match *REDIS_PAYLOAD_TYPE { let event = match *REDIS_PAYLOAD_TYPE {
PayloadType::Json => message PayloadType::Json => message
.value .value
.as_str() .as_str()
@@ -201,12 +201,7 @@ async fn listener(
.as_bytes() .as_bytes()
.and_then(|b| bincode::deserialize::<EventV1>(b).ok()), .and_then(|b| bincode::deserialize::<EventV1>(b).ok()),
}; };
let Some(mut event) = event else {
let Some(mut event) = message
.value
.as_str()
.and_then(|s| serde_json::from_str::<EventV1>(s.as_ref()).ok())
else {
warn!("Failed to deserialise an event for {}!", message.channel); warn!("Failed to deserialise an event for {}!", message.channel);
return; return;
}; };