feat(LtdRaffleGrain): enhance deactivation process and update loser handling

Author: Diddyy

Turbo.Catalog/Grains/LtdRaffleGrain.cs

@@ -48,6 +48,28 @@ public override async Task OnActivateAsync(CancellationToken ct)
             _raffleFinished = _series.IsRaffleFinished;
     }
 
+    public override async Task OnDeactivateAsync(DeactivationReason reason, CancellationToken ct)
+    {
+        _raffleTimer?.Dispose();
+        _raffleTimer = null;
+
+        if (_currentBatchEntries.Count > 0)
+        {
+            try
+            {
+                await ExecuteRaffleAsync();
+            }
+            catch (Exception ex)
+            {
+                logger.LogError(
+                    ex,
+                    "Failed to execute raffle during deactivation for series {SeriesId}",
+                    this.GetPrimaryKeyLong()
+                );
+            }
+        }
+    }
+
     public async Task<LtdRaffleEntryResult> EnterRaffleAsync(int playerId, CancellationToken ct)
     {
         if (_series is not { IsAvailable: true })
@@ -164,6 +186,7 @@ private async Task ExecuteRaffleAsync()
         _currentBatchEntries.Clear();
         _isInBufferPeriod = false;
         _raffleFinished = true;
+        _raffleTimer?.Dispose();
         _raffleTimer = null;
 
         await PersistFinishedAsync();
@@ -174,12 +197,31 @@ private async Task ExecuteRaffleAsync()
             ? [.. entries.OrderBy(_ => Random.Shared.Next()).Take(winnersCount).Select(e => e.Key)]
             : SelectWeighted(entries, winnersCount);
 
+        var loserIds = new List<int>();
+
         foreach (var entry in entries)
         {
             if (winners.Contains(entry.Key))
                 await TryFinalizeWinnerAsync(entry.Key, batchId, true);
             else
+            {
+                loserIds.Add(entry.Key);
                 await NotifyLoserAsync(entry.Key, LtdRaffleResultCode.Lost);
+            }
+        }
+
+        if (loserIds.Count > 0)
+        {
+            await using var db = await dbCtxFactory.CreateDbContextAsync(CancellationToken.None);
+
+            await db
+                .LtdRaffleEntries.Where(e =>
+                    e.BatchId == batchId && loserIds.Contains(e.PlayerEntityId)
+                )
+                .ExecuteUpdateAsync(u =>
+                    u.SetProperty(e => e.Result, "lost")
+                        .SetProperty(e => e.ProcessedAt, DateTime.UtcNow)
+                );
         }
 
         await ReloadSeriesAsync(CancellationToken.None);

Turbo.PacketHandlers/Catalog/PurchaseFromCatalogMessageHandler.cs

@@ -116,7 +116,7 @@ CancellationToken ct
     {
         // Use the series ID if available (Perfect Design), otherwise fallback to Product ID
         var seriesId = ltdProduct.LtdSeriesId ?? ltdProduct.Id;
-        var ltdRaffleGrain = _grainFactory.GetGrain<ILtdRaffleGrain>(seriesId);
+        var ltdRaffleGrain = _grainFactory.GetLtdRaffleGrain(seriesId);
 
         var result = await ltdRaffleGrain.EnterRaffleAsync(ctx.PlayerId, ct).ConfigureAwait(false);