Address code review feedback: fix logger DI and remove unnecessary null-forgiving operator

Co-authored-by: JeanMarcMbouma <16613177+JeanMarcMbouma@users.noreply.github.com>

Author: Copilot

src/BbQ.Events.PostgreSql/Configuration/PostgreSqlSchemaInitializerHostedService.cs

@@ -10,27 +10,27 @@ namespace BbQ.Events.PostgreSql.Configuration;
 internal class PostgreSqlSchemaInitializerHostedService : IHostedService
 {
     private readonly ISchemaInitializer _schemaInitializer;
-    private readonly ILogger<PostgreSqlSchemaInitializerHostedService>? _logger;
+    private readonly ILogger<PostgreSqlSchemaInitializerHostedService> _logger;
 
     public PostgreSqlSchemaInitializerHostedService(
         ISchemaInitializer schemaInitializer,
-        ILogger<PostgreSqlSchemaInitializerHostedService>? logger = null)
+        ILogger<PostgreSqlSchemaInitializerHostedService> logger)
     {
         _schemaInitializer = schemaInitializer ?? throw new ArgumentNullException(nameof(schemaInitializer));
-        _logger = logger;
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
     }
 
     public async Task StartAsync(CancellationToken cancellationToken)
     {
         try
         {
-            _logger?.LogInformation("Ensuring PostgreSQL event store schema exists...");
+            _logger.LogInformation("Ensuring PostgreSQL event store schema exists...");
             await _schemaInitializer.EnsureSchemaAsync(cancellationToken);
-            _logger?.LogInformation("PostgreSQL event store schema initialized successfully");
+            _logger.LogInformation("PostgreSQL event store schema initialized successfully");
         }
         catch (Exception ex)
         {
-            _logger?.LogError(ex, "Failed to initialize PostgreSQL event store schema");
+            _logger.LogError(ex, "Failed to initialize PostgreSQL event store schema");
             throw;
         }
     }

src/BbQ.Events.SqlServer/Configuration/SqlServerSchemaInitializerHostedService.cs

@@ -10,27 +10,27 @@ namespace BbQ.Events.SqlServer.Configuration;
 internal class SqlServerSchemaInitializerHostedService : IHostedService
 {
     private readonly ISchemaInitializer _schemaInitializer;
-    private readonly ILogger<SqlServerSchemaInitializerHostedService>? _logger;
+    private readonly ILogger<SqlServerSchemaInitializerHostedService> _logger;
 
     public SqlServerSchemaInitializerHostedService(
         ISchemaInitializer schemaInitializer,
-        ILogger<SqlServerSchemaInitializerHostedService>? logger = null)
+        ILogger<SqlServerSchemaInitializerHostedService> logger)
     {
         _schemaInitializer = schemaInitializer ?? throw new ArgumentNullException(nameof(schemaInitializer));
-        _logger = logger;
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
     }
 
     public async Task StartAsync(CancellationToken cancellationToken)
     {
         try
         {
-            _logger?.LogInformation("Ensuring SQL Server event store schema exists...");
+            _logger.LogInformation("Ensuring SQL Server event store schema exists...");
             await _schemaInitializer.EnsureSchemaAsync(cancellationToken);
-            _logger?.LogInformation("SQL Server event store schema initialized successfully");
+            _logger.LogInformation("SQL Server event store schema initialized successfully");
         }
         catch (Exception ex)
         {
-            _logger?.LogError(ex, "Failed to initialize SQL Server event store schema");
+            _logger.LogError(ex, "Failed to initialize SQL Server event store schema");
             throw;
         }
     }

src/BbQ.Events.SqlServer/Schema/SqlServerSchemaInitializer.cs

@@ -56,7 +56,7 @@ FROM INFORMATION_SCHEMA.TABLES
         await using var checkCommand = new SqlCommand(checkSql, connection);
         checkCommand.Parameters.AddWithValue("@TableName", tableName);
 
-        var exists = (int)(await checkCommand.ExecuteScalarAsync(cancellationToken))! > 0;
+        var exists = (int)(await checkCommand.ExecuteScalarAsync(cancellationToken)) > 0;
 
         if (exists)
         {