discours.io/quoter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

dont-stream-own-msg

Browse Source
This commit is contained in:
Untone 2023-10-18 11:19:36 +03:00
parent 6b20322edf
commit e22c6a81f1
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main.rs
View File

@ -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,