From 03993331631f3eef6971734f046ab9d7a4e6379e Mon Sep 17 00:00:00 2001
From: "Torsten Schulz (local)" <tsschulz@gmx.net>
Date: Fri, 23 Jan 2026 10:46:32 +0100
Subject: [PATCH] Enhance relationship deletion logging across workers:
 Implement detailed logging for the number of deleted relationships in
 CharacterCreationWorker, EventsWorker, and UserCharacterWorker, improving
 traceability and user awareness during character interactions.

---
 src/worker/character_creation.rs | 14 ++++++++++++--
 src/worker/events.rs             | 14 ++++++++++++--
 src/worker/sql.rs                |  2 +-
 src/worker/user_character.rs     | 14 ++++++++++++--
 4 files changed, 37 insertions(+), 7 deletions(-)

diff --git a/src/worker/character_creation.rs b/src/worker/character_creation.rs
index ee7d96b..3214e37 100644
--- a/src/worker/character_creation.rs
+++ b/src/worker/character_creation.rs
@@ -418,6 +418,16 @@ impl CharacterCreationWorker {
         // 2) Relationships löschen und betroffene User benachrichtigen
         conn.prepare("delete_relationship", QUERY_DELETE_RELATIONSHIP)?;
         let rel_result = conn.execute("delete_relationship", &[&character_id])?;
+        
+        // Logging: Anzahl gelöschter Relationships
+        let deleted_count = rel_result.len();
+        if deleted_count > 0 {
+            eprintln!(
+                "[CharacterCreationWorker] {} Relationship(s) gelöscht für character_id={}",
+                deleted_count, character_id
+            );
+        }
+        
         for row in rel_result {
             let related_user_id = row
                 .get("related_user_id")
@@ -432,9 +442,9 @@ impl CharacterCreationWorker {
 
             // Logging: Relationship wurde gelöscht
             eprintln!(
-                "[CharacterCreationWorker] Relationship gelöscht: character_id={}, related_character_id={}, related_user_id={:?}, relationship_type={:?}",
+                "[CharacterCreationWorker] Relationship gelöscht: character_id={}, related_character_id={:?}, related_user_id={:?}, relationship_type={:?}",
                 character_id, 
-                related_character_id.unwrap_or(-1),
+                related_character_id,
                 related_user_id,
                 relationship_type_tr
             );
diff --git a/src/worker/events.rs b/src/worker/events.rs
index f1f4d95..6af6402 100644
--- a/src/worker/events.rs
+++ b/src/worker/events.rs
@@ -1778,6 +1778,16 @@ impl EventsWorker {
         // 2) Relationships löschen und betroffene User benachrichtigen
     conn.prepare("delete_relationship", QUERY_DELETE_RELATIONSHIP)?;
         let rel_result = conn.execute("delete_relationship", &[&character_id])?;
+        
+        // Logging: Anzahl gelöschter Relationships
+        let deleted_count = rel_result.len();
+        if deleted_count > 0 {
+            eprintln!(
+                "[EventsWorker] {} Relationship(s) gelöscht für character_id={}",
+                deleted_count, character_id
+            );
+        }
+        
         for row in rel_result {
             let related_user_id = row
                 .get("related_user_id")
@@ -1792,9 +1802,9 @@ impl EventsWorker {
 
             // Logging: Relationship wurde gelöscht
             eprintln!(
-                "[EventsWorker] Relationship gelöscht: character_id={}, related_character_id={}, related_user_id={:?}, relationship_type={:?}",
+                "[EventsWorker] Relationship gelöscht: character_id={}, related_character_id={:?}, related_user_id={:?}, relationship_type={:?}",
                 character_id, 
-                related_character_id.unwrap_or(-1),
+                related_character_id,
                 related_user_id,
                 relationship_type_tr
             );
diff --git a/src/worker/sql.rs b/src/worker/sql.rs
index 488bd52..d84dad8 100644
--- a/src/worker/sql.rs
+++ b/src/worker/sql.rs
@@ -736,7 +736,7 @@ SELECT
     d.relationship_type_id,
     rt.tr AS relationship_type_tr
 FROM deleted d 
-JOIN falukant_data.character c ON c.id = d.related_character_id
+LEFT JOIN falukant_data.character c ON c.id = d.related_character_id
 LEFT JOIN falukant_type.relationship rt ON rt.id = d.relationship_type_id;
 "#;
 
diff --git a/src/worker/user_character.rs b/src/worker/user_character.rs
index 0fd8118..728862a 100644
--- a/src/worker/user_character.rs
+++ b/src/worker/user_character.rs
@@ -582,6 +582,16 @@ impl UserCharacterWorker {
         
         // Relationships löschen mit Logging und spezieller Notification für Verlobungen
         let rel_result = conn.execute("delete_relationship", &[&character_id])?;
+        
+        // Logging: Anzahl gelöschter Relationships
+        let deleted_count = rel_result.len();
+        if deleted_count > 0 {
+            eprintln!(
+                "[UserCharacterWorker] {} Relationship(s) gelöscht für character_id={}",
+                deleted_count, character_id
+            );
+        }
+        
         for row in rel_result {
             let related_user_id = row
                 .get("related_user_id")
@@ -596,9 +606,9 @@ impl UserCharacterWorker {
 
             // Logging: Relationship wurde gelöscht
             eprintln!(
-                "[UserCharacterWorker] Relationship gelöscht: character_id={}, related_character_id={}, related_user_id={:?}, relationship_type={:?}",
+                "[UserCharacterWorker] Relationship gelöscht: character_id={}, related_character_id={:?}, related_user_id={:?}, relationship_type={:?}",
                 character_id, 
-                related_character_id.unwrap_or(-1),
+                related_character_id,
                 related_user_id,
                 relationship_type_tr
             );