feat(mongodb): Set Id and Verify storage

With MongoDB we must set the Id manually.  A single item with a null Id can be successfully inserted, as null is a valid Id value.  But trying in insert it a second time results in a duplicate key error.

Author: jfoshee

.vscode/settings.json

@@ -1,7 +1,9 @@
 {
     "cSpell.words": [
+        "Bson",
         "cref",
         "inheritdoc",
-        "paramref"
+        "paramref",
+        "Xunit"
     ]
 }

IntBasis.DocumentOriented.MongoDB.Tests/IntBasis.DocumentOriented.MongoDB.Tests.csproj

@@ -9,6 +9,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="FluentAssertions" Version="6.7.0" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.2.0" />
     <PackageReference Include="xunit" Version="2.4.1" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">

IntBasis.DocumentOriented.MongoDB.Tests/MongoDbDocumentStorageTest.cs

@@ -1,3 +1,5 @@
+using MongoDB.Driver;
+
 namespace IntBasis.DocumentOriented.MongoDB.Tests;
 
 class Category : IDocumentEntity
@@ -19,6 +21,13 @@ public async Task Storage()
         var subject = new MongoDbDocumentStorage();
         var entity = new Category("test category");
         await subject.Store(entity);
-        // entity.Id.Should().NotBeNull();
+        entity.Id.Should().NotBeNull();
+
+        var mongoDatabase = MongoDbDocumentStorage.OpenTestDatabase();
+        var collectionName = "entities";
+        var collection = mongoDatabase.GetCollection<Category>(collectionName);
+        var found = collection.Find<Category>(doc => doc.Id == entity.Id).FirstOrDefault();
+        found.Id.Should().Be(entity.Id);
+        found.Name.Should().Be("test category");
     }
 }

IntBasis.DocumentOriented.MongoDB.Tests/Usings.cs

@@ -1 +1,2 @@
-global using Xunit;
+global using Xunit;
+global using FluentAssertions;

IntBasis.DocumentOriented.MongoDB/IntBasis.DocumentOriented.MongoDB.csproj

@@ -17,4 +17,7 @@
     <PackageReference Include="MongoDB.Driver" Version="2.16.1" />
   </ItemGroup>
 
+  <ItemGroup>
+    <InternalsVisibleTo Include="$(AssemblyName).Tests" />
+  </ItemGroup>
 </Project>

IntBasis.DocumentOriented.MongoDB/MongoDbDocumentStorage.cs

@@ -1,4 +1,5 @@
-using MongoDB.Driver;
+using MongoDB.Bson;
+using MongoDB.Driver;
 
 namespace IntBasis.DocumentOriented.MongoDB;
 
@@ -12,13 +13,20 @@ public Task<T> Retrieve<T>(string id) where T : IDocumentEntity
 
     /// <inheritdoc/>
     public async Task Store<T>(T entity) where T : IDocumentEntity
+    {
+        IMongoDatabase database = OpenTestDatabase();
+        var collectionName = "entities";
+        var collection = database.GetCollection<T>(collectionName);
+        entity.Id = ObjectId.GenerateNewId().ToString();
+        await collection.InsertOneAsync(entity);
+    }
+
+    internal static IMongoDatabase OpenTestDatabase()
     {
         var connectionString = "mongodb://localhost:27017";
         var client = new MongoClient(connectionString);
         var databaseName = "test";
         var database = client.GetDatabase(databaseName);
-        var collectionName = "entities";
-        var collection = database.GetCollection<T>(collectionName);
-        await collection.InsertOneAsync(entity);
+        return database;
     }
 }