Fixed live messaging notifications

Author: DonPrus

src/notifications.rs

@@ -46,7 +46,9 @@ pub async fn register_notifications(
     settings: &ApplicationSettings,
     store: &AsyncProgramStore,
 ) {
+    tracing::info!("Registering notifications, enabled: {}", settings.tunables.notifications.enabled);
     if !settings.tunables.notifications.enabled {
+        tracing::info!("Notifications disabled, skipping registration");
         return;
     }
     let notify_via = settings.tunables.notifications.via;
@@ -58,6 +60,7 @@ pub async fn register_notifications(
     };
 
     let store = store.clone();
+    tracing::info!("About to register notification handler");
     client
         .register_notification_handler(move |notification, room: MatrixRoom, client: Client| {
             let store = store.clone();
@@ -77,7 +80,22 @@ pub async fn register_notifications(
                 match notification.event {
                     RawAnySyncOrStrippedTimelineEvent::Sync(e) => {
                         // Skip notifications for live messages
-                        if crate::message::live_detection::has_live_marker_in_raw(&e) {
+                        let json_str = e.json().get();
+                        let has_live_marker = crate::message::live_detection::has_live_marker_in_raw(&e);
+
+                        // Extra debug logging
+                        if json_str.contains("org.matrix.msc4357.live") {
+                            tracing::info!("Found live marker string in notification event: {}",
+                                if has_live_marker { "DETECTED" } else { "NOT DETECTED by function" });
+                            if !has_live_marker {
+                                // Log first 500 chars of the event to see structure
+                                let preview = if json_str.len() > 500 { &json_str[..500] } else { &json_str };
+                                tracing::warn!("Live marker in string but not detected by function. Event preview: {}", preview);
+                            }
+                        }
+
+                        if has_live_marker {
+                            tracing::info!("Skipping notification for live message in room {}", room_id);
                             return;
                         }