From 27ac2d18438d5f98db0fba00b50f4b3d2143460a Mon Sep 17 00:00:00 2001 From: Loretta Date: Sun, 5 Apr 2026 09:31:06 +0200 Subject: [PATCH] Refactor SignalR message handling in FruitBankSignalRClient Update MessageReceived to use SignalReceiveParams and construct SignalResponseDataMessage with more context. Add AyCode.Core.Serializers using directive for serializer type support. --- .../Services/SignalRs/FruitBankSignalRClient.cs | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/FruitBankHybrid.Shared/Services/SignalRs/FruitBankSignalRClient.cs b/FruitBankHybrid.Shared/Services/SignalRs/FruitBankSignalRClient.cs index 6f5ea823..35f210a5 100644 --- a/FruitBankHybrid.Shared/Services/SignalRs/FruitBankSignalRClient.cs +++ b/FruitBankHybrid.Shared/Services/SignalRs/FruitBankSignalRClient.cs @@ -19,6 +19,7 @@ using Microsoft.AspNetCore.SignalR.Client; using Nop.Core.Domain.Customers; using System.Collections.ObjectModel; using System.ServiceModel.Channels; +using AyCode.Core.Serializers; using Mango.Nop.Core.Entities; namespace FruitBankHybrid.Shared.Services.SignalRs @@ -42,10 +43,14 @@ namespace FruitBankHybrid.Shared.Services.SignalRs /// public event Func OnMessageReceived = null!; - protected override async Task MessageReceived(int messageTag, byte[] messageBytes) + protected override async Task MessageReceived(int messageTag, SignalReceiveParams receiveParams, byte[] data) { - var responseDataMessage = messageBytes.BinaryTo(); - + var responseDataMessage = new SignalResponseDataMessage + { + Status = receiveParams.Status, + DataSerializerType = AcSerializerType.Binary, + ResponseData = data + }; await OnMessageReceived(messageTag, responseDataMessage); }