Merge pull request #1287 from SamhammerAG/fix-mongo

Fixed usage of CreateIndexes for mongo

Author: danielgerlag

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

@@ -23,7 +23,6 @@ public class MongoPersistenceProvider : IPersistenceProvider
         public MongoPersistenceProvider(IMongoDatabase database)
         {
             _database = database;
-            CreateIndexes(this);
         }
 
         static MongoPersistenceProvider()
@@ -263,7 +262,7 @@ public async Task ClearSubscriptionToken(string eventSubscriptionId, string toke
 
         public void EnsureStoreExists()
         {
-
+            CreateIndexes(this);
         }
 
         public async Task<IEnumerable<EventSubscription>> GetSubscriptions(string eventName, string eventKey, DateTime asOf, CancellationToken cancellationToken = default)

test/WorkflowCore.Tests.MongoDB/MongoPersistenceProviderFixture.cs

@@ -1,5 +1,4 @@
 using MongoDB.Driver;
-using System;
 using WorkflowCore.Interface;
 using WorkflowCore.Persistence.MongoDB.Services;
 using WorkflowCore.UnitTests;
@@ -23,7 +22,9 @@ protected override IPersistenceProvider Subject
             {
                 var client = new MongoClient(MongoDockerSetup.ConnectionString);
                 var db = client.GetDatabase(nameof(MongoPersistenceProviderFixture));
-                return new MongoPersistenceProvider(db);
+                var provider = new MongoPersistenceProvider(db);
+                provider.EnsureStoreExists();
+                return provider;
             }
         }
     }