Fixed usage of CreateIndexes for mongo to avoid database connection already opening during ioc

agentschmitt · agentschmitt · commit da17e9ee7ea1 · 2024-08-14T18:08:44.000+02:00
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)

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,6 @@ public class MongoPersistenceProvider : IPersistenceProvider`
`23`	`23`	`public MongoPersistenceProvider(IMongoDatabase database)`
`24`	`24`	`{`
`25`	`25`	`_database = database;`
`26`		`- CreateIndexes(this);`
`27`	`26`	`}`
`28`	`27`
`29`	`28`	`static MongoPersistenceProvider()`
`@@ -263,7 +262,7 @@ public async Task ClearSubscriptionToken(string eventSubscriptionId, string toke`
`263`	`262`
`264`	`263`	`public void EnsureStoreExists()`
`265`	`264`	`{`
`266`		`-`
	`265`	`+ CreateIndexes(this);`
`267`	`266`	`}`
`268`	`267`
`269`	`268`	`public async Task<IEnumerable<EventSubscription>> GetSubscriptions(string eventName, string eventKey, DateTime asOf, CancellationToken cancellationToken = default)`