Merge pull request #1287 from SamhammerAG/fix-mongo

Fixed usage of CreateIndexes for mongo
danielgerlag · Nov 15, 2024 · 746bb65 · 746bb65
2 parents db61af3 + 0b51d8e
commit 746bb65
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/providers/WorkflowCore.Persistence.MongoDB/Services/MongoPersistenceProvider.cs b/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)

diff --git a/test/WorkflowCore.Tests.MongoDB/MongoPersistenceProviderFixture.cs b/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;
             }
         }
     }