Adam
/
TourIAm
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

improvements

This commit is contained in:
jozsef.b@aycode.com 2024-05-27 20:00:41 +02:00
parent 5f7df7ad9e
commit 05934c292a
4 changed files with 24 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
TIAM.Services/AcSignalRTags.cs
View File

@ -1,10 +0,0 @@
using AyCode.Services.SignalRs;
namespace TIAM.Services;
public class SignalRTags : AcSignalRTags
{
public const int GetTransfersAsync = 5;
public const int GetPropertiesByOwnerIdAsync = 6;
public const int UpdateTransferAsync = 7;
}

15
TIAM.Services/SignalRTags.cs Normal file
View File

@ -0,0 +1,15 @@
using AyCode.Services.SignalRs;
using TIAM.Entities.Transfers;
namespace TIAM.Services;
public class SignalRTags : AcSignalRTags
{
//[SignalMessageTag(null, typeof(SignalResponseMessage<string>), null, null)]
public static readonly int GetTransfersAsync = 5;
public static readonly int GetPropertiesByOwnerIdAsync = 6;
[SignalMessageTag(typeof(SignalPostJsonDataMessage<Transfer>), typeof(SignalResponseMessage<string>), null, null)]
public static readonly int UpdateTransferAsync = 7;
}

5
TIAMWebApp/Server/Services/DevAdminSignalRhub.cs
View File

@ -71,11 +71,12 @@ public class DevAdminSignalRHub(AdminDal adminDal, ServiceProviderAPIController
} }
else if (messageTag == SignalRTags.UpdateTransferAsync) else if (messageTag == SignalRTags.UpdateTransferAsync)
{ {
//var jsonPostData = message!.MessagePackTo<SignalPostJsonDataMessage>().PostData;
//var jsonPostData = message!.MessagePackTo<SignalPostJsonDataMessage>().PostDataJson;
//_logger.DetailConditional($"PostData: [{jsonPostData}]"); //_logger.DetailConditional($"PostData: [{jsonPostData}]");
//var transfer = jsonPostData.JsonTo<Transfer>()!; //var transfer = jsonPostData.JsonTo<Transfer>()!;
var transfer = message!.MessagePackTo<SignalPostJsonDataMessage>().PostData.JsonTo<Transfer>()!; var transfer = message!.MessagePackTo<SignalPostJsonDataMessage<Transfer>>().PostData;
await transferDataAPIController.UpdateTransfer(transfer); await transferDataAPIController.UpdateTransfer(transfer);
await ResponseToCaller(messageTag, new SignalResponseMessage<string>(SignalResponseStatus.Success, transfer.ToJson()), requestId); await ResponseToCaller(messageTag, new SignalResponseMessage<string>(SignalResponseStatus.Success, transfer.ToJson()), requestId);

11
TIAMWebApp/Shared/Services/AcSignalRClientBase.cs
View File

@ -88,8 +88,9 @@ namespace TIAMWebApp.Shared.Application.Services
Logger.DebugConditional($"Client SendMessageToServerAsync; {nameof(messageTag)}: {messageTag}; {nameof(requestId)}: {requestId};"); Logger.DebugConditional($"Client SendMessageToServerAsync; {nameof(messageTag)}: {messageTag}; {nameof(requestId)}: {requestId};");
await StartConnection(); await StartConnection();
HubConnection.SendAsync(nameof(IAcSignalRHubClient.OnReceiveMessage), messageTag, message?.ToMessagePack(ContractlessStandardResolver.Options), requestId).Forget(); var msgp = message?.ToMessagePack(ContractlessStandardResolver.Options);
HubConnection.SendAsync(nameof(IAcSignalRHubClient.OnReceiveMessage), messageTag, msgp, requestId).Forget();
} }
#region CRUD #region CRUD
@ -104,9 +105,9 @@ namespace TIAMWebApp.Shared.Application.Services
=> SendMessageToServerAsync(messageTag, null, responseCallback); => SendMessageToServerAsync(messageTag, null, responseCallback);
public virtual Task<TPostData?> UpdateAsync<TPostData>(int messageTag, TPostData postData) where TPostData : class public virtual Task<TPostData?> UpdateAsync<TPostData>(int messageTag, TPostData postData) where TPostData : class
=> SendMessageToServerAsync<TPostData>(messageTag, new SignalPostJsonDataMessage(postData), AcDomain.NextUniqueInt32); => SendMessageToServerAsync<TPostData>(messageTag, new SignalPostJsonDataMessage<TPostData>(postData), AcDomain.NextUniqueInt32);
public virtual Task UpdateAsync<TPostData>(int messageTag, TPostData postData, Action<ISignalResponseMessage<TPostData?>> responseCallback) public virtual Task UpdateAsync<TPostData>(int messageTag, TPostData postData, Action<ISignalResponseMessage<TPostData?>> responseCallback) where TPostData : class
=> SendMessageToServerAsync(messageTag, new SignalPostJsonDataMessage(postData!), responseCallback); => SendMessageToServerAsync(messageTag, new SignalPostJsonDataMessage<TPostData>(postData), responseCallback);
#endregion CRUD #endregion CRUD