forked from jmug/stoatchat
chore(bonfire): fire error event with more information
This commit is contained in:
@@ -301,25 +301,23 @@ async fn listener(
|
|||||||
PayloadType::Json => message
|
PayloadType::Json => message
|
||||||
.value
|
.value
|
||||||
.as_str()
|
.as_str()
|
||||||
.and_then(|s| serde_json::from_str::<EventV1>(s.as_ref()).ok()),
|
.and_then(|s| report_internal_error!(serde_json::from_str::<EventV1>(s.as_ref())).ok()),
|
||||||
PayloadType::Msgpack => message
|
PayloadType::Msgpack => message
|
||||||
.value
|
.value
|
||||||
.as_bytes()
|
.as_bytes()
|
||||||
.and_then(|b| rmp_serde::from_slice::<EventV1>(b).ok()),
|
.and_then(|b| report_internal_error!(rmp_serde::from_slice::<EventV1>(b)).ok()),
|
||||||
PayloadType::Bincode => message
|
PayloadType::Bincode => message
|
||||||
.value
|
.value
|
||||||
.as_bytes()
|
.as_bytes()
|
||||||
.and_then(|b| bincode::deserialize::<EventV1>(b).ok()),
|
.and_then(|b| report_internal_error!(bincode::deserialize::<EventV1>(b)).ok()),
|
||||||
};
|
};
|
||||||
|
|
||||||
let Some(mut event) = event else {
|
let Some(mut event) = event else {
|
||||||
let err = format!(
|
let err = format!(
|
||||||
"Failed to deserialise an event for {}! Introspection: `{:?}`",
|
"Failed to deserialise event for {}: `{:?}`",
|
||||||
message.channel,
|
message.channel,
|
||||||
message
|
message
|
||||||
.value
|
.value
|
||||||
.as_string()
|
|
||||||
.map(|x| x.chars().take(32).collect::<String>())
|
|
||||||
);
|
);
|
||||||
|
|
||||||
error!("{}", err);
|
error!("{}", err);
|
||||||
|
|||||||
Reference in New Issue
Block a user