chakanysystems/hoot
1
0
Fork 0
Code Issues 3 Pull requests Projects 1 Releases Packages Wiki Activity Actions

make RelayMessage decoder work

Browse source
This commit is contained in:
Jack Chakany 2025-01-12 12:43:05 -05:00
parent efd80f64de
commit 3ae435202e
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/relay/message.rs
View file

@ -104,9 +104,20 @@ impl<'a> RelayMessage<'a> {
if let Some(comma_index) = msg[start..].find(',') {
let subid_end = start + comma_index;
let subid = &msg[start..subid_end].trim().trim_matches('"');
return Ok(Self::event(msg, subid));
// Find start of event JSON after subscription ID
let event_start = subid_end + 1;
let mut event_start = event_start;
while let Some(&b' ') = msg.as_bytes().get(event_start) {
event_start += 1;
}
// Event JSON goes until end, minus closing bracket
let event_json = &msg[event_start..msg.len()-1];
return Ok(Self::event(event_json, subid));
} else {
return Ok(Self::event(msg, "fixme"));
return Ok(Self::event("{}", "fixme")); // Empty event JSON if parsing fails
}
}