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

redis-debug

Browse Source
This commit is contained in:
Untone 2023-10-17 17:51:36 +03:00
parent 56b9c5ac49
commit 625cefd447
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main.rs
View File

@ -77,8 +77,14 @@ async fn connect_handler(
} }
while let Some(msg) = pubsub.on_message().next().await { while let Some(msg) = pubsub.on_message().next().await {
println!("Received a message from Redis"); // Add this line
let message_str: String = msg.get_payload().unwrap(); let message_str: String = msg.get_payload().unwrap();
println!("Message payload: {}", message_str); // Add this line
let message_data: RedisMessageData = serde_json::from_str(&message_str).unwrap(); let message_data: RedisMessageData = serde_json::from_str(&message_str).unwrap();
println!("Deserialized message data: {:?}", message_data); // Add this line
if msg.get_channel_name().starts_with("chat:") if msg.get_channel_name().starts_with("chat:")
|| msg.get_channel_name().starts_with("followers:") || msg.get_channel_name().starts_with("followers:")
|| data::is_fitting( || data::is_fitting(