blob: d343c758106e667e640125f50081f565a159293d (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
using api.Models;
using Microsoft.AspNetCore.SignalR;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Threading.Tasks;
namespace api.Services
{
public class ChatHub :Hub,IChat
{
static readonly Dictionary<string,string> Users=new Dictionary<string,string>();
private readonly IJwtToken _tokenService;
public ChatHub(IJwtToken tokenService)
{
_tokenService=tokenService;
}
public override async Task OnConnectedAsync()
{
string token=Context.GetHttpContext().Request.Query["access_token"];
string id=_tokenService.TokenToId(token);
Users.Add(id,Context.ConnectionId);
await SendDirect(id, "poruka");
//await Send(Context.ConnectionId);
await base.OnConnectedAsync();
}
public override async Task OnDisconnectedAsync(Exception? exception)
{
string id = Users.FirstOrDefault(u => u.Value == Context.ConnectionId).Key;
Users.Remove(id);
}
public async Task SendDirect(string id,string message)
{
if (Users[id]==null)
return;
await Clients.Client(Users[id]).SendAsync("Notify",message);
}
public async Task Send(string message)
{
await Clients.All.SendAsync("Notify",message);
}
}
}
|
