Start chat

Author: billsonnn

Turbo.PacketHandlers/Room/Chat/ChatMessageHandler.cs

@@ -1,18 +1,36 @@
 using System.Threading;
 using System.Threading.Tasks;
+using Orleans;
 using Turbo.Messages.Registry;
 using Turbo.Primitives.Messages.Incoming.Room.Chat;
+using Turbo.Primitives.Orleans;
 
 namespace Turbo.PacketHandlers.Room.Chat;
 
-public class ChatMessageHandler : IMessageHandler<ChatMessage>
+public class ChatMessageHandler(IGrainFactory grainFactory) : IMessageHandler<ChatMessage>
 {
+    private readonly IGrainFactory _grainFactory = grainFactory;
+
     public async ValueTask HandleAsync(
         ChatMessage message,
         MessageContext ctx,
         CancellationToken ct
     )
     {
-        await ValueTask.CompletedTask.ConfigureAwait(false);
+        if (ctx is null || ctx.PlayerId <= 0 || ctx.RoomId <= 0)
+            return;
+
+        var roomChatGrain = _grainFactory.GetRoomGrain(ctx.RoomId);
+
+        await roomChatGrain
+            .SendChatFromPlayerAsync(
+                ctx.PlayerId,
+                message.Text,
+                0,
+                message.StyleId,
+                [],
+                message.TrackingId
+            )
+            .ConfigureAwait(false);
     }
 }

Turbo.Primitives/Messages/Outgoing/Room/Chat/ChatMessageComposer.cs

@@ -2,14 +2,15 @@
 using Orleans;
 using Turbo.Primitives.Networking;
 using Turbo.Primitives.Rooms.Enums;
+using Turbo.Primitives.Rooms.Object;
 
 namespace Turbo.Primitives.Messages.Outgoing.Room.Chat;
 
 [GenerateSerializer, Immutable]
 public record ChatMessageComposer : IComposer
 {
     [Id(0)]
-    public required int UserId { get; init; }
+    public required RoomObjectId ObjectId { get; init; }
 
     [Id(1)]
     public required string Text { get; init; }

Turbo.Primitives/Rooms/Grains/IRoomGrain.Avatar.cs

@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Collections.Immutable;
 using System.Threading;
 using System.Threading.Tasks;
@@ -36,12 +37,19 @@ public Task<bool> SetAvatarDanceAsync(
         AvatarDanceType danceType,
         CancellationToken ct
     );
-
     public Task<bool> SetAvatarExpressionAsync(
         ActionContext ctx,
         AvatarExpressionType expressionType,
         CancellationToken ct
     );
+    public Task SendChatFromPlayerAsync(
+        PlayerId playerId,
+        string text,
+        AvatarGestureType gesture,
+        int styleId,
+        List<(string, string, bool)> links,
+        int trackingId
+    );
 
     public Task<ImmutableArray<RoomAvatarSnapshot>> GetAllAvatarSnapshotsAsync(
         CancellationToken ct

Turbo.Revisions/Revision20260112/Serializers/Room/Chat/ChatMessageComposerSerializer.cs

@@ -9,7 +9,7 @@ internal class ChatMessageComposerSerializer(int header)
     protected override void Serialize(IServerPacket packet, ChatMessageComposer message)
     {
         packet
-            .WriteInteger(message.UserId)
+            .WriteInteger(message.ObjectId)
             .WriteString(message.Text)
             .WriteInteger((int)message.Gesture)
             .WriteInteger(message.StyleId)

Turbo.Rooms/Grains/RoomGrain.Avatar.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using System.Collections.Immutable;
 using System.Threading;
 using System.Threading.Tasks;
@@ -176,6 +177,15 @@ CancellationToken ct
         }
     }
 
+    public Task SendChatFromPlayerAsync(
+        PlayerId playerId,
+        string text,
+        AvatarGestureType gesture,
+        int styleId,
+        List<(string, string, bool)> links,
+        int trackingId
+    ) => ChatSystem.SendChatFromPlayerAsync(playerId, text, gesture, styleId, links, trackingId);
+
     public Task<ImmutableArray<RoomAvatarSnapshot>> GetAllAvatarSnapshotsAsync(
         CancellationToken ct
     ) => AvatarModule.GetAllAvatarSnapshotsAsync(ct);

Turbo.Rooms/Grains/RoomGrain.cs

@@ -55,6 +55,7 @@ public sealed partial class RoomGrain : Grain, IRoomGrain
     public readonly RoomAvatarTickSystem AvatarTickSystem;
     public readonly RoomRollerSystem RollerSystem;
     public readonly RoomWiredSystem WiredSystem;
+    public readonly RoomChatSystem ChatSystem;
 
     public RoomId RoomId => _state.RoomId;
 
@@ -93,6 +94,7 @@ IGrainFactory grainFactory
         AvatarTickSystem = new(this);
         RollerSystem = new(this);
         WiredSystem = new(this);
+        ChatSystem = new(this);
 
         EventModule.Register(RollerSystem);
         EventModule.Register(WiredSystem);

Turbo.Rooms/Grains/Systems/RoomChatSystem.cs

@@ -0,0 +1,53 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Turbo.Primitives.Messages.Outgoing.Room.Chat;
+using Turbo.Primitives.Players;
+using Turbo.Primitives.Rooms.Enums;
+using Turbo.Primitives.Rooms.Object;
+
+namespace Turbo.Rooms.Grains.Systems;
+
+public sealed class RoomChatSystem(RoomGrain roomGrain)
+{
+    private readonly RoomGrain _roomGrain = roomGrain;
+
+    public async Task SendChatAsync(
+        RoomObjectId objectId,
+        string text,
+        AvatarGestureType gesture,
+        int styleId,
+        List<(string, string, bool)> links,
+        int trackingId
+    )
+    {
+        await _roomGrain.SendComposerToRoomAsync(
+            new ChatMessageComposer
+            {
+                ObjectId = objectId,
+                Text = text,
+                Gesture = gesture,
+                StyleId = styleId,
+                Links = links,
+                TrackingId = trackingId,
+            }
+        );
+    }
+
+    public async Task SendChatFromPlayerAsync(
+        PlayerId playerId,
+        string text,
+        AvatarGestureType gesture,
+        int styleId,
+        List<(string, string, bool)> links,
+        int trackingId
+    )
+    {
+        if (
+            !_roomGrain._state.AvatarsByPlayerId.TryGetValue(playerId, out var objectId)
+            || !_roomGrain._state.AvatarsByObjectId.TryGetValue(objectId, out var avatar)
+        )
+            return;
+
+        await SendChatAsync(avatar.ObjectId, text, gesture, styleId, links, trackingId);
+    }
+}