feat: include mongodb retry skip index creation parameter

When this parameter is included, the application will ignore the creation of its indexes. This makes the behavior explicit for the developer using the library.

Author: mauriciomoccelin

src/KafkaFlow.Retry.MongoDb/MongoDbDataProviderFactory.cs

@@ -23,7 +23,14 @@ public DataProviderCreationResult TryCreate(MongoDbSettings mongoDbSettings)
         {
             var mongoClient = new MongoClient(mongoDbSettings.ConnectionString);
             var dbContext = new DbContext(mongoDbSettings, mongoClient);
+
             DboConfigurations.TryAddIndexes(dbContext);
+
+            if (!mongoDbSettings.SkipIndexCreation)
+            {
+                DboConfigurations.TryAddIndexes(dbContext);
+            }
+
             return new DataProviderCreationResult(
                 null,
                 new RetryQueueDataProvider(

src/KafkaFlow.Retry.MongoDb/MongoDbSettings.cs

@@ -5,6 +5,8 @@ namespace KafkaFlow.Retry.MongoDb;
 [ExcludeFromCodeCoverage]
 public class MongoDbSettings
 {
+    public bool SkipIndexCreation { get; set; }
+
     public string ConnectionString { get; set; }
 
     public string DatabaseName { get; set; }

src/KafkaFlow.Retry.MongoDb/RetryDurableDefinitionBuilderExtension.cs

@@ -7,12 +7,14 @@ public static RetryDurableDefinitionBuilder WithMongoDbDataProvider(
         string connectionString,
         string databaseName,
         string mongoDbretryQueueCollectionName,
-        string mongoDbretryQueueItemCollectionName)
+        string mongoDbretryQueueItemCollectionName,
+        bool mongoDbretrySkipIndexCreation = false)
     {
         var dataProviderCreation = new MongoDbDataProviderFactory()
             .TryCreate(
                 new MongoDbSettings
                 {
+                    SkipIndexCreation = mongoDbretrySkipIndexCreation,
                     ConnectionString = connectionString,
                     DatabaseName = databaseName,
                     RetryQueueCollectionName = mongoDbretryQueueCollectionName,

tests/KafkaFlow.Retry.UnitTests/Repositories/MongoDb/RetryDurableDefinitionBuilderExtensionTests.cs

@@ -40,4 +40,23 @@ public void RetryDurableDefinitionBuilder_WithMongoDbDataProvider_Success()
         result.Should().NotBeNull();
         result.Should().BeOfType(typeof(RetryDurableDefinitionBuilder));
     }
+    
+    [Fact]
+    public void RetryDurableDefinitionBuilder_WithMongoDbDataProviderAndSkipIndexCreation_Success()
+    {
+        // Arrange
+        var builder = new RetryDurableDefinitionBuilder();
+
+        // Act
+        var result = builder.WithMongoDbDataProvider(
+            "mongodb://localhost:27017/KafkaFlowRetry?maxPoolSize=1000",
+            "Test",
+            "RetryQueueCollectionName",
+            "RetryQueueItemCollectionName",
+            true
+        );
+
+        result.Should().NotBeNull();
+        result.Should().BeOfType(typeof(RetryDurableDefinitionBuilder));
+    }
 }