Feature chat

Runtime/Models/Request.cs

@@ -9,8 +9,7 @@ public class Request : EventArgs
         private string GameId { get; set; }
         [JsonProperty("2", NullValueHandling = NullValueHandling.Ignore)] private string Protocol { get; set; }
         [JsonProperty("3")] public int? ReceiverId { get; set; }
-        [JsonProperty("4")]
-        public string Method { get; set; }
+        [JsonProperty("4")] public string Method { get; set; }
         [JsonProperty("5", NullValueHandling = NullValueHandling.Ignore)] public string Payload { get; set; }
         [JsonProperty("6")] public int? SenderId { get; set; }
 

Runtime/Services/Chat/ChatService.cs

@@ -0,0 +1,184 @@
+//using adapters.repositories.table.services;
+//using models.dto;
+//using models.inputs;
+
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using DynamicPixels.GameService.Models;
+using DynamicPixels.GameService.Services.Chat;
+using DynamicPixels.GameService.Services.Chat.Models;
+using DynamicPixels.GameService.Services.Chat.Repositories;
+using DynamicPixels.GameService.Utils.WebsocketClient;
+using Newtonsoft.Json;
+using MessageType = DynamicPixels.Services.Chat.MessageType;
+
+namespace DynamicPixels.GameService.Services.services
+{
+    public class ChatService: IChatService
+    {
+
+        private readonly ISocketAgent _socketAgent;
+        private readonly IChatRepository _repository;
+
+        public event EventHandler<Message> OnPrivateMessage;
+        public event EventHandler<Message> OnPublicMessage;
+        public event EventHandler<Conversation> OnSubscribe;
+        public event EventHandler<int> OnUnsubscribe;
+        public event EventHandler<Message> OnEditMessage;
+        public event EventHandler<Message> OnDeleteMessage;
+        public event EventHandler OnDeleteAllMessage;
+
+        public ChatService(ISocketAgent socketAgent)
+        {
+            _socketAgent = socketAgent;
+            _repository = new ChatRepository();
+            _socketAgent.OnMessageReceived += OnMessage;
+        }
+
+        private void OnMessage(object source, Request packet)
+        {
+            switch (packet.Method)
+            {
+                case MessageType.ChatSendPrivate:
+                    var privateMsg = JsonConvert.DeserializeObject<Message>(packet.Payload);
+                    OnPrivateMessage?.Invoke(this, privateMsg);
+                    break;
+                case MessageType.ChatSendGroup:
+                    var groupMsg = JsonConvert.DeserializeObject<Message>(packet.Payload);
+                    OnPublicMessage?.Invoke(this, groupMsg);
+                    break;
+                case MessageType.ChatSubscribe:
+                    var conversation = JsonConvert.DeserializeObject<Conversation>(packet.Payload);
+                    OnSubscribe?.Invoke(this, conversation);
+                    break;
+                case MessageType.ChatUnsubscribe:
+                    OnUnsubscribe?.Invoke(this, Int32.Parse(packet.Payload));
+                    break;
+                case MessageType.ChatMessageEdit:
+                    var editedMsg = JsonConvert.DeserializeObject<Message>(packet.Payload);
+                    OnEditMessage?.Invoke(this, editedMsg);
+                    break;
+                case MessageType.ChatMessageDelete:
+                    var deletedMsg = JsonConvert.DeserializeObject<Message>(packet.Payload);
+                    OnDeleteMessage?.Invoke(this, deletedMsg);
+                    break;
+                case MessageType.ChatMessageDeleteAll:
+                    OnDeleteAllMessage?.Invoke(this, packet);
+                    break;
+            }
+        }
+
+
+        // interactions
+        public Task Send<T>(T param) where T : SendParams
+        {
+            _socketAgent.Send(new Request
+            {
+                Method = param.Type == ConversationType.Private ? MessageType.ChatSendPrivate: MessageType.ChatSendGroup,
+                ReceiverId = param.TargetUserId,
+                Payload = new Payload
+                {
+                    TargetId = param.TargetUserId,
+                    Message = param.Message
+                }.ToString(),
+            });
+
+            return Task.CompletedTask;
+        }
+
+        public Task Subscribe<T>(T param) where T : SubscribeParams
+        {
+            _socketAgent.Send(new Request
+            {
+                Method = MessageType.ChatSubscribe,
+                Payload = new Payload
+                {
+                    TargetId = param.ConversationId,
+                    Value = param.ConversationName,
+                }.ToString(),
+            });
+
+            return Task.CompletedTask;
+        }
+
+        public Task Unsubscribe<T>(T param) where T : UnsubscribeParams
+        {
+            _socketAgent.Send(new Request
+            {
+                Method = MessageType.ChatUnsubscribe,
+                Payload = new Payload
+                {
+                    TargetId = param.ConversationId,
+                }.ToString(),
+            });
+
+            return Task.CompletedTask;
+        }
+
+        public Task EditMessage<T>(T param) where T : EditMessageParams
+        {
+            _socketAgent.Send(new Request
+            {
+                Method = MessageType.ChatMessageEdit,
+                Payload = new Payload
+                {
+                    TargetId = param.ConversationId,
+                    MessageId = param.MessageId,
+                    Message = param.Message,
+                }.ToString(),
+            });
+
+            return Task.CompletedTask;
+        }
+
+        public Task DeleteMessage<T>(T param) where T : DeleteMessageParams
+        {
+            _socketAgent.Send(new Request
+            {
+                Method = MessageType.ChatMessageDelete,
+                Payload = new Payload {
+                    TargetId = param.ConversationId,
+                    MessageId = param.MessageId,
+                }.ToString(),
+            });
+
+            return Task.CompletedTask;
+        }
+
+        public Task DeleteAllMessage<T>(T param) where T : DeleteAllMessageParams
+        {
+            _socketAgent.Send(new Request
+            {
+                Method = MessageType.ChatMessageDeleteAll,
+                Payload = new Payload
+                {
+                    TargetId = param.ConversationId,
+                    SubTargetId = param.TargetUserId,
+                }.ToString(),
+            });
+
+            return Task.CompletedTask;
+        }
+
+        // https
+        public async Task<List<Conversation>> GetSubscribedConversations<T>(T param) where T : GetSubscribedConversationsParams
+        {
+            var conversations = await this._repository.GetSubscribedConversations(param);
+            return conversations.List;
+        }
+
+        public async Task<List<Message>> GetConversationMessages<T>(T param) where T : GetConversationMessagesParams
+        {
+            var messages = await this._repository.GetConversationMessages(param);
+            return messages.List;
+        }
+
+        public async Task<List<ConversationMember>> GetConversationMembers<T>(T param) where T : GetConversationMembersParams
+        {
+            var members = await this._repository.GetConversationMembers(param);
+            return members.List;
+        }
+
+    }
+}

Runtime/Services/Chat/IChat.cs → Runtime/Services/Chat/IChatService.cs

@@ -5,7 +5,7 @@
 
 namespace DynamicPixels.GameService.Services.Chat
 {
-    public interface IChat
+    public interface IChatService
     {
         public Task Send<T>(T param) where T : SendParams;
         public Task Subscribe<T>(T param) where T : SubscribeParams;

Runtime/Services/Chat/MessageTypes.cs

@@ -0,0 +1,14 @@
+namespace DynamicPixels.Services.Chat
+{
+    public partial class MessageType
+    {
+        public const string ChatSendPrivate = "chat:send";
+        public const string ChatSendGroup = "chat:group:send";
+        public const string ChatSubscribe = "chat:subscribe";
+        public const string ChatUnsubscribe = "chat:unsubscribe";
+        public const string ChatMessageEdit = "chat:message:edit";
+        public const string ChatMessageDelete = "chat:message:delete";
+        // public const string ChatMessagePurge = "chat:message:purge";
+        public const string ChatMessageDeleteAll = "chat:group:delete";
+    }
+}

Runtime/Services/Chat/Models/Payload.cs

@@ -0,0 +1,30 @@
+using System.Collections.Generic;
+using DynamicPixels.GameService.Services.Chat.Repositories;
+using Newtonsoft.Json;
+
+namespace DynamicPixels.GameService.Services.Chat.Models
+{
+    public class Payload
+    {
+        [JsonProperty("target_id")] public int TargetId { get; set; }
+
+        [JsonProperty("sub_target_id")] public int SubTargetId { get; set; }
+
+        [JsonProperty("message_id")] public int MessageId { get; set; }
+
+        [JsonProperty("payload")] public Message? Message { get; set; }
+
+        [JsonProperty("value")] public string Value { get; set; } = "";
+
+        [JsonProperty("skip")] public int Skip { get; set; }
+
+        [JsonProperty("limit")] public int Limit { get; set; }
+
+        [JsonProperty("properties")] public Dictionary<string, string>? properties { get; set; }
+
+        public override string ToString()
+        {
+            return JsonConvert.SerializeObject(this);
+        }
+    }
+}