diff --git a/src/main.rs b/src/main.rs index aaf62f7..4b07294 100644 --- a/src/main.rs +++ b/src/main.rs @@ -77,8 +77,14 @@ async fn connect_handler( } 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(); + println!("Message payload: {}", message_str); // Add this line + 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:") || msg.get_channel_name().starts_with("followers:") || data::is_fitting(