- Fix pipeline issues

NinjaRocks · NinjaRocks · commit 96ef664d29e4 · 2025-11-29T09:59:19.000Z
diff --git a/.github/linters/.jscpd.json b/.github/linters/.jscpd.json
@@ -0,0 +1,18 @@
+{
+  "threshold": 7,
+  "reporters": ["console"],
+  "ignore": [
+    "**/*.min.js",
+    "**/node_modules/**",
+    "**/bin/**",
+    "**/obj/**",
+    "**/.git/**"
+  ],
+  "format": [
+    "csharp"
+  ],
+  "minLines": 5,
+  "minTokens": 100,
+  "blame": false,
+  "silent": false
+}
diff --git a/.jscpd.json b/.jscpd.json
@@ -1,5 +1,5 @@
 {
-  "threshold": 15,
+  "threshold": 7,
   "reporters": ["console"],
   "ignore": [
     "**/*.min.js",
diff --git a/src/SourceFlow.Net.EntityFramework/EntityDbContext.cs b/src/SourceFlow.Net.EntityFramework/EntityDbContext.cs
@@ -74,7 +74,7 @@ public static IEnumerable<Type> GetRegisteredTypes()
                 {
                     var assemblyTypes = assembly.GetTypes()
                         .Where(t => t.IsClass && !t.IsAbstract &&
-                                   t.GetInterfaces().Any(i => i.Name == "IEntity"));
+                            t.GetInterfaces().Any(i => i.Name == "IEntity"));
                     foreach (var type in assemblyTypes)
                     {
                         types.Add(type);
@@ -113,7 +113,7 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                 {
                     var types = assembly.GetTypes()
                         .Where(t => t.IsClass && !t.IsAbstract &&
-                                   t.GetInterfaces().Any(i => i.Name == "IEntity"));
+                            t.GetInterfaces().Any(i => i.Name == "IEntity"));
                     foreach (var type in types)
                     {
                         entityTypes.Add(type);
@@ -125,15 +125,15 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
             // Auto-discover from loaded assemblies (fallback)
             var discoveredTypes = AppDomain.CurrentDomain.GetAssemblies()
                 .Where(a => !a.IsDynamic && !a.FullName?.StartsWith("Microsoft.") == true
-                           && !a.FullName?.StartsWith("System.") == true
-                           && !a.FullName?.StartsWith("netstandard") == true)
+                    && !a.FullName?.StartsWith("System.") == true
+                    && !a.FullName?.StartsWith("netstandard") == true)
                 .SelectMany(a =>
                 {
                     try { return a.GetTypes(); }
                     catch { return Enumerable.Empty<Type>(); }
                 })
                 .Where(t => t.IsClass && !t.IsAbstract &&
-                           t.GetInterfaces().Any(i => i.Name == "IEntity"));
+                    t.GetInterfaces().Any(i => i.Name == "IEntity"));
 
             foreach (var type in discoveredTypes)
             {
diff --git a/src/SourceFlow.Net.EntityFramework/Migrations/DbContextMigrationHelper.cs b/src/SourceFlow.Net.EntityFramework/Migrations/DbContextMigrationHelper.cs
@@ -101,7 +101,7 @@ PRIMARY KEY (""Id"")
                 return null; // Skip complex types
 
             var nullable = Nullable.GetUnderlyingType(property.PropertyType) != null ||
-                          (!propertyType.IsValueType && columnName != "Id");
+                (!propertyType.IsValueType && columnName != "Id");
             var nullConstraint = nullable ? "" : " NOT NULL";
 
             return $@"""{columnName}"" {sqlType}{nullConstraint}";
diff --git a/src/SourceFlow.Net.EntityFramework/Options/TableNamingConvention.cs b/src/SourceFlow.Net.EntityFramework/Options/TableNamingConvention.cs
@@ -124,10 +124,10 @@ private static string PluralizeName(string input)
                 return input.Substring(0, input.Length - 1) + "ies";
             }
             else if (input.EndsWith("s", StringComparison.OrdinalIgnoreCase) ||
-                     input.EndsWith("x", StringComparison.OrdinalIgnoreCase) ||
-                     input.EndsWith("z", StringComparison.OrdinalIgnoreCase) ||
-                     input.EndsWith("ch", StringComparison.OrdinalIgnoreCase) ||
-                     input.EndsWith("sh", StringComparison.OrdinalIgnoreCase))
+                input.EndsWith("x", StringComparison.OrdinalIgnoreCase) ||
+                input.EndsWith("z", StringComparison.OrdinalIgnoreCase) ||
+                input.EndsWith("ch", StringComparison.OrdinalIgnoreCase) ||
+                input.EndsWith("sh", StringComparison.OrdinalIgnoreCase))
             {
                 // class -> classes, box -> boxes
                 return input + "es";
diff --git a/src/SourceFlow.Net.EntityFramework/Services/DatabaseResiliencePolicy.cs b/src/SourceFlow.Net.EntityFramework/Services/DatabaseResiliencePolicy.cs
@@ -80,10 +80,10 @@ private ResiliencePipeline BuildResiliencePipeline(ResilienceOptions options)
                 {
                     MaxRetryAttempts = options.Retry.MaxRetryAttempts,
                     ShouldHandle = new PredicateBuilder().Handle<DbUpdateException>()
-                                                          .Handle<TimeoutException>()
-                                                          .Handle<InvalidOperationException>(ex =>
-                                                              ex.Message.Contains("connection", StringComparison.OrdinalIgnoreCase) ||
-                                                              ex.Message.Contains("timeout", StringComparison.OrdinalIgnoreCase)),
+                        .Handle<TimeoutException>()
+                        .Handle<InvalidOperationException>(ex =>
+                            ex.Message.Contains("connection", StringComparison.OrdinalIgnoreCase) ||
+                            ex.Message.Contains("timeout", StringComparison.OrdinalIgnoreCase)),
                     BackoffType = options.Retry.UseExponentialBackoff
                         ? DelayBackoffType.Exponential
                         : DelayBackoffType.Constant,
@@ -104,10 +104,10 @@ private ResiliencePipeline BuildResiliencePipeline(ResilienceOptions options)
                     MinimumThroughput = options.CircuitBreaker.FailureThreshold,
                     BreakDuration = TimeSpan.FromMilliseconds(options.CircuitBreaker.BreakDurationMs),
                     ShouldHandle = new PredicateBuilder().Handle<DbUpdateException>()
-                                                          .Handle<TimeoutException>()
-                                                          .Handle<InvalidOperationException>(ex =>
-                                                              ex.Message.Contains("connection", StringComparison.OrdinalIgnoreCase) ||
-                                                              ex.Message.Contains("timeout", StringComparison.OrdinalIgnoreCase))
+                        .Handle<TimeoutException>()
+                        .Handle<InvalidOperationException>(ex =>
+                            ex.Message.Contains("connection", StringComparison.OrdinalIgnoreCase) ||
+                            ex.Message.Contains("timeout", StringComparison.OrdinalIgnoreCase))
                 };
 
                 pipelineBuilder.AddCircuitBreaker(circuitBreakerOptions);
diff --git a/src/SourceFlow.Net.EntityFramework/ViewModelDbContext.cs b/src/SourceFlow.Net.EntityFramework/ViewModelDbContext.cs
@@ -74,7 +74,7 @@ public static IEnumerable<Type> GetRegisteredTypes()
                 {
                     var assemblyTypes = assembly.GetTypes()
                         .Where(t => t.IsClass && !t.IsAbstract &&
-                                   t.GetInterfaces().Any(i => i.Name == "IViewModel"));
+                            t.GetInterfaces().Any(i => i.Name == "IViewModel"));
                     foreach (var type in assemblyTypes)
                     {
                         types.Add(type);
@@ -113,7 +113,7 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                 {
                     var types = assembly.GetTypes()
                         .Where(t => t.IsClass && !t.IsAbstract &&
-                                   t.GetInterfaces().Any(i => i.Name == "IViewModel"));
+                            t.GetInterfaces().Any(i => i.Name == "IViewModel"));
                     foreach (var type in types)
                     {
                         viewModelTypes.Add(type);
@@ -125,15 +125,15 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
             // Auto-discover from loaded assemblies (fallback)
             var discoveredTypes = AppDomain.CurrentDomain.GetAssemblies()
                 .Where(a => !a.IsDynamic && !a.FullName?.StartsWith("Microsoft.") == true
-                           && !a.FullName?.StartsWith("System.") == true
-                           && !a.FullName?.StartsWith("netstandard") == true)
+                    && !a.FullName?.StartsWith("System.") == true
+                    && !a.FullName?.StartsWith("netstandard") == true)
                 .SelectMany(a =>
                 {
                     try { return a.GetTypes(); }
                     catch { return Enumerable.Empty<Type>(); }
                 })
                 .Where(t => t.IsClass && !t.IsAbstract &&
-                           t.GetInterfaces().Any(i => i.Name == "IViewModel"));
+                    t.GetInterfaces().Any(i => i.Name == "IViewModel"));
 
             foreach (var type in discoveredTypes)
             {
diff --git a/src/SourceFlow/Aggregate/EventSubscriber.cs b/src/SourceFlow/Aggregate/EventSubscriber.cs
@@ -56,7 +56,7 @@ public Task Subscribe<TEvent>(TEvent @event) where TEvent : IEvent
                 tasks.Add(eventSubscriber.On(@event));
 
                 logger?.LogInformation("Action=Event_Disptcher_Aggregate, Event={Event}, Aggregate={Aggregate}",
-                       typeof(TEvent).Name, aggregate.GetType().Name);
+                    typeof(TEvent).Name, aggregate.GetType().Name);
             }
 
             return Task.WhenAll(tasks);
diff --git a/src/SourceFlow/IocExtensions.cs b/src/SourceFlow/IocExtensions.cs
@@ -163,23 +163,23 @@ private static IEnumerable<Type> GetImplementedTypes(Type interfaceType, Assembl
                     {
                         return a.GetTypes()
                             .Where(t => interfaceType.IsAssignableFrom(t) &&
-                                       t.IsClass &&
-                                       !t.IsAbstract &&
-                                       t.IsPublic &&
-                                       !t.IsGenericType &&
-                                       !t.ContainsGenericParameters);
+                                t.IsClass &&
+                                !t.IsAbstract &&
+                                t.IsPublic &&
+                                !t.IsGenericType &&
+                                !t.ContainsGenericParameters);
                     }
                     catch (ReflectionTypeLoadException)
                     {
                         // On cases where some types can't be loaded
                         return a.GetTypes()
                             .Where(t => t != null &&
-                                       interfaceType.IsAssignableFrom(t) &&
-                                       t.IsClass &&
-                                       !t.IsAbstract &&
-                                       t.IsPublic &&
-                                       !t.IsGenericType &&
-                                       !t.ContainsGenericParameters);
+                                interfaceType.IsAssignableFrom(t) &&
+                                t.IsClass &&
+                                !t.IsAbstract &&
+                                t.IsPublic &&
+                                !t.IsGenericType &&
+                                !t.ContainsGenericParameters);
                     }
                     catch
                     {
diff --git a/src/SourceFlow/Messaging/Bus/ICommandBus.cs b/src/SourceFlow/Messaging/Bus/ICommandBus.cs
@@ -15,7 +15,7 @@ public interface ICommandBus
         /// <param name="event"></param>
         /// <returns></returns>
         Task Publish<TCommand>(TCommand command)
-             where TCommand : ICommand;
+            where TCommand : ICommand;
 
         /// <summary>
         /// Replays all commands for a given aggregate.
diff --git a/src/SourceFlow/Messaging/Bus/Impl/CommandBus.cs b/src/SourceFlow/Messaging/Bus/Impl/CommandBus.cs
@@ -110,7 +110,7 @@ private Task DispatchCommand<TCommand>(TCommand command, ICommandDispatcher disp
         {
             // 2.2 Log event.
             logger?.LogInformation("Action=Command_Dispatched, Dispatcher={Dispatcher}, Command={Command}, Payload={Payload}, SequenceNo={No}",
-               dispatcher.GetType().Name, command.GetType().Name, command.Payload.GetType().Name, ((IMetadata)command).Metadata.SequenceNo);
+                dispatcher.GetType().Name, command.GetType().Name, command.Payload.GetType().Name, ((IMetadata)command).Metadata.SequenceNo);
 
             // 2.1 Dispatch to each dispatcher
             return dispatcher.Dispatch(command);
diff --git a/src/SourceFlow/Messaging/Commands/ICommandPublisher.cs b/src/SourceFlow/Messaging/Commands/ICommandPublisher.cs
@@ -14,7 +14,7 @@ public interface ICommandPublisher
         /// <param name="event"></param>
         /// <returns></returns>
         Task Publish<TCommand>(TCommand command)
-              where TCommand : ICommand;
+            where TCommand : ICommand;
 
         /// <summary>
         /// Replays commands for the specified entity Id.
diff --git a/src/SourceFlow/Messaging/Commands/ICommandSubscriber.cs b/src/SourceFlow/Messaging/Commands/ICommandSubscriber.cs
@@ -20,6 +20,6 @@ public interface ICommandSubscriber
         /// <param name="command"></param>
         /// <returns></returns>
         Task Subscribe<TCommand>(TCommand command)
-              where TCommand : ICommand;
+            where TCommand : ICommand;
     }
 }
diff --git a/src/SourceFlow/Projections/EventSubscriber.cs b/src/SourceFlow/Projections/EventSubscriber.cs
@@ -45,7 +45,7 @@ public EventSubscriber(IEnumerable<IView> views, ILogger<IEventSubscriber> logge
         /// <param name="event"></param>
         /// <returns></returns>
         public Task Subscribe<TEvent>(TEvent @event)
-           where TEvent : IEvent
+            where TEvent : IEvent
         {
             if (!views.Any())
             {
diff --git a/src/SourceFlow/Projections/IView.cs b/src/SourceFlow/Projections/IView.cs
@@ -9,6 +9,6 @@ namespace SourceFlow.Projections
     public interface IView
     {
         Task Apply<TEvent>(TEvent @event)
-           where TEvent : IEvent;
+            where TEvent : IEvent;
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,5 @@`
`1`	`1`	`{`
`2`		`- "threshold": 15,`
	`2`	`+ "threshold": 7,`
`3`	`3`	`"reporters": ["console"],`
`4`	`4`	`"ignore": [`
`5`	`5`	`"*/.min.js",`
Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ public static IEnumerable<Type> GetRegisteredTypes()`
`74`	`74`	`{`
`75`	`75`	`var assemblyTypes = assembly.GetTypes()`
`76`	`76`	`.Where(t => t.IsClass && !t.IsAbstract &&`
`77`		`- t.GetInterfaces().Any(i => i.Name == "IEntity"));`
	`77`	`+ t.GetInterfaces().Any(i => i.Name == "IEntity"));`
`78`	`78`	`foreach (var type in assemblyTypes)`
`79`	`79`	`{`
`80`	`80`	`types.Add(type);`
`@@ -113,7 +113,7 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)`
`113`	`113`	`{`
`114`	`114`	`var types = assembly.GetTypes()`
`115`	`115`	`.Where(t => t.IsClass && !t.IsAbstract &&`
`116`		`- t.GetInterfaces().Any(i => i.Name == "IEntity"));`
	`116`	`+ t.GetInterfaces().Any(i => i.Name == "IEntity"));`
`117`	`117`	`foreach (var type in types)`
`118`	`118`	`{`
`119`	`119`	`entityTypes.Add(type);`
`@@ -125,15 +125,15 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)`
`125`	`125`	`// Auto-discover from loaded assemblies (fallback)`
`126`	`126`	`var discoveredTypes = AppDomain.CurrentDomain.GetAssemblies()`
`127`	`127`	`.Where(a => !a.IsDynamic && !a.FullName?.StartsWith("Microsoft.") == true`
`128`		`- && !a.FullName?.StartsWith("System.") == true`
`129`		`- && !a.FullName?.StartsWith("netstandard") == true)`
	`128`	`+ && !a.FullName?.StartsWith("System.") == true`
	`129`	`+ && !a.FullName?.StartsWith("netstandard") == true)`
`130`	`130`	`.SelectMany(a =>`
`131`	`131`	`{`
`132`	`132`	`try { return a.GetTypes(); }`
`133`	`133`	`catch { return Enumerable.Empty<Type>(); }`
`134`	`134`	`})`
`135`	`135`	`.Where(t => t.IsClass && !t.IsAbstract &&`
`136`		`- t.GetInterfaces().Any(i => i.Name == "IEntity"));`
	`136`	`+ t.GetInterfaces().Any(i => i.Name == "IEntity"));`
`137`	`137`
`138`	`138`	`foreach (var type in discoveredTypes)`
`139`	`139`	`{`
Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ public Task Subscribe<TEvent>(TEvent @event) where TEvent : IEvent`
`56`	`56`	`tasks.Add(eventSubscriber.On(@event));`
`57`	`57`
`58`	`58`	`logger?.LogInformation("Action=Event_Disptcher_Aggregate, Event={Event}, Aggregate={Aggregate}",`
`59`		`- typeof(TEvent).Name, aggregate.GetType().Name);`
	`59`	`+ typeof(TEvent).Name, aggregate.GetType().Name);`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`return Task.WhenAll(tasks);`