Add OutboxRecord ClassMap

src/MinimalDomainEvents.Outbox.MongoDb/IOutboxDispatcherBuilderExtensions.cs

@@ -1,19 +1,31 @@
 using Microsoft.Extensions.DependencyInjection;
 using MinimalDomainEvents.Outbox.Abstractions;
+using MongoDB.Bson.Serialization;
 using MongoDB.Driver;
 
 namespace MinimalDomainEvents.Outbox.MongoDb;
 public static class IOutboxDispatcherBuilderExtensions
 {
     public static IOutboxDispatcherBuilder AddMongo(this IOutboxDispatcherBuilder builder, MongoClient mongoClient)
     {
+        TryRegisterOutboxRecordClassMap();
         builder.Services.AddScoped<IPersistOutboxRecords>(sp => ActivatorUtilities.CreateInstance<MongoDbDomainEventPersister>(sp, builder.OutboxSettings, mongoClient));
         return builder;
     }
 
     public static IOutboxDispatcherBuilder AddMongo(this IOutboxDispatcherBuilder builder, Func<IServiceProvider, MongoClient> mongoClientFactory)
     {
+        TryRegisterOutboxRecordClassMap();
         builder.Services.AddScoped<IPersistOutboxRecords>(sp => ActivatorUtilities.CreateInstance<MongoDbDomainEventPersister>(sp, builder.OutboxSettings, mongoClientFactory(sp)));
         return builder;
     }
+
+    private static bool TryRegisterOutboxRecordClassMap()
+    {
+        return BsonClassMap.TryRegisterClassMap<OutboxRecord>(cm =>
+        {
+            cm.AutoMap();
+            cm.SetIgnoreExtraElements(true);
+        });
+    }
 }

test/MinimalDomainEvents.Outbox.MongoDb.UnitTests/IOutboxDispatcherBuilderExtensionsTests.cs → test/MinimalDomainEvents.Outbox.MongoDb.UnitTests/OutboxBuilderExtensionsTests.cs

@@ -8,10 +8,10 @@
 namespace MinimalDomainEvents.Outbox.MongoDb.UnitTests;
 
 [Collection("MongoDb Integration")]
-public class IOutboxDispatcherBuilderExtensionsTests(MongoContainerFixture fixture)
+public class OutboxBuilderExtensionsTests(MongoContainerFixture fixture)
 {
     [Fact]
-    public async Task WithDatabase_AfterUseMongo_StillWorks()
+    public async Task WithDatabase_After_UseMongo_Works()
     {
         var mongoClient = new MongoClient(fixture.ConnectionString);
         IServiceCollection serviceCollection = new ServiceCollection();