From e22c6a81f1c8610d1c81808f95fe6765b2c544a2 Mon Sep 17 00:00:00 2001 From: Untone Date: Wed, 18 Oct 2023 11:19:36 +0300 Subject: [PATCH] dont-stream-own-msg --- src/main.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main.rs b/src/main.rs index ce033e7..d5d2e57 100644 --- a/src/main.rs +++ b/src/main.rs @@ -79,8 +79,11 @@ async fn connect_handler( while let Some(msg) = pubsub.on_message().next().await { let message_str: String = msg.get_payload().unwrap(); let message_data: RedisMessageData = serde_json::from_str(&message_str).unwrap(); + let message_author = message_data.payload.get("author") + .and_then(Value::as_i64) // Convert Value to i64 + .unwrap_or(-1) as i32; // Convert i64 to i32 - if msg.get_channel_name().starts_with("chat:") + if (msg.get_channel_name().starts_with("chat:") && message_author != listener_id) || msg.get_channel_name().starts_with("followers:") || data::is_fitting( listener_id,