diff options
Diffstat (limited to 'DSACore/Hubs')
-rw-r--r-- | DSACore/Hubs/ChatHub.cs | 40 |
1 files changed, 39 insertions, 1 deletions
diff --git a/DSACore/Hubs/ChatHub.cs b/DSACore/Hubs/ChatHub.cs index 6af8c38..a8bf883 100644 --- a/DSACore/Hubs/ChatHub.cs +++ b/DSACore/Hubs/ChatHub.cs @@ -2,15 +2,53 @@ using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; +using DSACore.Models; using Microsoft.AspNetCore.SignalR; namespace DSACore.Hubs { public class ChatHub : Hub { + private static Dictionary<string, User> UserGroup; + public async Task SendMessage(string user, string message) { - await Clients.All.SendAsync("ReciveMessage", user, message); + var args = message.Split(' ', StringSplitOptions.RemoveEmptyEntries).ToList(); + var ident = args.First().Replace("!", ""); + if(args.Count>0){args.RemoveAt(0);} + + await SendToGroup(UserGroup[Context.ConnectionId].Group, user, Commands.CommandHandler.ExecuteCommand(new Command{CharId = 0,CmdIdentifier = ident, CmdTexts = args, Name = user})); + } + + private Task SendToGroup(string group, string user, string message) + { + return Clients.Group(group).SendCoreAsync("ReceiveMessage", new object[] { user, message }); + } + + public async Task GetGroups() + { + await Clients.Caller.SendCoreAsync("ListGroups", new object[] { "TheCrew", "Testdata" }); + throw new NotImplementedException("add database call to get groups"); + } + + public async Task Login(string group, string password) + { + if (password == "valid") + { + UserGroup.Add(Context.ConnectionId, new User{Group = group}); + await Groups.AddToGroupAsync(Context.ConnectionId, group); + } + + await SendToGroup(group, "", "Ein neuer Nutzer hat die Gruppe betreten"); + } + + public async Task Disconnect() + { + var user = UserGroup[Context.ConnectionId]; + await Groups.RemoveFromGroupAsync(Context.ConnectionId, user.Group); + + await SendToGroup(user.Group, user.Name, "Connection lost"); } + } } |