118 lines
5.7 KiB
C#
118 lines
5.7 KiB
C#
using AyCode.Core.Loggers;
|
|
using AyCode.Models.Server.DynamicMethods;
|
|
using AyCode.Services.SignalRs;
|
|
using FruitBank.Common.Interfaces;
|
|
using FruitBank.Common.Loggers;
|
|
using FruitBank.Common.Server.Interfaces;
|
|
using FruitBank.Common.SignalRs;
|
|
using Mango.Nop.Core.Loggers;
|
|
using Microsoft.Extensions.Configuration;
|
|
|
|
namespace FruitBank.Common.Server.Services.SignalRs;
|
|
|
|
//public class DevAdminSignalRHub : AcWebSignalRHubWithSessionBase<SignalRTags, Logger<DevAdminSignalRHub>>
|
|
//{
|
|
// public DevAdminSignalRHub(IConfiguration configuration, IEnumerable<IAcLogWriterBase> logWriters)
|
|
// : base(configuration, new Logger<DevAdminSignalRHub>(logWriters.ToArray()))
|
|
// {
|
|
// Logger.Info("DevAdminSignalRHub");
|
|
// }
|
|
|
|
// public Task ReceiveMessage(int messageTag, byte[]? message, int? requestId)
|
|
// {
|
|
|
|
// Clients.All.SendAsync("TestMessage", "Hello from server");
|
|
// }
|
|
|
|
//}
|
|
|
|
public class DevAdminSignalRHub : AcWebSignalRHubWithSessionBase<SignalRTags, Logger<DevAdminSignalRHub>>
|
|
{
|
|
public DevAdminSignalRHub(IConfiguration configuration, IFruitBankDataControllerServer fruitBankDataController/*, SessionService sessionService*/,
|
|
ICustomOrderSignalREndpointServer customOrderSignalREndpoint, IEnumerable<IAcLogWriterBase> logWriters)
|
|
: base(configuration, new Logger<DevAdminSignalRHub>(logWriters.ToArray()))
|
|
{
|
|
DynamicMethodCallModels.Add(new AcDynamicMethodCallModel<SignalRAttribute>(fruitBankDataController));
|
|
DynamicMethodCallModels.Add(new AcDynamicMethodCallModel<SignalRAttribute>(customOrderSignalREndpoint));
|
|
}
|
|
|
|
//public override Task OnReceiveMessage(int messageTag, byte[]? message, int? requestId)
|
|
//{
|
|
// return ProcessOnReceiveMessage(messageTag, message, requestId, async 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;
|
|
// }
|
|
// });
|
|
//}
|
|
} |