Я пытаюсь интегрировать Identity Users с SingalR. Пока что авторизация прошла успешно до подключения к хабу. Проблема в том, что я могу заставить его работать с группами, но, несмотря на работу авторизации, я не могу отправлять напрямую пользователем. Я также попробовал электронную почту вместо уникального идентификатора пользователя, но результаты те же. Хотелось бы узнать ваше мнение. Спасибо.
JWT:
options.Events = new JwtBearerEvents
{
OnMessageReceived = context =>
{
var accessToken = context.Request.Query["access_token"];
if (!string.IsNullOrEmpty(accessToken) &&(context.Request.Path.StartsWithSegments("/feed/get")))
{
context.Token = context.Request.Query["access_token"];
}
return Task.CompletedTask;
}
};
Startup.cs
app.UseEndpoints(route =>
{
route.MapHub<ActivityHub>("/feed/Get");
});
Hub
[Authorize(AuthenticationSchemes = JwtBearerDefaults.AuthenticationScheme)]
public class ActivityHub : Hub
{
IAuthService AuthService;
public ActivityHub(IAuthService authService)
{
AuthService = authService;
}
public override async Task OnConnectedAsync()
{
var user = await AuthService.GetUserByNameAsync(Context.User.Identity.Name);
await Clients.User(user.Id).SendAsync("receiveMessage", "Hello user"); //this doesn't get recived on client
await Groups.AddToGroupAsync(Context.ConnectionId, user.Id);
await Clients.Group(user.Id).SendAsync("receiveMessage", "Hello group!");//this works
await base.OnConnectedAsync();
}
public override async Task OnDisconnectedAsync(Exception exception)
{
await base.OnDisconnectedAsync(exception);
}
}
}