This commit is contained in:
Pistasj
2023-05-28 17:35:51 +02:00
parent c5d43489de
commit 13d2b1b1fb
8 changed files with 369 additions and 7 deletions

View File

@@ -4,7 +4,7 @@ namespace LiveChat.Server.Hubs;
public class ChatHub : Hub
{
public async Task SendMessage(string user, string message)
public async Task SendMessage(string user, string message, string room)
{
using (var db = new ChattingContext())
{
@@ -14,9 +14,32 @@ public class ChatHub : Hub
Message = message,
};
var dbSave = db.Messages.Add(messageData);
await Clients.All.SendAsync("ReceiveMessage", user, message);
await Clients.AllExcept("LiveChat Room Users").SendAsync("ReceiveMessage", user, message);
db.SaveChanges();
}
}
public async Task SendMessageRoom(string user, string message, string room)
{
using (var db = new ChattingContext())
{
var messageData = new RoomChatMessage()
{
User = user,
Message = message,
RoomId = room
};
var dbSave = db.RoomChatMessages.Add(messageData);
await Clients.Group(room).SendAsync("ReceiveMessage", user, message);
db.SaveChanges();
}
}
public async Task JoinRoom(string room, string user)
{
await Groups.AddToGroupAsync(Context.ConnectionId, room);
await Groups.AddToGroupAsync(Context.ConnectionId, "Folk i rom");
await Clients.Caller.SendAsync("ConnectionIdReceive", Context.ConnectionId);
}
}