310 lines
16 KiB
C#
310 lines
16 KiB
C#
using AyCode.Core.Extensions;
|
|
using AyCode.Core.Loggers;
|
|
using AyCode.Services.SignalRs;
|
|
using Microsoft.AspNetCore.SignalR;
|
|
using TIAM.Database.DataLayers.Admins;
|
|
using MessagePack.Resolvers;
|
|
using AyCode.Services.Server.SignalRs;
|
|
using TIAM.Services;
|
|
using TIAMWebApp.Server.Controllers;
|
|
using MessagePack;
|
|
using TIAM.Entities.Addresses;
|
|
using System.Linq.Expressions;
|
|
using AyCode.Core.Helpers;
|
|
using Profile = TIAM.Entities.Profiles.Profile;
|
|
using Serialize.Linq.Serializers;
|
|
using System.Security.Claims;
|
|
using AyCode.Core;
|
|
using AyCode.Blazor.Components.Services;
|
|
using TIAM.Database.DataLayers.Users;
|
|
using TIAM.Services.Server.Logins;
|
|
using TIAMWebApp.Shared.Application.Interfaces;
|
|
|
|
namespace TIAMWebApp.Server.Services;
|
|
|
|
public class DevAdminSignalRHub : Hub<ISignalRHubItemServer>, IAcSignalRHubServer
|
|
{
|
|
private readonly List<DynamicMethodCallModel<SignalRAttribute>> _dynamicMethodCallModels = [];
|
|
private readonly TIAM.Core.Loggers.Logger<DevAdminSignalRHub> _logger;
|
|
|
|
private SessionService _sessionService;
|
|
private IConfiguration _configuration;
|
|
|
|
private readonly AdminDal _adminDal;
|
|
private readonly UserDal _userDal;
|
|
//private readonly ServiceProviderAPIController _serviceProviderApiController;
|
|
//private readonly TransferDataAPIController _transferDataApiController;
|
|
|
|
public DevAdminSignalRHub(IConfiguration configuration, AdminDal adminDal, UserDal userDal, UserAPIController userApiController, ServiceProviderAPIController serviceProviderApiController, TransferDataAPIController transferDataApiController, MessageAPIController messageApiController, ProfileAPIController profileApiController, LoggerApiController loggerApiController, SessionService sessionService, IEnumerable<IAcLogWriterBase> logWriters)
|
|
{
|
|
_adminDal = adminDal;
|
|
_userDal = userDal;
|
|
|
|
_configuration = configuration;
|
|
|
|
//_serviceProviderApiController = serviceProviderApiController;
|
|
//_transferDataApiController = transferDataApiController;
|
|
|
|
_logger = new(logWriters.ToArray());
|
|
_sessionService = sessionService;
|
|
|
|
_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(userApiController));
|
|
_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(serviceProviderApiController));
|
|
_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(transferDataApiController));
|
|
_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(messageApiController));
|
|
_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(profileApiController));
|
|
_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(loggerApiController));
|
|
//_dynamicMethodCallModels.Add(new DynamicMethodCallModel<SignalRAttribute>(typeof(AdminDal)));
|
|
|
|
}
|
|
|
|
// https://docs.microsoft.com/en-us/aspnet/core/signalr/hubs?view=aspnetcore-3.1#strongly-typed-hubs
|
|
public override async Task OnConnectedAsync()
|
|
{
|
|
_logger.Debug($"Server OnConnectedAsync; ConnectionId: {Context.ConnectionId}; UserIdentifier: {Context.UserIdentifier}");
|
|
|
|
LogContextUserNameAndId();
|
|
|
|
_sessionService.Sessions.TryAdd(Context.ConnectionId, new SessionItem(Context.ConnectionId, new LoginService(_userDal, _configuration)));
|
|
_logger.Info($"_sessionService.Sessions count: {_sessionService.Sessions.Count}");
|
|
|
|
////insert or updatde them into database.
|
|
//var CId = _context.UserIdToCId.Find(userId);
|
|
//CId.ConnectionId = connectionid;
|
|
//_context.Update(CId);
|
|
//await _context.SaveChangesAsync();
|
|
//await base.OnConnectedAsync();
|
|
////await Groups.AddToGroupAsync(Context.ConnectionId, "SignalR Users");
|
|
|
|
await base.OnConnectedAsync();
|
|
|
|
//Clients.Caller.ConnectionId = Context.ConnectionId;
|
|
//Clients.Caller.UserIdentifier = Context.UserIdentifier;
|
|
}
|
|
|
|
public override async Task OnDisconnectedAsync(Exception? exception)
|
|
{
|
|
var logText = $"Server OnDisconnectedAsync; ConnectionId: {Context.ConnectionId}; UserIdentifier: {Context.UserIdentifier};";
|
|
|
|
if (exception == null) _logger.Debug(logText);
|
|
else _logger.Error(logText, exception);
|
|
|
|
LogContextUserNameAndId();
|
|
|
|
if (_sessionService.Sessions.TryRemove(Context.ConnectionId, out var sessionItem)) sessionItem.LoginService.Logout();
|
|
_logger.Info($"_sessionService.Sessions count: {_sessionService.Sessions.Count}");
|
|
|
|
//await Groups.RemoveFromGroupAsync(Context.ConnectionId, "SignalR Users");
|
|
await base.OnDisconnectedAsync(exception);
|
|
}
|
|
|
|
public async Task OnReceiveMessage(int messageTag, byte[]? message, int? requestId)
|
|
{
|
|
var tagName = ConstHelper.NameByValue<SignalRTags>(messageTag);
|
|
var logText = $"Server OnReceiveMessage; {nameof(requestId)}: {requestId}; ConnectionId: {Context.ConnectionId}; {tagName}";
|
|
|
|
if (message is { Length: 0 }) _logger.Warning($"message.Length == 0! {logText}");
|
|
else _logger.Info($"[{message?.Length:N0}b] {logText}");
|
|
|
|
try
|
|
{
|
|
if (AcDomain.IsDeveloperVersion) LogContextUserNameAndId();
|
|
|
|
foreach (var methodsByDeclaringObject in _dynamicMethodCallModels)
|
|
{
|
|
if (!methodsByDeclaringObject.MethodsByMessageTag.TryGetValue(messageTag, out var methodInfoModel)) continue;
|
|
|
|
object[]? paramValues = null;
|
|
|
|
logText = $"Found dynamic method for the tag! method: {methodsByDeclaringObject.InstanceObject.GetType().Name}.{methodInfoModel.MethodInfo.Name}";
|
|
|
|
if (methodInfoModel.ParamInfos is { Length: > 0 })
|
|
{
|
|
_logger.Debug($"{logText}({string.Join(", ", methodInfoModel.ParamInfos.Select(x => x.Name))}); {tagName}");
|
|
|
|
paramValues = new object[methodInfoModel.ParamInfos.Length];
|
|
|
|
var firstParamType = methodInfoModel.ParamInfos[0].ParameterType;
|
|
if (methodInfoModel.ParamInfos.Length > 1 || firstParamType == typeof(string) || firstParamType.IsEnum || firstParamType.IsValueType || firstParamType == typeof(DateTime))
|
|
{
|
|
var msg = message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>();
|
|
|
|
for (var i = 0; i < msg.PostData.Ids.Count; i++)
|
|
{
|
|
//var obj = (string)msg.PostData.Ids[i];
|
|
//if (msg.PostData.Ids[i] is Guid id)
|
|
//{
|
|
// if (id.IsNullOrEmpty()) throw new NullReferenceException($"PostData.Id.IsNullOrEmpty(); Ids: {msg.PostData.Ids}");
|
|
// paramValues[i] = id;
|
|
//}
|
|
//else if (Guid.TryParse(obj, out id))
|
|
//{
|
|
// if (id.IsNullOrEmpty()) throw new NullReferenceException($"PostData.Id.IsNullOrEmpty(); Ids: {msg.PostData.Ids}");
|
|
// paramValues[i] = id;
|
|
//}
|
|
//else if (Enum.TryParse(methodInfoModel.ParameterType, obj, out var enumObj))
|
|
//{
|
|
// paramValues[i] = enumObj;
|
|
//}
|
|
//else paramValues[i] = Convert.ChangeType(obj, methodInfoModel.ParameterType);
|
|
|
|
var obj = msg.PostData.Ids[i];
|
|
//var config = new MapperConfiguration(cfg =>
|
|
//{
|
|
// cfg.CreateMap(obj.GetType(), methodInfoModel.ParameterType);
|
|
//});
|
|
|
|
//var mapper = new Mapper(config);
|
|
//paramValues[i] = mapper.Map(obj, methodInfoModel.ParameterType);
|
|
|
|
//paramValues[i] = obj;
|
|
|
|
var a = Array.CreateInstance(methodInfoModel.ParamInfos[i].ParameterType, 1);
|
|
|
|
if (methodInfoModel.ParamInfos[i].ParameterType == typeof(Expression))
|
|
{
|
|
var serializer = new ExpressionSerializer(new JsonSerializer());
|
|
paramValues[i] = serializer.DeserializeText((string)(obj.JsonTo(a.GetType()) as Array)?.GetValue(0)!);
|
|
}
|
|
else paramValues[i] = (obj.JsonTo(a.GetType()) as Array)?.GetValue(0)!;
|
|
|
|
}
|
|
}
|
|
else paramValues[0] = message!.MessagePackTo<SignalPostJsonDataMessage<object>>(MessagePackSerializerOptions.Standard).PostDataJson.JsonTo(firstParamType)!;
|
|
}
|
|
else _logger.Debug($"{logText}(); {tagName}");
|
|
|
|
var responseDataJson = new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, methodInfoModel.MethodInfo.InvokeMethod(methodsByDeclaringObject.InstanceObject, paramValues));
|
|
var responseDataJsonKiloBytes = System.Text.Encoding.Unicode.GetByteCount(responseDataJson.ResponseData!) / 1024;
|
|
|
|
//File.WriteAllText(Path.Combine("h:", $"{requestId}.json"), responseDataJson.ResponseData);
|
|
|
|
_logger.Info($"[{responseDataJsonKiloBytes}kb] responseData serialized to json");
|
|
await ResponseToCaller(messageTag, responseDataJson, requestId);
|
|
|
|
return;
|
|
}
|
|
|
|
_logger.Debug($"Not found dynamic method for the tag! {tagName}");
|
|
|
|
switch (messageTag)
|
|
{
|
|
case SignalRTags.GetAddress:
|
|
//var id = Guid.Parse((string)message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0]);
|
|
var id = message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0].JsonTo<Guid[]>()![0];
|
|
|
|
var address = await _adminDal.GetAddressByIdAsync(id);
|
|
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, address), requestId);
|
|
|
|
return;
|
|
|
|
case SignalRTags.GetAddressesByContextId:
|
|
//id = Guid.Parse((string)message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0]);
|
|
id = message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0].JsonTo<Guid[]>()![0];
|
|
|
|
address = await _adminDal.GetAddressByIdAsync(id);
|
|
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, new List<Address> { address! }), requestId);
|
|
|
|
return;
|
|
|
|
case SignalRTags.UpdateAddress:
|
|
address = message!.MessagePackTo<SignalPostJsonDataMessage<Address>>().PostData;
|
|
|
|
await _adminDal.UpdateAddressAsync(address);
|
|
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, address), requestId);
|
|
|
|
return;
|
|
|
|
case SignalRTags.UpdateProfile:
|
|
var profile = message!.MessagePackTo<SignalPostJsonDataMessage<Profile>>().PostData;
|
|
|
|
await _adminDal.UpdateProfileAsync(profile);
|
|
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, profile), requestId);
|
|
|
|
return;
|
|
|
|
//case SignalRTags.GetTransfersAsync:
|
|
// await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await _transferDataApiController.GetTransfers()), requestId);
|
|
|
|
// return;
|
|
|
|
//case SignalRTags.GetPropertiesByOwnerIdAsync:
|
|
// var ownerId = message!.MessagePackTo<SignalRequestByIdMessage>().Id;
|
|
|
|
// await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await _serviceProviderApiController.GetServiceProvidersByOwnerId(ownerId)), requestId);
|
|
|
|
// return;
|
|
|
|
//case SignalRTags.UpdateTransferAsync:
|
|
// var transfer = message!.MessagePackTo<SignalPostJsonDataMessage<Transfer>>().PostData;
|
|
|
|
// await _transferDataApiController.UpdateTransfer(transfer);
|
|
// await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, transfer), requestId);
|
|
|
|
// return;
|
|
|
|
//case SignalRTags.GetCompaniesAsync:
|
|
// await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await _serviceProviderApiController.GetServiceProviders()), requestId);
|
|
|
|
// return;
|
|
//case SignalRTags.UpdateCompanyAsync:
|
|
|
|
// var updateCompany = message!.MessagePackTo<SignalPostJsonDataMessage<Company>>().PostData;
|
|
|
|
// await _serviceProviderApiController.UpdateServiceProvider(updateCompany);
|
|
// await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, updateCompany), requestId);
|
|
|
|
// return;
|
|
|
|
default:
|
|
_logger.Error($"Server OnReceiveMessage; messageTag not found! {tagName}");
|
|
break;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.Error($"Server OnReceiveMessage; {ex.Message}; {tagName}", ex);
|
|
}
|
|
|
|
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Error), requestId);
|
|
}
|
|
|
|
protected async Task ResponseToCaller(int messageTag, ISignalRMessage message, int? requestId)
|
|
=> await SendMessageToClient(Clients.Caller, messageTag, message, requestId);
|
|
|
|
public async Task SendMessageToUserId(string userId, int messageTag, ISignalRMessage message, int? requestId)
|
|
=> await SendMessageToClient(Clients.User(userId), messageTag, message, requestId);
|
|
|
|
public async Task SendMessageToConnectionId(string connectionId, int messageTag, ISignalRMessage message, int? requestId)
|
|
=> await SendMessageToClient(Clients.Client(Context.ConnectionId), messageTag, message, requestId);
|
|
|
|
protected async Task SendMessageToClient(ISignalRHubItemServer sendTo, int messageTag, ISignalRMessage message, int? requestId = null)
|
|
{
|
|
var responseDataMessagePack = message.ToMessagePack(ContractlessStandardResolver.Options);
|
|
_logger.Info($"[{(responseDataMessagePack.Length/1024)}kb] Server sending responseDataMessagePack to client; {nameof(requestId)}: {requestId}; ConnectionId: {Context.ConnectionId}; {ConstHelper.NameByValue<SignalRTags>(messageTag)}");
|
|
|
|
await sendTo.OnReceiveMessage(messageTag, responseDataMessagePack, requestId);
|
|
}
|
|
|
|
public async Task SendMessageToGroup(string groupId, int messageTag, string message)
|
|
{
|
|
//await Clients.Group(groupId).Post("", messageTag, message);
|
|
}
|
|
|
|
//[Conditional("DEBUG")]
|
|
private void LogContextUserNameAndId()
|
|
{
|
|
string? userName = null;
|
|
var userId = Guid.Empty;
|
|
|
|
if (Context.User != null)
|
|
{
|
|
userName = Context.User.Identity?.Name;
|
|
Guid.TryParse(Context.User.FindFirstValue(ClaimTypes.NameIdentifier), out userId);
|
|
}
|
|
|
|
if (AcDomain.IsDeveloperVersion) _logger.WarningConditional($"SignalR.Context; userName: {userName}; userId: {userId}");
|
|
else _logger.Debug($"SignalR.Context; userName: {userName}; userId: {userId}");
|
|
}
|
|
|
|
} |