From 82bf1608fd8539682d77f45b68ce4362a84038ce Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Tue, 23 Sep 2025 23:05:41 +0800 Subject: [PATCH] :bug: Fix award handler --- .../Startup/BroadcastEventHandler.cs | 30 +++++++++---------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/DysonNetwork.Sphere/Startup/BroadcastEventHandler.cs b/DysonNetwork.Sphere/Startup/BroadcastEventHandler.cs index 29232a4..d99609a 100644 --- a/DysonNetwork.Sphere/Startup/BroadcastEventHandler.cs +++ b/DysonNetwork.Sphere/Startup/BroadcastEventHandler.cs @@ -71,25 +71,25 @@ public class BroadcastEventHandler( switch (evt.ProductIdentifier) { case "posts.award": - { - var awardEvt = JsonSerializer.Deserialize(msg.Data); - if (awardEvt?.Meta == null) throw new ArgumentNullException(nameof(awardEvt)); + { + var awardEvt = JsonSerializer.Deserialize(msg.Data, GrpcTypeHelper.SerializerOptions); + if (awardEvt?.Meta == null) throw new ArgumentNullException(nameof(awardEvt)); - var meta = awardEvt.Meta; + var meta = awardEvt.Meta; - logger.LogInformation("Handling post award order: {OrderId}", evt.OrderId); + logger.LogInformation("Handling post award order: {OrderId}", evt.OrderId); - await using var scope = serviceProvider.CreateAsyncScope(); - var ps = scope.ServiceProvider.GetRequiredService(); + await using var scope = serviceProvider.CreateAsyncScope(); + var ps = scope.ServiceProvider.GetRequiredService(); - var amountNum = decimal.Parse(meta.Amount); + var amountNum = decimal.Parse(meta.Amount); - await ps.AwardPost(meta.PostId, meta.AccountId, amountNum, meta.Attitude, meta.Message); + await ps.AwardPost(meta.PostId, meta.AccountId, amountNum, meta.Attitude, meta.Message); - logger.LogInformation("Post award for order {OrderId} handled successfully.", evt.OrderId); - await msg.AckAsync(cancellationToken: stoppingToken); - break; - } + logger.LogInformation("Post award for order {OrderId} handled successfully.", evt.OrderId); + await msg.AckAsync(cancellationToken: stoppingToken); + break; + } default: await msg.NakAsync(cancellationToken: stoppingToken); break; @@ -177,7 +177,7 @@ public class BroadcastEventHandler( WebSocketPacketEvent.SubjectPrefix + "sphere", cancellationToken: stoppingToken)) { logger.LogDebug("Handling websocket packet..."); - + try { var evt = JsonSerializer.Deserialize(msg.Data, GrpcTypeHelper.SerializerOptions); @@ -290,4 +290,4 @@ public class BroadcastEventHandler( }.ToProtoValue() }); } -} \ No newline at end of file +}