Fixed tests related to Marten v8 migration

Author: oskardudycz

Core.ElasticSearch/Config.cs

@@ -7,8 +7,8 @@ namespace Core.ElasticSearch;
 
 public class ElasticSearchConfig
 {
-    public string Url { get; set; } = default!;
-    public string DefaultIndex { get; set; } = default!;
+    public string Url { get; set; } = null!;
+    public string DefaultIndex { get; set; } = null!;
 }
 
 public static class ElasticSearchConfigExtensions

Core.EntityFramework.Tests/EntityFrameworkProjectionTests.cs

@@ -45,8 +45,8 @@ public async Task Applies_Works_Separately()
     {
         var projection = new ShoppingCartProjection { DbContext = context };
 
-        var cartId = Guid.NewGuid();
-        var clientId = Guid.NewGuid();
+        var cartId = Guid.CreateVersion7();
+        var clientId = Guid.CreateVersion7();
 
         await projection.Handle([EventEnvelope.From(new Opened(cartId, clientId))], CancellationToken.None);
         await context.SaveChangesAsync();
@@ -75,8 +75,8 @@ public async Task Applies_Works_In_Batch()
     {
         var projection = new ShoppingCartProjection { DbContext = context };
 
-        var cartId = Guid.NewGuid();
-        var clientId = Guid.NewGuid();
+        var cartId = Guid.CreateVersion7();
+        var clientId = Guid.CreateVersion7();
 
         await projection.Handle([
             EventEnvelope.From(new Opened(cartId, clientId)),
@@ -96,8 +96,8 @@ public async Task Applies_Works_In_Batch_With_AddAndDeleteOnTheSameRecord()
     {
         var projection = new ShoppingCartProjection { DbContext = context };
 
-        var cartId = Guid.NewGuid();
-        var clientId = Guid.NewGuid();
+        var cartId = Guid.CreateVersion7();
+        var clientId = Guid.CreateVersion7();
 
         await projection.Handle([
             EventEnvelope.From(new Opened(cartId, clientId)),
@@ -112,7 +112,7 @@ await projection.Handle([
     [Fact]
     public async Task SmokeTest()
     {
-        var entity = new ShoppingCart { Id = Guid.NewGuid(), ProductCount = 2, ClientId = Guid.NewGuid() };
+        var entity = new ShoppingCart { Id = Guid.CreateVersion7(), ProductCount = 2, ClientId = Guid.CreateVersion7() };
         context.ShoppingCarts.Add(entity);
         await context.SaveChangesAsync();
 

Core.EntityFramework.Tests/Fixtures/EfCorePostgresContainerFixture.cs

@@ -8,7 +8,7 @@ public class EfCorePostgresContainerFixture<TContext>: IAsyncLifetime where TCon
 {
     private readonly PostgresContainerFixture postgresContainerFixture = new();
 
-    public TContext DbContext { get; private set; } = default!;
+    public TContext DbContext { get; private set; } = null!;
 
     public async Task InitializeAsync()
     {

Core.EntityFramework.Tests/TestDbContext.cs

@@ -13,7 +13,7 @@ public class ShoppingCart
 
 public class TestDbContext(DbContextOptions<TestDbContext> options): DbContext(options)
 {
-    public DbSet<ShoppingCart> ShoppingCarts { get; set; } = default!;
+    public DbSet<ShoppingCart> ShoppingCarts { get; set; } = null!;
 
     protected override void OnModelCreating(ModelBuilder modelBuilder) =>
         modelBuilder.Entity<ShoppingCart>();

Core.EntityFramework/Projections/EntityFrameworkProjection.cs

@@ -10,7 +10,7 @@ namespace Core.EntityFramework.Projections;
 public class EntityFrameworkProjection<TDbContext>: IEventBatchHandler
     where TDbContext : DbContext
 {
-    public TDbContext DbContext { protected get; set; } = default!;
+    public TDbContext DbContext { protected get; set; } = null!;
     public IAsyncPolicy RetryPolicy { protected get; set; } = Policy.NoOpAsync();
 
     private readonly HashSet<Type> handledEventTypes = [];
@@ -47,8 +47,8 @@ private record ProjectEvent(
     );
 
     private readonly Dictionary<Type, ProjectEvent> projectors = new();
-    private Expression<Func<TView, TId>> viewIdExpression = default!;
-    private Func<TView, TId> viewId = default!;
+    private Expression<Func<TView, TId>> viewIdExpression = null!;
+    private Func<TView, TId> viewId = null!;
 
     public void ViewId(Expression<Func<TView, TId>> id)
     {

Core.EventStoreDB.Tests/Commands/EventStoreDBAsyncCommandBusTests.cs

@@ -70,7 +70,7 @@ public EventStoreDBAsyncCommandBusTests()
     public async Task CommandIsStoredInEventStoreDBAndForwardedToCommandHandler()
     {
         // Given
-        var userId = Guid.NewGuid();
+        var userId = Guid.CreateVersion7();
         var command = new AddUser(userId);
 
         // When
@@ -91,7 +91,7 @@ public async Task CommandIsStoredInEventStoreDBAndForwardedToCommandHandler()
     }
 }
 
-public record AddUser(Guid UserId, string? Sth = default);
+public record AddUser(Guid UserId, string? Sth = null);
 
 internal class AddUserCommandHandler(List<Guid> userIds): ICommandHandler<AddUser>
 {

Core.EventStoreDB.Tests/Subscriptions/Checkpoints/PostgresSubscriptionCheckpointRepositoryTests.cs

@@ -11,7 +11,7 @@ namespace Core.EventStoreDB.Tests.Subscriptions.Checkpoints;
 public class PostgresSubscriptionCheckpointRepositoryTests(PostgresContainerFixture fixture)
     : IClassFixture<PostgresContainerFixture>
 {
-    private readonly string subscriptionId = Guid.NewGuid().ToString("N");
+    private readonly string subscriptionId = Guid.CreateVersion7().ToString("N");
 
     [Fact]
     public async Task Store_InitialInsert_Success()

Core.EventStoreDB/Config.cs

@@ -14,7 +14,7 @@ namespace Core.EventStoreDB;
 
 public class EventStoreDBConfig
 {
-    public string ConnectionString { get; set; } = default!;
+    public string ConnectionString { get; set; } = null!;
 }
 
 public record EventStoreDBOptions(

Core.EventStoreDB/Subscriptions/EventStoreDBSubscriptionToAll.cs

@@ -48,9 +48,9 @@ public enum ProcessingStatus
 
     public record EventBatch(string SubscriptionId, ResolvedEvent[] Events);
 
-    public EventStoreDBSubscriptionToAllOptions Options { get; set; } = default!;
+    public EventStoreDBSubscriptionToAllOptions Options { get; set; } = null!;
 
-    public Func<IServiceProvider, IEventBatchHandler[]> GetHandlers { get; set; } = default!;
+    public Func<IServiceProvider, IEventBatchHandler[]> GetHandlers { get; set; } = null!;
 
     public ProcessingStatus Status = ProcessingStatus.NotStarted;
 

Core.Kafka/Consumers/KafkaConsumerConfig.cs

@@ -6,8 +6,8 @@ namespace Core.Kafka.Consumers;
 
 public class KafkaConsumerConfig
 {
-    public ConsumerConfig ConsumerConfig { get; set; } = default!;
-    public string[] Topics { get; set; } = default!;
+    public ConsumerConfig ConsumerConfig { get; set; } = null!;
+    public string[] Topics { get; set; } = null!;
 
     public bool IgnoreDeserializationErrors { get; set; } =  true;
 }