use transactions

teraa · Sep 13, 2024 · 887b06b · 887b06b
1 parent 83eea0a
commit 887b06b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/BattleTrace/Features/Players/FetchPlayers.cs b/BattleTrace/Features/Players/FetchPlayers.cs
@@ -120,6 +120,8 @@ await Parallel.ForEachAsync(
             sw.Elapsed
         );
 
+        await using var tsx = await _ctx.Database.BeginTransactionAsync(cancellationToken);
+
         _ctx.PlayerScans.Add(
             new PlayerScan
             {
@@ -141,5 +143,7 @@ await _ctx.BulkCopyAsync(
             players,
             cancellationToken
         );
+
+        await tsx.CommitAsync(cancellationToken);
     }
 }
diff --git a/BattleTrace/Features/Servers/FetchServers.cs b/BattleTrace/Features/Servers/FetchServers.cs
@@ -73,6 +73,8 @@ public async Task Handle(CancellationToken cancellationToken = default)
 
         var now = _time.GetUtcNow();
 
+        await using var tsx = await _ctx.Database.BeginTransactionAsync(cancellationToken);
+
         _ctx.ServerScans.Add(
             new Data.Models.ServerScan
             {
@@ -105,5 +107,7 @@ await _ctx.BulkCopyAsync(
             entities,
             cancellationToken
         );
+
+        await tsx.CommitAsync(cancellationToken);
     }
 }