Add transaction scope support

Author: glucaci

src/providers/WorkflowCore.Persistence.MongoDB/Services/MongoPersistenceProvider.cs

@@ -12,6 +12,7 @@
 using WorkflowCore.Interface;
 using WorkflowCore.Models;
 using System.Threading;
+using MongoDB.Extensions.Transactions;
 
 namespace WorkflowCore.Persistence.MongoDB.Services
 {
@@ -115,13 +116,13 @@ static void CreateIndexes(MongoPersistenceProvider instance)
             }
         }
 
-        private IMongoCollection<WorkflowInstance> WorkflowInstances => _database.GetCollection<WorkflowInstance>(WorkflowCollectionName);
+        private IMongoCollection<WorkflowInstance> WorkflowInstances => _database.GetCollection<WorkflowInstance>(WorkflowCollectionName).AsTransactionCollection();
 
-        private IMongoCollection<EventSubscription> EventSubscriptions => _database.GetCollection<EventSubscription>("wfc.subscriptions");
+        private IMongoCollection<EventSubscription> EventSubscriptions => _database.GetCollection<EventSubscription>("wfc.subscriptions").AsTransactionCollection();
 
-        private IMongoCollection<Event> Events => _database.GetCollection<Event>("wfc.events");
+        private IMongoCollection<Event> Events => _database.GetCollection<Event>("wfc.events").AsTransactionCollection();
 
-        private IMongoCollection<ExecutionError> ExecutionErrors => _database.GetCollection<ExecutionError>("wfc.execution_errors");
+        private IMongoCollection<ExecutionError> ExecutionErrors => _database.GetCollection<ExecutionError>("wfc.execution_errors").AsTransactionCollection();
 
         public async Task<string> CreateNewWorkflow(WorkflowInstance workflow, CancellationToken cancellationToken = default)
         {

src/providers/WorkflowCore.Persistence.MongoDB/WorkflowCore.Persistence.MongoDB.csproj

@@ -22,7 +22,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="MongoDB.Driver" Version="2.8.1" />
+    <PackageReference Include="MongoDB.Driver" Version="2.12.2" />
+    <PackageReference Include="MongoDB.Extensions.Transactions" Version="0.8.0" />
     <PackageReference Include="Newtonsoft.Json" Version="12.0.1" />
   </ItemGroup>