summaryrefslogtreecommitdiff
path: root/DSACore/Hubs
diff options
context:
space:
mode:
Diffstat (limited to 'DSACore/Hubs')
-rw-r--r--DSACore/Hubs/Login.cs88
1 files changed, 30 insertions, 58 deletions
diff --git a/DSACore/Hubs/Login.cs b/DSACore/Hubs/Login.cs
index f08c24a..80ee29c 100644
--- a/DSACore/Hubs/Login.cs
+++ b/DSACore/Hubs/Login.cs
@@ -10,18 +10,15 @@ using DSALib.DSA_Game.Characters;
using DSALib.FireBase;
using DSALib.Models.Network;
using Microsoft.AspNetCore.SignalR;
-using Group = DSACore.Models.Network.Group;
-namespace DSACore.Hubs
-{
- public class Users : Hub
- {
+namespace DSACore.Hubs {
+ public class Users : Hub {
//private static Dictionary<string, User> UserGroup = new Dictionary<string, User>();
private const string ReceiveMethod = "ReceiveMessage"; //receiveMethod;
static Users() {
- DsaGroups = Database.GetGroups().Result.Select(x=>new Group(x.Item1, x.Item2)).ToList();
+ DsaGroups = Database.GetGroups().Result.Select(x => new Group(x.Item1, x.Item2)).ToList();
DsaGroups.Add(new Group("login", ""));
DsaGroups.Add(new Group("online", ""));
//AddGroups();
@@ -31,20 +28,16 @@ namespace DSACore.Hubs
public static List<Token> Tokens { get; } = new List<Token>();
- public async Task SendMessage(string user, string message)
- {
- try
- {
+ public async Task SendMessage(string user, string message) {
+ try {
var group = getGroup(Context.ConnectionId).Name;
}
- catch (InvalidOperationException)
- {
- await Clients.Caller.SendCoreAsync(ReceiveMethod,
- new object[] { "Nutzer ist in keiner Gruppe. Erst joinen!" });
+ catch (InvalidOperationException) {
+ await Clients.Caller.SendCoreAsync(ReceiveMethod,
+ new object[] {"Nutzer ist in keiner Gruppe. Erst joinen!"});
}
- if (message[0] == '/')
- {
+ if (message[0] == '/') {
var args = message.Split(' ', StringSplitOptions.RemoveEmptyEntries).ToList();
var Timon = args.Any(x => x == "hallo");
@@ -52,16 +45,14 @@ namespace DSACore.Hubs
var ident = args.First().Replace("/", "");
if (args.Count > 0) args.RemoveAt(0);
- var ret = CommandHandler.ExecuteCommand(new Command
- {
+ var ret = CommandHandler.ExecuteCommand(new Command {
CharId = 0,
CmdIdentifier = ident,
CmdTexts = args,
Name = user
});
- switch (ret.ResponseType)
- {
+ switch (ret.ResponseType) {
case ResponseType.Caller:
case ResponseType.Error:
await Clients.Caller.SendAsync(ReceiveMethod, ret.message);
@@ -71,34 +62,28 @@ namespace DSACore.Hubs
break;
}
}
- else
- {
+ else {
await SendToGroup(message);
}
}
- private Task SendToGroup(string message)
- {
- try
- {
+ private Task SendToGroup(string message) {
+ try {
var group = getGroup(Context.ConnectionId).Name;
return Clients.Group(group).SendCoreAsync(ReceiveMethod,
new object[] {getUser(Context.ConnectionId).Name, message});
}
- catch (InvalidOperationException)
- {
+ catch (InvalidOperationException) {
return Clients.Caller.SendCoreAsync(ReceiveMethod,
new object[] {"Nutzer ist in keiner Gruppe. Erst joinen!"});
}
}
- private Group getGroup(string id)
- {
+ private Group getGroup(string id) {
return DsaGroups.First(x => x.Users.Exists(y => y.ConnectionId.Equals(id)));
}
- private User getUser(string id)
- {
+ private User getUser(string id) {
return DsaGroups.First(x => x.Users.Exists(y => y.ConnectionId.Equals(id))).Users
.First(z => z.ConnectionId.Equals(id));
}
@@ -113,8 +98,7 @@ namespace DSACore.Hubs
//throw new NotImplementedException("add database call to get groups");
}
- public async Task AddGroup(string group, string password)
- {
+ public async Task AddGroup(string group, string password) {
DsaGroups.Add(new Group(group, password));
var Dgroup = new DSALib.Models.Database.Groups.Group {Name = group, Id = DsaGroups.Count - 1};
//Database.AddGroup(Dgroup);
@@ -122,22 +106,18 @@ namespace DSACore.Hubs
//throw new NotImplementedException("add database call to add groups");
}
- public async Task UploadChar(string xml)
- {
+ public async Task UploadChar(string xml) {
var group = getGroup(Context.ConnectionId);
await Database.AddChar(new Character(new MemoryStream(Encoding.UTF8.GetBytes(xml))), group.Name);
//throw new NotImplementedException("add database call to add groups");
}
- public async Task Login(string group, string user, string hash)
- {
+ public async Task Login(string group, string user, string hash) {
//string password = System.Text.Encoding.UTF8.GetString(hash);
- if (hash == DsaGroups.First(x => x.Name == group).Password)
- {
+ if (hash == DsaGroups.First(x => x.Name == group).Password) {
var gGroup = DsaGroups.First(x => x.Name.Equals(group));
- if (!gGroup.Users.Exists(x => x.Name.Equals(user)))
- {
+ if (!gGroup.Users.Exists(x => x.Name.Equals(user))) {
await Groups.RemoveFromGroupAsync(Context.ConnectionId, "login");
await Groups.AddToGroupAsync(Context.ConnectionId, group);
gGroup.Users.Add(new User {ConnectionId = Context.ConnectionId, Name = user});
@@ -149,42 +129,35 @@ namespace DSACore.Hubs
await Clients.Caller.SendAsync("Token", Tokens.Last().GetHashCode());
purgeTokens();
}
- else
- {
+ else {
await Clients.Caller.SendAsync("LoginResponse", 1);
}
}
- else
- {
+ else {
await Clients.Caller.SendAsync("LoginResponse", 2);
//await Clients.Caller.SendAsync(receiveMethod, "Falsches Passwort!");
}
}
- private void purgeTokens()
- {
+ private void purgeTokens() {
Tokens.RemoveAll(x => !x.IsValid());
}
- public override Task OnDisconnectedAsync(Exception exception)
- {
+ public override Task OnDisconnectedAsync(Exception exception) {
Disconnect().Wait();
return base.OnDisconnectedAsync(exception);
}
- public override Task OnConnectedAsync()
- {
+ public override Task OnConnectedAsync() {
Groups.AddToGroupAsync(Context.ConnectionId, "login").Wait();
Groups.AddToGroupAsync(Context.ConnectionId, "online").Wait();
return base.OnConnectedAsync();
}
- public async Task Disconnect()
- {
+ public async Task Disconnect() {
await Groups.RemoveFromGroupAsync(Context.ConnectionId, "online");
if (DsaGroups.Exists(x => x.Users.Exists(y => y.ConnectionId == Context.ConnectionId)))
- try
- {
+ try {
var group = getGroup(Context.ConnectionId);
@@ -195,8 +168,7 @@ namespace DSACore.Hubs
group.Users.Remove(user);
await Groups.RemoveFromGroupAsync(Context.ConnectionId, group.Name);
}
- catch (Exception e)
- {
+ catch (Exception e) {
Console.WriteLine(e);
//throw;
}