fix(example): only attempt to decode messages sent in the toy chat content topic

This commit is contained in:
Richard Ramos 2023-05-16 17:23:03 -04:00
parent d7cbdc2658
commit b09f834fe4
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 4 additions and 0 deletions

View File

@ -134,6 +134,10 @@ fn main() -> std::result::Result<(), Box<dyn Error>> {
let shared_messages = Arc::clone(&app.messages);
waku_set_event_callback(move |signal| match signal.event() {
waku_bindings::Event::WakuMessage(event) => {
if event.waku_message().content_topic() != &TOY_CHAT_CONTENT_TOPIC {
return
}
match <Chat2Message as Message>::decode(event.waku_message().payload()) {
Ok(chat_message) => {
shared_messages.write().unwrap().push(chat_message);