Commit everything.

Author: SebastianStehle

events/Squidex.Events.Mongo/MongoEventStore.cs

@@ -49,7 +49,7 @@ public partial class MongoEventStore(
     public async Task InitializeAsync(
         CancellationToken ct)
     {
-        var versionInfo = await MongoVersionInfo.DetectAsync(database, ct);
+        var versionInfo = await MongoVersionInfo.DetectAsync(database, options.Value.Derivate, ct);
 
         queryStrategy = versionInfo.Dervivate == MongoDerivate.MongoDB ?
             new QueryByTimestamp() :

events/Squidex.Events.Mongo/MongoVersionInfo.cs

@@ -32,26 +32,6 @@ public static async Task<MongoVersionInfo> DetectAsync(IMongoDatabase database,
 
         int.TryParse(versionMajor, NumberStyles.Integer, CultureInfo.InvariantCulture, out int version);
 
-        var serverString = document.ToString().ToLowerInvariant();
-        bool Contains(string expected)
-        {
-            return serverString.Contains(expected, StringComparison.OrdinalIgnoreCase);
-        }
-
-        var derivate = MongoDerivate.MongoDB;
-        if (Contains("ferret"))
-        {
-            derivate = MongoDerivate.FerretDB;
-        }
-        else if (Contains("cosmos"))
-        {
-            derivate = MongoDerivate.CosmosDB;
-        }
-        else if (Contains("amazon") || Contains("docdb") || Contains("documentdb"))
-        {
-            derivate = MongoDerivate.DocumentDB;
-        }
-
         return new MongoVersionInfo(derivate, version);
     }
 }

events/Squidex.Events.Tests/MongoEventStoreDocumentDbTests.cs

@@ -10,6 +10,7 @@
 using Microsoft.Extensions.DependencyInjection;
 using MongoDB.Bson;
 using MongoDB.Driver;
+using Squidex.Events.Mongo;
 using Squidex.Hosting;
 using TestHelpers;
 
@@ -52,7 +53,7 @@ public async Task InitializeAsync()
             {
                 options.PollingInterval = TimeSpan.FromSeconds(0.1);
                 options.UseChangeStreams = true;
-                options.Derivate = Mongo.MongoDerivate.DocumentDB;
+                options.Derivate = MongoDerivate.DocumentDB;
             }).Services;
 
         Services = serviceCollection.BuildServiceProvider();