Complete index

Author: glucaci

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

@@ -95,7 +95,8 @@ static void CreateIndexes(MongoPersistenceProvider instance)
                 instance.WorkflowInstances.Indexes.CreateOne(new CreateIndexModel<WorkflowInstance>(
                     Builders<WorkflowInstance>.IndexKeys
                         .Ascending(x => x.NextExecution)
-                        .Ascending(x => x.Status),
+                        .Ascending(x => x.Status)
+                        .Ascending(x => x.Id),
                     new CreateIndexOptions {Background = true, Name = "idx_nextExec_v2"}));
 
                 instance.Events.Indexes.CreateOne(new CreateIndexModel<Event>(
@@ -111,17 +112,9 @@ static void CreateIndexes(MongoPersistenceProvider instance)
 
                 instance.EventSubscriptions.Indexes.CreateOne(new CreateIndexModel<EventSubscription>(
                     Builders<EventSubscription>.IndexKeys
-                        .Ascending(x => x.EventKey)
-                        .Ascending(x => x.EventName),
-                    new CreateIndexOptions { Background = true, Name = "idx_namekey_v2" }));
-                
-                instance.EventSubscriptions.Indexes.CreateOne(new CreateIndexModel<EventSubscription>(
-                    Builders<EventSubscription>.IndexKeys.Ascending(x => x.SubscribeAsOf),
-                    new CreateIndexOptions { Background = true, Name = "idx_subscribe" }));
-                
-                instance.EventSubscriptions.Indexes.CreateOne(new CreateIndexModel<EventSubscription>(
-                    Builders<EventSubscription>.IndexKeys.Ascending(x => x.ExternalToken),
-                    new CreateIndexOptions { Background = true, Name = "idx_token" }));
+                        .Ascending(x => x.EventName)
+                        .Ascending(x => x.EventKey),
+                    new CreateIndexOptions { Background = true, Name = "idx_namekey" }));
 
                 instance.ScheduledCommands.Indexes.CreateOne(new CreateIndexModel<ScheduledCommand>(
                     Builders<ScheduledCommand>.IndexKeys

test/WorkflowCore.Tests.MongoDB/MongoDockerSetup.cs

@@ -19,8 +19,6 @@ public MongoDockerSetup()
         public async Task InitializeAsync()
         {
             await _mongoResource.InitializeAsync();
-            var command = new BsonDocument { { "setParameter", 1 }, { "notablescan", 1 } };
-            _mongoResource.Client.GetDatabase("admin").RunCommand<BsonDocument>(command);
             ConnectionString = _mongoResource.ConnectionString;
         }