Optimize transaction processing with dynamic batch limit

planetarium · Feb 28, 2025 · 378938e · 378938e
1 parent 1a2bc02
commit 378938e
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/ArenaService/Worker/BattleTxTracker.cs b/ArenaService/Worker/BattleTxTracker.cs
@@ -98,6 +98,17 @@ CancellationToken stoppingToken
             return;
         }
 
+        var blockDiff = currentBlockIndex - startingBlock;
+        var limit = blockDiff switch
+        {
+            > 1000 => 300,
+            > 500 => 100,
+            > 100 => 30,
+            > 50 => 10,
+            > 30 => 5,
+            _ => 1
+        };
+
         _logger.LogInformation(
             $"Processing transactions from block {startingBlock} to {currentBlockIndex}"
         );
@@ -107,7 +118,7 @@ CancellationToken stoppingToken
             {
                 var response = await client.GetTxs.ExecuteAsync(
                     startingBlock,
-                    1,
+                    limit,
                     ACTION_TYPE,
                     [TxStatus.Success, TxStatus.Staging],
                     stoppingToken
@@ -180,10 +191,11 @@ out var payload
             catch (Exception ex)
             {
                 _logger.LogError(ex, $"Failed to process transaction {tx.Id}");
+                throw;
             }
         }
 
-        await SetLastProcessedBlockAsync(redis, startingBlock + 1);
+        await SetLastProcessedBlockAsync(redis, startingBlock + limit - 1);
     }
 
     private async Task<long> GetLastProcessedBlockAsync(IDatabase redis)