Revert and provide a new extension for creating db from outside

Author: glucaci

src/providers/WorkflowCore.Persistence.MongoDB/ServiceCollectionExtensions.cs

@@ -1,6 +1,5 @@
 using MongoDB.Driver;
 using System;
-using System.Linq;
 using WorkflowCore.Interface;
 using WorkflowCore.Models;
 using WorkflowCore.Persistence.MongoDB.Services;
@@ -33,5 +32,26 @@ public static WorkflowOptions UseMongoDB(
             });
             return options;
         }
+
+        public static WorkflowOptions UseMongoDB(
+            this WorkflowOptions options, 
+            Func<IServiceProvider, IMongoDatabase> createDatabase)
+        {
+            if (options == null) throw new ArgumentNullException(nameof(options));
+            if (createDatabase == null) throw new ArgumentNullException(nameof(createDatabase));
+
+            options.UsePersistence(sp =>
+            {
+                var db = createDatabase(sp);
+                return new MongoPersistenceProvider(db);
+            });
+            options.Services.AddTransient<IWorkflowPurger>(sp =>
+            {
+                var db = createDatabase(sp);
+                return new WorkflowPurger(db);
+            });
+
+            return options;
+        }
     }
 }

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

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

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

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