- cleaned up code

Author: NinjaRocks

src/SourceFlow.Net.EntityFramework/CommandDbContext.cs

@@ -1,6 +1,5 @@
 #nullable enable
 
-using System;
 using Microsoft.EntityFrameworkCore;
 using SourceFlow.Stores.EntityFramework.Models;
 using SourceFlow.Stores.EntityFramework.Options;
@@ -51,4 +50,4 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
             }
         }
     }
-}
+}

src/SourceFlow.Net.EntityFramework/Examples/DatabaseProviderExamples.cs

@@ -36,10 +36,10 @@
 
 //            // Command store using SQLite
 //            var commandConnectionString = "DataSource=:memory:command.db";
-            
+
 //            // Entity store using a different SQLite database
 //            var entityConnectionString = "DataSource=:memory:entity.db";
-            
+
 //            // View model store using another SQLite database
 //            var viewModelConnectionString = "DataSource=:memory:viewmodel.db";
 
@@ -94,7 +94,7 @@
 //            // This is the original method that uses SQL Server
 //            services.AddSourceFlowEfStores(connectionString);
 //        }
-        
+
 //        /// <summary>
 //        /// Example: Using SQL Server with different connection strings per store
 //        /// </summary>
@@ -115,4 +115,4 @@
 //            );
 //        }
 //    }
-//}
+//}

src/SourceFlow.Net.EntityFramework/Examples/UsageExamples.cs

@@ -46,7 +46,7 @@
 
 //            // Reads connection strings from configuration:
 //            // ConnectionStrings:SourceFlow.Command
-//            // ConnectionStrings:SourceFlow.Entity  
+//            // ConnectionStrings:SourceFlow.Entity
 //            // ConnectionStrings:SourceFlow.ViewModel
 //            services.AddSourceFlowEfStores(configuration);
 //        }
@@ -73,4 +73,4 @@
 //        private static string GetEntityConnectionString() => "Server=localhost;Database=SourceFlow.Entities;Trusted_Connection=true;";
 //        private static string GetViewModelConnectionString() => "Server=localhost;Database=SourceFlow.ViewModels;Trusted_Connection=true;";
 //    }
-//}
+//}

src/SourceFlow.Net.EntityFramework/Extensions/ServiceCollectionExtensions.cs

@@ -1,10 +1,8 @@
 using System;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.DependencyInjection.Extensions;
-using Microsoft.EntityFrameworkCore;
-using Microsoft.Extensions.Options;
-using Microsoft.Extensions.Primitives;
 using SourceFlow.Stores.EntityFramework.Options;
 using SourceFlow.Stores.EntityFramework.Services;
 using SourceFlow.Stores.EntityFramework.Stores;
@@ -362,4 +360,4 @@ private static void ConfigureNamingConventions(SourceFlowEfOptions options)
             ViewModelDbContext.ConfigureNamingConvention(options.ViewModelTableNaming);
         }
     }
-}
+}

src/SourceFlow.Net.EntityFramework/Models/CommandRecord.cs

@@ -1,7 +1,6 @@
 using System;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Metadata.Builders;
-using SourceFlow.Messaging.Commands;
 
 namespace SourceFlow.Stores.EntityFramework.Models
 {
@@ -12,16 +11,18 @@ public class CommandRecord
         public int SequenceNo { get; set; }
         public string CommandName { get; set; } = string.Empty;
         public string CommandType { get; set; } = string.Empty;
-        
+
         // Store command data in relational fields instead of serialization
         public string PayloadType { get; set; } = string.Empty;
+
         public string PayloadData { get; set; } = string.Empty; // This can be JSON but for the payload itself
-        
+
         public string Metadata { get; set; } = string.Empty; // Store metadata as JSON
         public DateTime Timestamp { get; set; }
-        
+
         // Relational fields that can be indexed and queried
         public DateTime CreatedAt { get; set; } = DateTime.UtcNow;
+
         public DateTime UpdatedAt { get; set; } = DateTime.UtcNow;
     }
 
@@ -35,4 +36,4 @@ public void Configure(EntityTypeBuilder<CommandRecord> builder)
             builder.HasIndex(c => c.Timestamp);
         }
     }
-}
+}

src/SourceFlow.Net.EntityFramework/Options/ObservabilityOptions.cs

@@ -1,5 +1,3 @@
-using System;
-
 namespace SourceFlow.Stores.EntityFramework.Options
 {
     /// <summary>

src/SourceFlow.Net.EntityFramework/Options/ResilienceOptions.cs

@@ -1,5 +1,3 @@
-using System;
-
 namespace SourceFlow.Stores.EntityFramework.Options
 {
     /// <summary>

src/SourceFlow.Net.EntityFramework/Options/SourceFlowEfOptions.cs

@@ -1,7 +1,6 @@
 #nullable enable
 
 using System;
-using System.ComponentModel.DataAnnotations;
 
 namespace SourceFlow.Stores.EntityFramework.Options
 {
@@ -14,17 +13,17 @@ public class SourceFlowEfOptions
         /// Connection string for command store
         /// </summary>
         public string? CommandConnectionString { get; set; }
-        
+
         /// <summary>
         /// Connection string for entity store
         /// </summary>
         public string? EntityConnectionString { get; set; }
-        
+
         /// <summary>
         /// Connection string for view model store
         /// </summary>
         public string? ViewModelConnectionString { get; set; }
-        
+
         /// <summary>
         /// If true, a single connection string will be used for all stores
         /// </summary>
@@ -64,17 +63,17 @@ public string GetConnectionString(StoreType storeType)
         {
             return storeType switch
             {
-                StoreType.Command => CommandConnectionString ?? DefaultConnectionString 
+                StoreType.Command => CommandConnectionString ?? DefaultConnectionString
                     ?? throw new InvalidOperationException("Command connection string not configured"),
-                StoreType.Entity => EntityConnectionString ?? DefaultConnectionString 
+                StoreType.Entity => EntityConnectionString ?? DefaultConnectionString
                     ?? throw new InvalidOperationException("Entity connection string not configured"),
-                StoreType.ViewModel => ViewModelConnectionString ?? DefaultConnectionString 
+                StoreType.ViewModel => ViewModelConnectionString ?? DefaultConnectionString
                     ?? throw new InvalidOperationException("ViewModel connection string not configured"),
                 _ => throw new ArgumentException($"Unknown store type: {storeType}", nameof(storeType))
             };
         }
     }
-    
+
     /// <summary>
     /// Enum representing different store types
     /// </summary>
@@ -84,4 +83,4 @@ public enum StoreType
         Entity,
         ViewModel
     }
-}
+}

src/SourceFlow.Net.EntityFramework/Services/DatabaseTelemetryService.cs

@@ -20,6 +20,7 @@ public class DatabaseTelemetryService : IDatabaseTelemetryService
 
         // Counters
         private readonly Counter<long>? _commandsAppended;
+
         private readonly Counter<long>? _commandsLoaded;
         private readonly Counter<long>? _entitiesPersisted;
         private readonly Counter<long>? _viewModelsPersisted;

src/SourceFlow.Net.EntityFramework/Stores/EfCommandStore.cs

@@ -7,7 +7,6 @@
 using SourceFlow.Stores.EntityFramework.Models;
 using SourceFlow.Stores.EntityFramework.Services;
 
-
 namespace SourceFlow.Stores.EntityFramework.Stores
 {
     public class EfCommandStore : ICommandStore
@@ -105,4 +104,4 @@ public async Task<IEnumerable<CommandData>> Load(int entityId)
                 });
         }
     }
-}
+}