diff --git a/src/worker/events.rs b/src/worker/events.rs index 97902a1..af5319a 100644 --- a/src/worker/events.rs +++ b/src/worker/events.rs @@ -543,8 +543,14 @@ impl EventsWorker { } } - // Schreibe Benachrichtigung in die Datenbank - Self::notify_user(pool, broker, user_id, &format!("random_event.{}", event.id))?; + // Schreibe Benachrichtigung in die Datenbank mit Event-Details + let notification_json = serde_json::json!({ + "tr": format!("random_event.{}", event.id), + "event_id": event.id, + "event_type": "personal", + "effects": effect_results + }); + Self::notify_user(pool, broker, user_id, ¬ification_json.to_string())?; // Sende Benachrichtigung über WebSocket let notification = json!({ @@ -644,7 +650,17 @@ impl EventsWorker { } } - // Sende Benachrichtigung + // Schreibe Benachrichtigung in die Datenbank mit Event-Details + let notification_json = serde_json::json!({ + "tr": format!("random_event.{}", event.id), + "event_id": event.id, + "event_type": "personal", + "character_id": character_id, + "effects": effect_results + }); + Self::notify_user(pool, broker, user_id, ¬ification_json.to_string())?; + + // Sende Benachrichtigung über WebSocket let notification = json!({ "event": "random_event", "event_id": event.id, @@ -895,8 +911,15 @@ impl EventsWorker { .and_then(|v| v.parse::().ok()); if let Some(uid) = user_id { - // Schreibe Benachrichtigung in die Datenbank - if let Err(err) = Self::notify_user(pool, broker, uid, &format!("random_event.{}", event.id)) { + // Schreibe Benachrichtigung in die Datenbank mit Event-Details + let notification_json = serde_json::json!({ + "tr": format!("random_event.{}", event.id), + "event_id": event.id, + "event_type": "regional", + "region_id": region_id, + "effects": effect_results + }); + if let Err(err) = Self::notify_user(pool, broker, uid, ¬ification_json.to_string()) { eprintln!("[EventsWorker] Fehler beim Schreiben der Benachrichtigung für User {}: {}", uid, err); }