compliance

Author: Dippys

Turbo.PacketHandlers/Users/RespectUserMessageHandler.cs

@@ -3,7 +3,6 @@
 using Orleans;
 using Turbo.Messages.Registry;
 using Turbo.Primitives.Messages.Incoming.Users;
-using Turbo.Primitives.Messages.Outgoing.Users;
 using Turbo.Primitives.Orleans;
 using Turbo.Primitives.Rooms.Enums;
 
@@ -34,27 +33,14 @@ CancellationToken ct
         if (!consumed)
             return;
 
-        // Give respect to the target player
+        // Give respect to the target player (grain sends room notification)
         var targetGrain = _grainFactory.GetPlayerGrain(message.UserId);
-        var newTotal = await targetGrain
-            .ReceiveRespectAsync(ctx.PlayerId, ct)
-            .ConfigureAwait(false);
+        await targetGrain.ReceiveRespectAsync(ctx.PlayerId, ct).ConfigureAwait(false);
 
         // Play the thumbs-up expression on the giver
         var roomGrain = _grainFactory.GetRoomGrain(ctx.RoomId);
         await roomGrain
             .SetAvatarExpressionAsync(ctx.AsActionContext(), AvatarExpressionType.Respect, ct)
             .ConfigureAwait(false);
-
-        // Broadcast the respect notification to the entire room
-        await roomGrain
-            .SendComposerToRoomAsync(
-                new RespectNotificationMessageComposer
-                {
-                    UserId = message.UserId,
-                    RespectTotal = newTotal,
-                }
-            )
-            .ConfigureAwait(false);
     }
 }

Turbo.Players/Grains/PlayerGrain.cs

@@ -9,6 +9,7 @@
 using Turbo.Logging;
 using Turbo.Primitives;
 using Turbo.Primitives.Grains.Players;
+using Turbo.Primitives.Messages.Outgoing.Users;
 using Turbo.Primitives.Orleans;
 using Turbo.Primitives.Orleans.Snapshots.Players;
 using Turbo.Primitives.Players;
@@ -185,6 +186,15 @@ public async Task<int> ReceiveRespectAsync(PlayerId giverId, CancellationToken c
         _state.RespectTotal++;
         await WriteToDatabaseAsync(ct);
 
+        var presence = _grainFactory.GetPlayerPresenceGrain((int)this.GetPrimaryKeyLong());
+        await presence.SendComposerToActiveRoomAsync(
+            new RespectNotificationMessageComposer
+            {
+                UserId = (int)_state.PlayerId,
+                RespectTotal = _state.RespectTotal,
+            }
+        );
+
         return _state.RespectTotal;
     }
 

Turbo.Players/Grains/PlayerPresenceGrain.Room.cs

@@ -115,4 +115,13 @@ public Task SetPendingRoomAsync(RoomId roomId, bool approved)
 
         return Task.CompletedTask;
     }
+
+    public async Task SendComposerToActiveRoomAsync(IComposer composer)
+    {
+        if (_state.ActiveRoomId <= 0)
+            return;
+
+        var roomGrain = _grainFactory.GetRoomGrain(_state.ActiveRoomId);
+        await roomGrain.SendComposerToRoomAsync(composer);
+    }
 }

Turbo.Primitives/Players/Grains/IPlayerPresenceGrain.Room.cs

@@ -1,5 +1,6 @@
 using System.Threading;
 using System.Threading.Tasks;
+using Turbo.Primitives.Networking;
 using Turbo.Primitives.Orleans.Snapshots.Room;
 using Turbo.Primitives.Rooms;
 
@@ -12,4 +13,5 @@ public partial interface IPlayerPresenceGrain
     public Task SetActiveRoomAsync(RoomId roomId, CancellationToken ct);
     public Task ClearActiveRoomAsync(CancellationToken ct);
     public Task SetPendingRoomAsync(RoomId roomId, bool approved);
+    public Task SendComposerToActiveRoomAsync(IComposer composer);
 }