From e6445eef68a553d98eb83320b51149a213fe1e2f Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Wed, 26 Nov 2025 14:24:38 -0300 Subject: [PATCH 01/16] feat: implement command, query, and event handling in UltraMediator and update README --- README.md | 74 +++++++++++++++++++ .../Contracts/ICommandHandler.cs | 6 ++ .../Contracts/IEventHandler.cs | 6 ++ .../Contracts/IQueryHandler.cs | 6 ++ .../ICommandHandler.cs | 18 ----- .../Mediator/UltraMediator.cs | 0 6 files changed, 92 insertions(+), 18 deletions(-) create mode 100644 src/UltraSpeedBus.Abstractions/Contracts/ICommandHandler.cs create mode 100644 src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs create mode 100644 src/UltraSpeedBus.Abstractions/Contracts/IQueryHandler.cs delete mode 100644 src/UltraSpeedBus.Abstractions/ICommandHandler.cs rename src/{UltraSpeedBus.Abstractions => UltraSpeedBus}/Mediator/UltraMediator.cs (100%) diff --git a/README.md b/README.md index 5785a4d..1ec8e1d 100644 --- a/README.md +++ b/README.md @@ -27,6 +27,80 @@ dotnet add package UltraSpeedBus.Abstractions dotnet add package UltraSpeedBus.Extensions.DependencyInjection ``` +# Configure your ``Program`` +```cs +using UltraSpeedBus.Abstractions; +using UltraSpeedBus.Abstractions.Contracts; +using UltraSpeedBus.Abstractions.Mediator; +using UltraSpeedBus.Extensions.DepedencyInjection; +using UltraSpeedBus.WebAPI; + +var builder = WebApplication.CreateBuilder(args); + +builder.Services.AddEndpointsApiExplorer(); +builder.Services.AddSwaggerGen(); +builder.Services.AddUltraSpeedBus(); + +builder.Services.AddSingleton, CreateOrderHandler>(); +builder.Services.AddSingleton, GetOrderQueryHandler>(); +builder.Services.AddSingleton, OrderCreatedEventHandler>(); + +var app = builder.Build(); + +if (app.Environment.IsDevelopment()) +{ + app.UseSwagger(); + app.UseSwaggerUI(); +} + +app.UseHttpsRedirection(); + +var mediator = app.Services.GetRequiredService(); + +mediator.RegisterCommandHandler( + (ctx) => app.Services.GetRequiredService>().Handle(ctx) +); + +mediator.RegisterQueryHandler( + (ctx) => app.Services.GetRequiredService>().Handle(ctx) +); + +mediator.RegisterEventHandler( + (ctx) => app.Services.GetRequiredService>().Handle(ctx) +); + +app.MapPost("/orders", async (CreateOrder command, ISend sender) => +{ + var result = await sender.SendAsync(command); + return Results.Ok(result); +}); + +// GET /orders/{id} -> Send Query +app.MapGet("/orders/{id:int}", async (int id, ISend sender) => +{ + var result = await sender.SendAsync(new GetOrder(id)); + if (result is null) + return Results.NotFound(); + + return Results.Ok(result); +}); + +// POST /simulate -> Publish Event directly +app.MapPost("/simulate", async (IPublish publisher) => +{ + await publisher.PublishAsync(new OrderCreated(999)); + return Results.Ok("Event Published"); +}); + +// Example: Dynamic event consumer (runtime registration) +mediator.ConnectHandlerAsync(async ctx => +{ + Console.WriteLine($"[Dynamic Consumer] Order created with {ctx.Message.OrderId}"); +}); + +app.Run(); +``` + ## Command handler ```csharp diff --git a/src/UltraSpeedBus.Abstractions/Contracts/ICommandHandler.cs b/src/UltraSpeedBus.Abstractions/Contracts/ICommandHandler.cs new file mode 100644 index 0000000..0342786 --- /dev/null +++ b/src/UltraSpeedBus.Abstractions/Contracts/ICommandHandler.cs @@ -0,0 +1,6 @@ +namespace UltraSpeedBus.Abstractions.Contracts; + +public interface ICommandHandler +{ + Task Handle(CommandContext request); +} diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs b/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs new file mode 100644 index 0000000..2c41eee --- /dev/null +++ b/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs @@ -0,0 +1,6 @@ +namespace UltraSpeedBus.Abstractions.Contracts; + +public interface IEventHandler +{ + Task Handle(EventContext request); +} \ No newline at end of file diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IQueryHandler.cs b/src/UltraSpeedBus.Abstractions/Contracts/IQueryHandler.cs new file mode 100644 index 0000000..60baaf2 --- /dev/null +++ b/src/UltraSpeedBus.Abstractions/Contracts/IQueryHandler.cs @@ -0,0 +1,6 @@ +namespace UltraSpeedBus.Abstractions.Contracts; + +public interface IQueryHandler +{ + Task Handle(QueryContext request); +} diff --git a/src/UltraSpeedBus.Abstractions/ICommandHandler.cs b/src/UltraSpeedBus.Abstractions/ICommandHandler.cs deleted file mode 100644 index d734479..0000000 --- a/src/UltraSpeedBus.Abstractions/ICommandHandler.cs +++ /dev/null @@ -1,18 +0,0 @@ -using UltraSpeedBus.Abstractions.Contracts; - -namespace UltraSpeedBus.Abstractions; - -public interface ICommandHandler -{ - Task Handle(CommandContext request); -} - -public interface IQueryHandler -{ - Task Handle(QueryContext request); -} - -public interface IEventHandler -{ - Task Handle(EventContext request); -} \ No newline at end of file diff --git a/src/UltraSpeedBus.Abstractions/Mediator/UltraMediator.cs b/src/UltraSpeedBus/Mediator/UltraMediator.cs similarity index 100% rename from src/UltraSpeedBus.Abstractions/Mediator/UltraMediator.cs rename to src/UltraSpeedBus/Mediator/UltraMediator.cs From e7dcbfcf50a16aee9e23972034c78172d6e4b12a Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Wed, 26 Nov 2025 14:28:02 -0300 Subject: [PATCH 02/16] feat: update README with additional configuration details and remove development environment checks --- README.md | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/README.md b/README.md index 1ec8e1d..34252e9 100644 --- a/README.md +++ b/README.md @@ -39,36 +39,39 @@ var builder = WebApplication.CreateBuilder(args); builder.Services.AddEndpointsApiExplorer(); builder.Services.AddSwaggerGen(); -builder.Services.AddUltraSpeedBus(); +builder.Services.AddUltraSpeedBus(); // Add this method extensions: AddUltraSpeedBus() +// Configure your Command, Query and Event handlers builder.Services.AddSingleton, CreateOrderHandler>(); builder.Services.AddSingleton, GetOrderQueryHandler>(); builder.Services.AddSingleton, OrderCreatedEventHandler>(); var app = builder.Build(); -if (app.Environment.IsDevelopment()) -{ - app.UseSwagger(); - app.UseSwaggerUI(); -} - -app.UseHttpsRedirection(); +// more configurations +// Get the mediator instance var mediator = app.Services.GetRequiredService(); + +// Register your Commandhandler for CreateOrder record mediator.RegisterCommandHandler( (ctx) => app.Services.GetRequiredService>().Handle(ctx) ); + +// Register your QueryHandler for GetOrder record mediator.RegisterQueryHandler( (ctx) => app.Services.GetRequiredService>().Handle(ctx) ); +// Register your EventHandler for GetOrder record mediator.RegisterEventHandler( (ctx) => app.Services.GetRequiredService>().Handle(ctx) ); +// Use Minimal APIS + app.MapPost("/orders", async (CreateOrder command, ISend sender) => { var result = await sender.SendAsync(command); From 0121eb658cc3039c594b3aa8b0bc28d524e556c5 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 07:29:39 -0300 Subject: [PATCH 03/16] feat: implement CreateOrder command handler and GetOrder query handler --- .../CommandHandlers/CreateOrderHandler.cs | 23 +++++++++ .../CreateOrderHandler.cs | 51 ------------------- .../EventHandler/OrderCreatedEventHandler.cs | 13 +++++ .../QueryHandler/GetOrderQueryHandler.cs | 19 +++++++ 4 files changed, 55 insertions(+), 51 deletions(-) create mode 100644 sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs delete mode 100644 sample/UltraSpeedBus.WebAPI/CreateOrderHandler.cs create mode 100644 sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs create mode 100644 sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs diff --git a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs new file mode 100644 index 0000000..31c7706 --- /dev/null +++ b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs @@ -0,0 +1,23 @@ +using UltraSpeedBus.Abstractions.Contracts; + +namespace UltraSpeedBus.WebAPI.CommandHandler; + +#region Command +public sealed record CreateOrder(string Product, int Quantity); +public sealed record OrderResult(int OrderId); +public sealed record OrderCreated(int OrderId); + +public class CreateOrderHandler : ICommandHandler +{ + public Task Handle(CommandContext request) + { + // Simula criação de pedido + int generatedId = Random.Shared.Next(1000, 9999); + + return Task.FromResult(new OrderResult(generatedId)); + } +} + +#endregion +#region Event +#endregion \ No newline at end of file diff --git a/sample/UltraSpeedBus.WebAPI/CreateOrderHandler.cs b/sample/UltraSpeedBus.WebAPI/CreateOrderHandler.cs deleted file mode 100644 index 796dd84..0000000 --- a/sample/UltraSpeedBus.WebAPI/CreateOrderHandler.cs +++ /dev/null @@ -1,51 +0,0 @@ -using UltraSpeedBus.Abstractions; -using UltraSpeedBus.Abstractions.Contracts; - - -namespace UltraSpeedBus.WebAPI; - - -#region Command -public sealed record CreateOrder(string Product, int Quantity); -public sealed record OrderResult(int OrderId); -public sealed record OrderCreated(int OrderId); - -public class CreateOrderHandler : ICommandHandler -{ - public Task Handle(CommandContext request) - { - // Simula criação de pedido - int generatedId = Random.Shared.Next(1000, 9999); - - return Task.FromResult(new OrderResult(generatedId)); - } -} -#endregion - -#region Query -public sealed record GetOrder(int OrderId); -public sealed record OrderDto(int OrderId, string Description); -public class GetOrderQueryHandler : IQueryHandler -{ - public Task Handle(QueryContext context) - { - if (context.Query.OrderId == 42) - { - return Task.FromResult(new OrderDto(42, "Example Order")); - } - - return Task.FromResult(null); - } -} -#endregion - -#region Event -public class OrderCreatedEventHandler : IEventHandler -{ - public Task Handle(EventContext context) - { - Console.WriteLine($"[Event] Order created → Id = {context.Event.OrderId}"); - return Task.CompletedTask; - } -} -#endregion \ No newline at end of file diff --git a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs new file mode 100644 index 0000000..be566ad --- /dev/null +++ b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs @@ -0,0 +1,13 @@ +using UltraSpeedBus.Abstractions.Contracts; +using UltraSpeedBus.WebAPI.CommandHandler; + +namespace UltraSpeedBus.WebAPI.EventHandler; + +public class OrderCreatedEventHandler : IEventHandler +{ + public Task Handle(EventContext context) + { + Console.WriteLine($"[Event] Order created → Id = {context.Event.OrderId}"); + return Task.CompletedTask; + } +} diff --git a/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs b/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs new file mode 100644 index 0000000..d3e515b --- /dev/null +++ b/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs @@ -0,0 +1,19 @@ +using UltraSpeedBus.Abstractions.Contracts; + +namespace UltraSpeedBus.WebAPI.QueryHandler; + +public sealed record GetOrder(int OrderId); +public sealed record OrderDto(int OrderId, string Description); + +public class GetOrderQueryHandler : IQueryHandler +{ + public Task Handle(QueryContext context) + { + if (context.Query.OrderId == 42) + { + return Task.FromResult(new OrderDto(42, "Example Order")); + } + + return Task.FromResult(null); + } +} From af19968a5ad72332a69ce612dbe373d083f17ccb Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 09:13:13 -0300 Subject: [PATCH 04/16] feat: add EditorConfig for coding standards and update Directory.Build.props to treat warnings as errors --- .editorconfig | 142 ++++++++++++++++++ Directory.Build.props | 1 + .../CommandHandlers/CreateOrderHandler.cs | 5 - sample/UltraSpeedBus.WebAPI/Program.cs | 5 +- src/UltraSpeedBus/Mediator/UltraMediator.cs | 6 +- 5 files changed, 151 insertions(+), 8 deletions(-) create mode 100644 .editorconfig diff --git a/.editorconfig b/.editorconfig new file mode 100644 index 0000000..06d6959 --- /dev/null +++ b/.editorconfig @@ -0,0 +1,142 @@ +############################### +# Core EditorConfig Options # +############################### +root = true +# All files +[*] +indent_style = space + +# XML project files +[*.{csproj,vbproj,vcxproj,vcxproj.filters,proj,projitems,shproj}] +indent_size = 4 + +# XML config files +[*.{props,targets,ruleset,config,nuspec,resx,vsixmanifest,vsct}] +indent_size = 4 + +# Code files +[*.{cs,csx,vb,vbx}] +indent_size = 4 +insert_final_newline = true +charset = utf-8-bom +############################### +# .NET Coding Conventions # +############################### +[*.{cs,vb}] +# Organize usings +dotnet_sort_system_directives_first = true +# this. preferences +dotnet_style_qualification_for_field = false:silent +dotnet_style_qualification_for_property = false:silent +dotnet_style_qualification_for_method = false:silent +dotnet_style_qualification_for_event = false:silent +# Language keywords vs BCL types preferences +dotnet_style_predefined_type_for_locals_parameters_members = true:silent +dotnet_style_predefined_type_for_member_access = true:silent +# Parentheses preferences +dotnet_style_parentheses_in_arithmetic_binary_operators = always_for_clarity:silent +dotnet_style_parentheses_in_relational_binary_operators = always_for_clarity:silent +dotnet_style_parentheses_in_other_binary_operators = always_for_clarity:silent +dotnet_style_parentheses_in_other_operators = never_if_unnecessary:silent +# Modifier preferences +dotnet_style_require_accessibility_modifiers = for_non_interface_members:silent +dotnet_style_readonly_field = true:suggestion +# Expression-level preferences +dotnet_style_object_initializer = true:suggestion +dotnet_style_collection_initializer = true:suggestion +dotnet_style_explicit_tuple_names = true:suggestion +dotnet_style_null_propagation = true:suggestion +dotnet_style_coalesce_expression = true:suggestion +dotnet_style_prefer_is_null_check_over_reference_equality_method = true:silent +dotnet_style_prefer_inferred_tuple_names = true:suggestion +dotnet_style_prefer_inferred_anonymous_type_member_names = true:suggestion +dotnet_style_prefer_auto_properties = true:silent +dotnet_style_prefer_conditional_expression_over_assignment = true:silent +dotnet_style_prefer_conditional_expression_over_return = true:silent +############################### +# Naming Conventions # +############################### +# Style Definitions +dotnet_naming_style.pascal_case_style.capitalization = pascal_case +# Use PascalCase for constant fields +dotnet_naming_rule.constant_fields_should_be_pascal_case.severity = suggestion +dotnet_naming_rule.constant_fields_should_be_pascal_case.symbols = constant_fields +dotnet_naming_rule.constant_fields_should_be_pascal_case.style = pascal_case_style +dotnet_naming_symbols.constant_fields.applicable_kinds = field +dotnet_naming_symbols.constant_fields.applicable_accessibilities = * +dotnet_naming_symbols.constant_fields.required_modifiers = const +tab_width=2 +dotnet_naming_rule.private_members_with_underscore.symbols = private_fields +dotnet_naming_rule.private_members_with_underscore.style = prefix_underscore +dotnet_naming_rule.private_members_with_underscore.severity = suggestion +dotnet_naming_symbols.private_fields.applicable_kinds = field +dotnet_naming_symbols.private_fields.applicable_accessibilities = private +dotnet_naming_style.prefix_underscore.capitalization = camel_case +dotnet_naming_style.prefix_underscore.required_prefix = _ +############################### +# C# Coding Conventions # +############################### +[*.cs] +# var preferences +csharp_style_var_for_built_in_types = true:silent +csharp_style_var_when_type_is_apparent = true:silent +csharp_style_var_elsewhere = true:silent +# Expression-bodied members +csharp_style_expression_bodied_methods = false:silent +csharp_style_expression_bodied_constructors = false:silent +csharp_style_expression_bodied_operators = false:silent +csharp_style_expression_bodied_properties = true:silent +csharp_style_expression_bodied_indexers = true:silent +csharp_style_expression_bodied_accessors = true:silent +# Pattern matching preferences +csharp_style_pattern_matching_over_is_with_cast_check = true:suggestion +csharp_style_pattern_matching_over_as_with_null_check = true:suggestion +# Null-checking preferences +csharp_style_throw_expression = true:suggestion +csharp_style_conditional_delegate_call = true:suggestion +# Modifier preferences +csharp_preferred_modifier_order = public,private,protected,internal,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,volatile,async:suggestion +# Expression-level preferences +csharp_prefer_braces = true:silent +csharp_style_deconstructed_variable_declaration = true:suggestion +csharp_prefer_simple_default_expression = true:suggestion +csharp_style_pattern_local_over_anonymous_function = true:suggestion +csharp_style_inlined_variable_declaration = true:suggestion +# Namespaces +csharp_style_namespace_declarations = file_scoped:warning +############################### +# C# Formatting Rules # +############################### +# New line preferences +csharp_new_line_before_open_brace = all +csharp_new_line_before_else = true +csharp_new_line_before_catch = true +csharp_new_line_before_finally = true +csharp_new_line_before_members_in_object_initializers = true +csharp_new_line_before_members_in_anonymous_types = true +csharp_new_line_between_query_expression_clauses = true +# Indentation preferences +csharp_indent_case_contents = true +csharp_indent_switch_labels = true +csharp_indent_labels = flush_left +# Space preferences +csharp_space_after_cast = false +csharp_space_after_keywords_in_control_flow_statements = true +csharp_space_between_method_call_parameter_list_parentheses = false +csharp_space_between_method_declaration_parameter_list_parentheses = false +csharp_space_between_parentheses = false +csharp_space_before_colon_in_inheritance_clause = true +csharp_space_after_colon_in_inheritance_clause = true +csharp_space_around_binary_operators = before_and_after +csharp_space_between_method_declaration_empty_parameter_list_parentheses = false +csharp_space_between_method_call_name_and_opening_parenthesis = false +csharp_space_between_method_call_empty_parameter_list_parentheses = false +# Wrapping preferences +csharp_preserve_single_line_statements = true +csharp_preserve_single_line_blocks = true +############################### +# VB Coding Conventions # +############################### +[*.vb] +# Modifier preferences +visual_basic_preferred_modifier_order = Partial,Default,Private,Protected,Public,Friend,NotOverridable,Overridable,MustOverride,Overloads,Overrides,MustInherit,NotInheritable,Static,Shared,Shadows,ReadOnly,WriteOnly,Dim,Const,WithEvents,Widening,Narrowing,Custom,Async:suggestion \ No newline at end of file diff --git a/Directory.Build.props b/Directory.Build.props index b8f8148..2ab0f63 100644 --- a/Directory.Build.props +++ b/Directory.Build.props @@ -13,6 +13,7 @@ enable enable latest + true 1.0.0 diff --git a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs index 31c7706..6e9596a 100644 --- a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs @@ -2,7 +2,6 @@ namespace UltraSpeedBus.WebAPI.CommandHandler; -#region Command public sealed record CreateOrder(string Product, int Quantity); public sealed record OrderResult(int OrderId); public sealed record OrderCreated(int OrderId); @@ -17,7 +16,3 @@ public Task Handle(CommandContext request) return Task.FromResult(new OrderResult(generatedId)); } } - -#endregion -#region Event -#endregion \ No newline at end of file diff --git a/sample/UltraSpeedBus.WebAPI/Program.cs b/sample/UltraSpeedBus.WebAPI/Program.cs index 91cf792..435de7b 100644 --- a/sample/UltraSpeedBus.WebAPI/Program.cs +++ b/sample/UltraSpeedBus.WebAPI/Program.cs @@ -1,8 +1,9 @@ -using UltraSpeedBus.Abstractions; using UltraSpeedBus.Abstractions.Contracts; using UltraSpeedBus.Abstractions.Mediator; using UltraSpeedBus.Extensions.DepedencyInjection; -using UltraSpeedBus.WebAPI; +using UltraSpeedBus.WebAPI.CommandHandler; +using UltraSpeedBus.WebAPI.EventHandler; +using UltraSpeedBus.WebAPI.QueryHandler; var builder = WebApplication.CreateBuilder(args); diff --git a/src/UltraSpeedBus/Mediator/UltraMediator.cs b/src/UltraSpeedBus/Mediator/UltraMediator.cs index 4735e7f..d17ba90 100644 --- a/src/UltraSpeedBus/Mediator/UltraMediator.cs +++ b/src/UltraSpeedBus/Mediator/UltraMediator.cs @@ -35,6 +35,8 @@ public Task SendAsync(TRequest request) // Publisher 1 x Many Consumers public Task PublishAsync(TEvent @event) { + if (@event == null) throw new ArgumentException(nameof(@event)); + var type = typeof(TEvent); var tasks = new List(); @@ -108,6 +110,8 @@ private async Task InvokeHandler( TRequest request ) { + if (request is null) throw new ArgumentNullException(nameof(request)); + var response = await handler(request); return (TResponse)response; } @@ -152,4 +156,4 @@ public void Disconnect() _mediator.RemoveDynamicHandler(this); } } -} \ No newline at end of file +} From 9fcffd523a0e8a9027142f49a8f91817f5852c99 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 09:14:27 -0300 Subject: [PATCH 05/16] feat: update .editorconfig with new line preferences and adjust Visual Basic modifier order --- .editorconfig | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/.editorconfig b/.editorconfig index 06d6959..9158dc3 100644 --- a/.editorconfig +++ b/.editorconfig @@ -5,6 +5,11 @@ root = true # All files [*] indent_style = space +tab_width = 4 + +# New line preferences +end_of_line = crlf +insert_final_newline = true # XML project files [*.{csproj,vbproj,vcxproj,vcxproj.filters,proj,projitems,shproj}] @@ -139,4 +144,4 @@ csharp_preserve_single_line_blocks = true ############################### [*.vb] # Modifier preferences -visual_basic_preferred_modifier_order = Partial,Default,Private,Protected,Public,Friend,NotOverridable,Overridable,MustOverride,Overloads,Overrides,MustInherit,NotInheritable,Static,Shared,Shadows,ReadOnly,WriteOnly,Dim,Const,WithEvents,Widening,Narrowing,Custom,Async:suggestion \ No newline at end of file +visual_basic_preferred_modifier_order = Partial,Default,Private,Protected,Public,Friend,NotOverridable,Overridable,MustOverride,Overloads,Overrides,MustInherit,NotInheritable,Static,Shared,Shadows,ReadOnly,WriteOnly,Dim,Const,WithEvents,Widening,Narrowing,Custom,Async:suggestion From 2280f6d659621778a2e6beba0d5fee8899288c22 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 10:32:26 -0300 Subject: [PATCH 06/16] feat: update event handling interfaces and improve code analysis settings --- .editorconfig | 9 +++++++++ Directory.Build.props | 20 ++++++++++++++++++- .../EventHandler/OrderCreatedEventHandler.cs | 2 +- sample/UltraSpeedBus.WebAPI/Program.cs | 4 ++-- .../Contracts/IEventHandler.cs | 4 ++-- .../Contracts/IPublish.cs | 4 ++-- src/UltraSpeedBus/Mediator/UltraMediator.cs | 8 ++++---- 7 files changed, 39 insertions(+), 12 deletions(-) diff --git a/.editorconfig b/.editorconfig index 9158dc3..34e0812 100644 --- a/.editorconfig +++ b/.editorconfig @@ -145,3 +145,12 @@ csharp_preserve_single_line_blocks = true [*.vb] # Modifier preferences visual_basic_preferred_modifier_order = Partial,Default,Private,Protected,Public,Friend,NotOverridable,Overridable,MustOverride,Overloads,Overrides,MustInherit,NotInheritable,Static,Shared,Shadows,ReadOnly,WriteOnly,Dim,Const,WithEvents,Widening,Narrowing,Custom,Async:suggestion + +# S125: Sections of code should not be commented out +dotnet_diagnostic.S125.severity = none +# S1075: URIs should not be hardcoded +dotnet_diagnostic.S1075.severity = none +# S2094: Classes should not be empty +dotnet_diagnostic.S2094.severity = none +# S3267: Loops should be simplified with "LINQ" expressions +dotnet_diagnostic.S3267.severity = none diff --git a/Directory.Build.props b/Directory.Build.props index 2ab0f63..575a862 100644 --- a/Directory.Build.props +++ b/Directory.Build.props @@ -14,6 +14,9 @@ enable latest true + true + true + latest 1.0.0 @@ -22,4 +25,19 @@ - \ No newline at end of file + + + + + + diff --git a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs index be566ad..3460579 100644 --- a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs @@ -3,7 +3,7 @@ namespace UltraSpeedBus.WebAPI.EventHandler; -public class OrderCreatedEventHandler : IEventHandler +public class OrderCreatedEventHandler : IEventProcessor { public Task Handle(EventContext context) { diff --git a/sample/UltraSpeedBus.WebAPI/Program.cs b/sample/UltraSpeedBus.WebAPI/Program.cs index 435de7b..fa04a89 100644 --- a/sample/UltraSpeedBus.WebAPI/Program.cs +++ b/sample/UltraSpeedBus.WebAPI/Program.cs @@ -13,7 +13,7 @@ builder.Services.AddSingleton, CreateOrderHandler>(); builder.Services.AddSingleton, GetOrderQueryHandler>(); -builder.Services.AddSingleton, OrderCreatedEventHandler>(); +builder.Services.AddSingleton, OrderCreatedEventHandler>(); var app = builder.Build(); @@ -36,7 +36,7 @@ ); mediator.RegisterEventHandler( - (ctx) => app.Services.GetRequiredService>().Handle(ctx) + (ctx) => app.Services.GetRequiredService>().Handle(ctx) ); app.MapPost("/orders", async (CreateOrder command, ISend sender) => diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs b/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs index 2c41eee..76183d0 100644 --- a/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs +++ b/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs @@ -1,6 +1,6 @@ namespace UltraSpeedBus.Abstractions.Contracts; -public interface IEventHandler +public interface IEventProcessor { Task Handle(EventContext request); -} \ No newline at end of file +} diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IPublish.cs b/src/UltraSpeedBus.Abstractions/Contracts/IPublish.cs index fe1710d..d138458 100644 --- a/src/UltraSpeedBus.Abstractions/Contracts/IPublish.cs +++ b/src/UltraSpeedBus.Abstractions/Contracts/IPublish.cs @@ -2,5 +2,5 @@ namespace UltraSpeedBus.Abstractions.Contracts; public interface IPublish { - Task PublishAsync(TEvent @event); -} \ No newline at end of file + Task PublishAsync(TEvent message); +} diff --git a/src/UltraSpeedBus/Mediator/UltraMediator.cs b/src/UltraSpeedBus/Mediator/UltraMediator.cs index d17ba90..26c6ed4 100644 --- a/src/UltraSpeedBus/Mediator/UltraMediator.cs +++ b/src/UltraSpeedBus/Mediator/UltraMediator.cs @@ -33,9 +33,9 @@ public Task SendAsync(TRequest request) #region Implement IPublish // Publisher 1 x Many Consumers - public Task PublishAsync(TEvent @event) + public Task PublishAsync(TEvent message) { - if (@event == null) throw new ArgumentException(nameof(@event)); + if (message == null) throw new ArgumentException(nameof(message)); var type = typeof(TEvent); var tasks = new List(); @@ -43,14 +43,14 @@ public Task PublishAsync(TEvent @event) if (_eventHandlers.TryGetValue(type, out var eventHandlers)) { foreach (var handler in eventHandlers) - tasks.Add(handler(@event)); + tasks.Add(handler(message)); } // You can disable this one if (_dynamicHandlers.TryGetValue(type, out var dynamicEventHandlers)) { foreach (var handler in dynamicEventHandlers.OfType>()) - tasks.Add(handler.Handle(@event)); + tasks.Add(handler.Handle(message)); } return Task.WhenAll(tasks); From 438dd45dc2f735befc76623f2b138201a61c01e1 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 17:21:15 -0300 Subject: [PATCH 07/16] feat: add IEventProcessor interface and improve CommandContext formatting --- .editorconfig | 18 ++++++++++++------ .../Context/CommandContext.cs | 1 + .../{IEventHandler.cs => IEventProcessor.cs} | 0 3 files changed, 13 insertions(+), 6 deletions(-) rename src/UltraSpeedBus.Abstractions/Contracts/{IEventHandler.cs => IEventProcessor.cs} (100%) diff --git a/.editorconfig b/.editorconfig index 34e0812..57df07a 100644 --- a/.editorconfig +++ b/.editorconfig @@ -139,12 +139,6 @@ csharp_space_between_method_call_empty_parameter_list_parentheses = false # Wrapping preferences csharp_preserve_single_line_statements = true csharp_preserve_single_line_blocks = true -############################### -# VB Coding Conventions # -############################### -[*.vb] -# Modifier preferences -visual_basic_preferred_modifier_order = Partial,Default,Private,Protected,Public,Friend,NotOverridable,Overridable,MustOverride,Overloads,Overrides,MustInherit,NotInheritable,Static,Shared,Shadows,ReadOnly,WriteOnly,Dim,Const,WithEvents,Widening,Narrowing,Custom,Async:suggestion # S125: Sections of code should not be commented out dotnet_diagnostic.S125.severity = none @@ -154,3 +148,15 @@ dotnet_diagnostic.S1075.severity = none dotnet_diagnostic.S2094.severity = none # S3267: Loops should be simplified with "LINQ" expressions dotnet_diagnostic.S3267.severity = none +dotnet_diagnostic.SA16.severity = none +dotnet_diagnostic.SA1600.severity = none +dotnet_diagnostic.SA1507.severity = none +dotnet_diagnostic.SA1505.severity = none +dotnet_diagnostic.SA1508.severity = none +dotnet_diagnostic.SA1201.severity = none +dotnet_diagnostic.S1135.severity = none +dotnet_diagnostic.SA1633.severity = none +dotnet_diagnostic.SA1200.severity = none +dotnet_diagnostic.SA1028.severity = none +dotnet_diagnostic.SA1516.severity = none +dotnet_diagnostic.SA1101.severity = none diff --git a/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs b/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs index 202e311..97d29cd 100644 --- a/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs +++ b/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs @@ -1,5 +1,6 @@ namespace UltraSpeedBus.Abstractions.Contracts; + public class CommandContext { public TCommand Command { get; } diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs b/src/UltraSpeedBus.Abstractions/Contracts/IEventProcessor.cs similarity index 100% rename from src/UltraSpeedBus.Abstractions/Contracts/IEventHandler.cs rename to src/UltraSpeedBus.Abstractions/Contracts/IEventProcessor.cs From af9641cae7e7f41c663184f1f65031085ffa79f0 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 21:57:47 -0300 Subject: [PATCH 08/16] feat: enhance EditorConfig settings, fix method signature, and implement DynamicHandler for event handling --- .editorconfig | 368 ++++++++++++------ .../Contracts/IHandlerHandle.cs | 5 +- .../UltraSpeedBusExtensions.cs | 8 +- src/UltraSpeedBus/Mediator/DynamicHandler.cs | 33 ++ src/UltraSpeedBus/Mediator/UltraMediator.cs | 123 +++--- 5 files changed, 332 insertions(+), 205 deletions(-) create mode 100644 src/UltraSpeedBus/Mediator/DynamicHandler.cs diff --git a/.editorconfig b/.editorconfig index 57df07a..2083db8 100644 --- a/.editorconfig +++ b/.editorconfig @@ -1,9 +1,12 @@ -############################### -# Core EditorConfig Options # -############################### root = true -# All files -[*] + +# C# files +[*.cs] + +#### Core EditorConfig Options #### + +# Indentation and spacing +indent_size = 4 indent_style = space tab_width = 4 @@ -11,152 +14,271 @@ tab_width = 4 end_of_line = crlf insert_final_newline = true -# XML project files -[*.{csproj,vbproj,vcxproj,vcxproj.filters,proj,projitems,shproj}] -indent_size = 4 - -# XML config files -[*.{props,targets,ruleset,config,nuspec,resx,vsixmanifest,vsct}] -indent_size = 4 +#### .NET Coding Conventions #### -# Code files -[*.{cs,csx,vb,vbx}] -indent_size = 4 -insert_final_newline = true -charset = utf-8-bom -############################### -# .NET Coding Conventions # -############################### -[*.{cs,vb}] # Organize usings +dotnet_separate_import_directive_groups = false dotnet_sort_system_directives_first = true -# this. preferences -dotnet_style_qualification_for_field = false:silent -dotnet_style_qualification_for_property = false:silent -dotnet_style_qualification_for_method = false:silent -dotnet_style_qualification_for_event = false:silent + +# this. and Me. preferences +dotnet_style_qualification_for_event = false:error +dotnet_style_qualification_for_field = false:error +dotnet_style_qualification_for_method = false:error +dotnet_style_qualification_for_property = false:error + # Language keywords vs BCL types preferences -dotnet_style_predefined_type_for_locals_parameters_members = true:silent -dotnet_style_predefined_type_for_member_access = true:silent +dotnet_style_predefined_type_for_locals_parameters_members = true:error +dotnet_style_predefined_type_for_member_access = true:error + # Parentheses preferences -dotnet_style_parentheses_in_arithmetic_binary_operators = always_for_clarity:silent -dotnet_style_parentheses_in_relational_binary_operators = always_for_clarity:silent -dotnet_style_parentheses_in_other_binary_operators = always_for_clarity:silent -dotnet_style_parentheses_in_other_operators = never_if_unnecessary:silent +dotnet_style_parentheses_in_arithmetic_binary_operators = never_if_unnecessary:error +dotnet_style_parentheses_in_other_binary_operators = never_if_unnecessary:error +dotnet_style_parentheses_in_other_operators = never_if_unnecessary:error +dotnet_style_parentheses_in_relational_binary_operators = never_if_unnecessary:error + # Modifier preferences -dotnet_style_require_accessibility_modifiers = for_non_interface_members:silent -dotnet_style_readonly_field = true:suggestion +dotnet_style_require_accessibility_modifiers = for_non_interface_members:error + # Expression-level preferences -dotnet_style_object_initializer = true:suggestion -dotnet_style_collection_initializer = true:suggestion -dotnet_style_explicit_tuple_names = true:suggestion -dotnet_style_null_propagation = true:suggestion -dotnet_style_coalesce_expression = true:suggestion -dotnet_style_prefer_is_null_check_over_reference_equality_method = true:silent -dotnet_style_prefer_inferred_tuple_names = true:suggestion -dotnet_style_prefer_inferred_anonymous_type_member_names = true:suggestion -dotnet_style_prefer_auto_properties = true:silent -dotnet_style_prefer_conditional_expression_over_assignment = true:silent -dotnet_style_prefer_conditional_expression_over_return = true:silent -############################### -# Naming Conventions # -############################### -# Style Definitions -dotnet_naming_style.pascal_case_style.capitalization = pascal_case -# Use PascalCase for constant fields -dotnet_naming_rule.constant_fields_should_be_pascal_case.severity = suggestion -dotnet_naming_rule.constant_fields_should_be_pascal_case.symbols = constant_fields -dotnet_naming_rule.constant_fields_should_be_pascal_case.style = pascal_case_style -dotnet_naming_symbols.constant_fields.applicable_kinds = field -dotnet_naming_symbols.constant_fields.applicable_accessibilities = * -dotnet_naming_symbols.constant_fields.required_modifiers = const -tab_width=2 -dotnet_naming_rule.private_members_with_underscore.symbols = private_fields -dotnet_naming_rule.private_members_with_underscore.style = prefix_underscore -dotnet_naming_rule.private_members_with_underscore.severity = suggestion -dotnet_naming_symbols.private_fields.applicable_kinds = field -dotnet_naming_symbols.private_fields.applicable_accessibilities = private -dotnet_naming_style.prefix_underscore.capitalization = camel_case -dotnet_naming_style.prefix_underscore.required_prefix = _ -############################### -# C# Coding Conventions # -############################### -[*.cs] +dotnet_style_coalesce_expression = true:error +dotnet_style_collection_initializer = true:error +dotnet_style_explicit_tuple_names = true:error +dotnet_style_null_propagation = true:error +dotnet_style_object_initializer = true:error +dotnet_style_prefer_auto_properties = true:warning +dotnet_style_prefer_compound_assignment = true:error +dotnet_style_prefer_conditional_expression_over_assignment = true:error +dotnet_style_prefer_conditional_expression_over_return = true:error +dotnet_style_prefer_inferred_anonymous_type_member_names = true:error +dotnet_style_prefer_inferred_tuple_names = true:error +dotnet_style_prefer_is_null_check_over_reference_equality_method = true:error + +# Field preferences +dotnet_style_readonly_field = true:error + +# Parameter preferences +dotnet_code_quality_unused_parameters = all:error + +#### C# Coding Conventions #### + +# Namespace preferences +csharp_style_namespace_declarations=file_scoped:error + # var preferences -csharp_style_var_for_built_in_types = true:silent -csharp_style_var_when_type_is_apparent = true:silent -csharp_style_var_elsewhere = true:silent +csharp_style_var_elsewhere = false:error +csharp_style_var_for_built_in_types = false:error +csharp_style_var_when_type_is_apparent = true:error + # Expression-bodied members -csharp_style_expression_bodied_methods = false:silent -csharp_style_expression_bodied_constructors = false:silent -csharp_style_expression_bodied_operators = false:silent -csharp_style_expression_bodied_properties = true:silent -csharp_style_expression_bodied_indexers = true:silent -csharp_style_expression_bodied_accessors = true:silent +csharp_style_expression_bodied_accessors = true:error +csharp_style_expression_bodied_constructors = true:error +csharp_style_expression_bodied_indexers = true:error +csharp_style_expression_bodied_lambdas = true:error +csharp_style_expression_bodied_local_functions = true:error +csharp_style_expression_bodied_methods = true:error +csharp_style_expression_bodied_operators = true:error +csharp_style_expression_bodied_properties = true:error + # Pattern matching preferences -csharp_style_pattern_matching_over_is_with_cast_check = true:suggestion -csharp_style_pattern_matching_over_as_with_null_check = true:suggestion +csharp_style_pattern_matching_over_as_with_null_check = true:error +csharp_style_pattern_matching_over_is_with_cast_check = true:error +csharp_style_prefer_switch_expression = true:error + # Null-checking preferences -csharp_style_throw_expression = true:suggestion -csharp_style_conditional_delegate_call = true:suggestion +csharp_style_conditional_delegate_call = true:error + # Modifier preferences -csharp_preferred_modifier_order = public,private,protected,internal,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,volatile,async:suggestion +csharp_prefer_static_local_function = true:error +csharp_preferred_modifier_order = public,private,protected,internal,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,volatile,async + +# Code-block preferences +csharp_prefer_braces = true:error +csharp_prefer_simple_using_statement = true:error + # Expression-level preferences -csharp_prefer_braces = true:silent +csharp_prefer_simple_default_expression = true:error csharp_style_deconstructed_variable_declaration = true:suggestion -csharp_prefer_simple_default_expression = true:suggestion -csharp_style_pattern_local_over_anonymous_function = true:suggestion -csharp_style_inlined_variable_declaration = true:suggestion -# Namespaces -csharp_style_namespace_declarations = file_scoped:warning -############################### -# C# Formatting Rules # -############################### +csharp_style_inlined_variable_declaration = true:error +csharp_style_pattern_local_over_anonymous_function = true:error +csharp_style_prefer_index_operator = true:suggestion +csharp_style_prefer_range_operator = true:suggestion +csharp_style_throw_expression = true:suggestion +csharp_style_unused_value_assignment_preference = discard_variable:silent +csharp_style_unused_value_expression_statement_preference = discard_variable:silent + +# 'using' directive preferences +csharp_using_directive_placement = outside_namespace:error + +#### C# Formatting Rules #### + # New line preferences +csharp_new_line_before_catch =true +csharp_new_line_before_else =true +csharp_new_line_before_finally =true +csharp_new_line_before_members_in_anonymous_types = false, +csharp_new_line_before_members_in_object_initializers = false, csharp_new_line_before_open_brace = all -csharp_new_line_before_else = true -csharp_new_line_before_catch = true -csharp_new_line_before_finally = true -csharp_new_line_before_members_in_object_initializers = true -csharp_new_line_before_members_in_anonymous_types = true csharp_new_line_between_query_expression_clauses = true + # Indentation preferences +csharp_indent_block_contents = true +csharp_indent_braces = false csharp_indent_case_contents = true +csharp_indent_case_contents_when_block = true +csharp_indent_labels = one_less_than_current csharp_indent_switch_labels = true -csharp_indent_labels = flush_left + # Space preferences csharp_space_after_cast = false +csharp_space_after_colon_in_inheritance_clause = true +csharp_space_after_comma = true +csharp_space_after_dot = false csharp_space_after_keywords_in_control_flow_statements = true +csharp_space_after_semicolon_in_for_statement = true +csharp_space_around_binary_operators = before_and_after +csharp_space_around_declaration_statements = false +csharp_space_before_colon_in_inheritance_clause = true +csharp_space_before_comma = false +csharp_space_before_dot = false +csharp_space_before_open_square_brackets = false +csharp_space_before_semicolon_in_for_statement = false +csharp_space_between_empty_square_brackets = false +csharp_space_between_method_call_empty_parameter_list_parentheses = false +csharp_space_between_method_call_name_and_opening_parenthesis = false csharp_space_between_method_call_parameter_list_parentheses = false +csharp_space_between_method_declaration_empty_parameter_list_parentheses = false +csharp_space_between_method_declaration_name_and_open_parenthesis = false csharp_space_between_method_declaration_parameter_list_parentheses = false csharp_space_between_parentheses = false -csharp_space_before_colon_in_inheritance_clause = true -csharp_space_after_colon_in_inheritance_clause = true -csharp_space_around_binary_operators = before_and_after -csharp_space_between_method_declaration_empty_parameter_list_parentheses = false -csharp_space_between_method_call_name_and_opening_parenthesis = false -csharp_space_between_method_call_empty_parameter_list_parentheses = false +csharp_space_between_square_brackets = false + # Wrapping preferences -csharp_preserve_single_line_statements = true csharp_preserve_single_line_blocks = true +csharp_preserve_single_line_statements = false + +#### Naming styles #### + +# Naming rules + +dotnet_naming_rule.interface_should_be_begins_with_i.severity = suggestion +dotnet_naming_rule.interface_should_be_begins_with_i.symbols = interface +dotnet_naming_rule.interface_should_be_begins_with_i.style = begins_with_i + +dotnet_naming_rule.types_should_be_pascal_case.severity = suggestion +dotnet_naming_rule.types_should_be_pascal_case.symbols = types +dotnet_naming_rule.types_should_be_pascal_case.style = pascal_case + +dotnet_naming_rule.non_field_members_should_be_pascal_case.severity = suggestion +dotnet_naming_rule.non_field_members_should_be_pascal_case.symbols = non_field_members +dotnet_naming_rule.non_field_members_should_be_pascal_case.style = pascal_case + +# Symbol specifications + +dotnet_naming_symbols.interface.applicable_kinds = interface +dotnet_naming_symbols.interface.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected +dotnet_naming_symbols.interface.required_modifiers = + +dotnet_naming_symbols.types.applicable_kinds = class, struct, interface, enum +dotnet_naming_symbols.types.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected +dotnet_naming_symbols.types.required_modifiers = + +dotnet_naming_symbols.non_field_members.applicable_kinds = property, event, method +dotnet_naming_symbols.non_field_members.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected +dotnet_naming_symbols.non_field_members.required_modifiers = + +# Naming styles -# S125: Sections of code should not be commented out -dotnet_diagnostic.S125.severity = none -# S1075: URIs should not be hardcoded -dotnet_diagnostic.S1075.severity = none -# S2094: Classes should not be empty -dotnet_diagnostic.S2094.severity = none -# S3267: Loops should be simplified with "LINQ" expressions -dotnet_diagnostic.S3267.severity = none -dotnet_diagnostic.SA16.severity = none +dotnet_naming_style.pascal_case.required_prefix = +dotnet_naming_style.pascal_case.required_suffix = +dotnet_naming_style.pascal_case.word_separator = +dotnet_naming_style.pascal_case.capitalization = pascal_case + +dotnet_naming_style.begins_with_i.required_prefix = I +dotnet_naming_style.begins_with_i.required_suffix = +dotnet_naming_style.begins_with_i.word_separator = +dotnet_naming_style.begins_with_i.capitalization = pascal_case + +# StyleCop.Analyzers + +# SA0001: XML comment analysis is disabled due to project configuration +dotnet_diagnostic.SA0001.severity = none + +# SA1101: Prefix local calls with this +dotnet_diagnostic.SA1101.severity = none + +# SA1309: Field names should not begin with underscore +dotnet_diagnostic.SA1309.severity = none + +# SA1413: Use trailing comma in multi-line initializers +dotnet_diagnostic.SA1413.severity = none + +# SA1600: Elements should be documented dotnet_diagnostic.SA1600.severity = none -dotnet_diagnostic.SA1507.severity = none -dotnet_diagnostic.SA1505.severity = none -dotnet_diagnostic.SA1508.severity = none -dotnet_diagnostic.SA1201.severity = none -dotnet_diagnostic.S1135.severity = none + +# SA1633: File should have header dotnet_diagnostic.SA1633.severity = none -dotnet_diagnostic.SA1200.severity = none -dotnet_diagnostic.SA1028.severity = none -dotnet_diagnostic.SA1516.severity = none -dotnet_diagnostic.SA1101.severity = none + +# SA1649: File name should match first type name +dotnet_diagnostic.SA1649.severity = none + +# SonarAnalyzers.CSharp + +# S1121: Assignments should not be made from within sub-expressions +dotnet_diagnostic.S1121.severity = none + +# NET.CodeAnalyzers + +# CA1000: Do not declare static members on generic types +dotnet_diagnostic.CA1000.severity = none + +# CA1014: Mark assemblies with CLSCompliantAttribute +dotnet_diagnostic.CA1014.severity = none + +# CA1030: Use events where appropriate +dotnet_diagnostic.CA1030.severity = none + +# CA1031: Do not catch general exception types +dotnet_diagnostic.CA1031.severity = none + +# CA1040: Avoid empty interfaces +dotnet_diagnostic.CA1040.severity = none + +# CA1062: Validate arguments of public methods +dotnet_diagnostic.CA1062.severity = none + +# CA1711: Identifiers should not have incorrect suffix +dotnet_diagnostic.CA1711.severity = none + +# CA1716: Identifiers should not match keywords +dotnet_diagnostic.CA1716.severity = none + +# CA1724: Type names should not match namespaces +dotnet_diagnostic.CA1724.severity = none + +# CA2326: Avoid uninstantiated internal classes +dotnet_diagnostic.CA1812.severity = none + +# CA1819: Properties should not return arrays +dotnet_diagnostic.CA1819.severity = none + +# CA1848: Use the LoggerMessage delegates +dotnet_diagnostic.CA1848.severity = none + +# CA2007: Consider calling ConfigureAwait on the awaited task +dotnet_diagnostic.CA2007.severity = none + +# CA2225: Operator overloads have named alternates +dotnet_diagnostic.CA2225.severity = none + +# CA2326: Do not use TypeNameHandling values other than None +dotnet_diagnostic.CA2326.severity = none + +# CA2327: Do not use insecure JsonSerializerSettings +dotnet_diagnostic.CA2327.severity = none + +# Visual Studio.Analyzers + +# IDE0046: Convert to conditional expression +dotnet_diagnostic.IDE0046.severity = none + +dotnet_diagnostic.SA1200.severity = none \ No newline at end of file diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IHandlerHandle.cs b/src/UltraSpeedBus.Abstractions/Contracts/IHandlerHandle.cs index 94982d5..511bb53 100644 --- a/src/UltraSpeedBus.Abstractions/Contracts/IHandlerHandle.cs +++ b/src/UltraSpeedBus.Abstractions/Contracts/IHandlerHandle.cs @@ -1,6 +1,5 @@ namespace UltraSpeedBus.Abstractions.Contracts; -// TODO implementar IDisposable public interface IHandlerHandle { void Disconnect(); @@ -11,5 +10,5 @@ public interface IDynamicHandler : IHandlerHandle Type MessageType { get; } // Handler is typed to generic publishing - Task Handle(object mesage); -} \ No newline at end of file + Task Handle(object message); +} diff --git a/src/UltraSpeedBus.Extensions.DepedencyInjection/UltraSpeedBusExtensions.cs b/src/UltraSpeedBus.Extensions.DepedencyInjection/UltraSpeedBusExtensions.cs index 956bc16..f7d18e0 100644 --- a/src/UltraSpeedBus.Extensions.DepedencyInjection/UltraSpeedBusExtensions.cs +++ b/src/UltraSpeedBus.Extensions.DepedencyInjection/UltraSpeedBusExtensions.cs @@ -1,13 +1,13 @@ -namespace UltraSpeedBus.Extensions.DepedencyInjection; - -using Microsoft.Extensions.DependencyInjection; +using Microsoft.Extensions.DependencyInjection; using UltraSpeedBus.Abstractions.Contracts; using UltraSpeedBus.Abstractions.Mediator; using UltraSppedBus.Abstractions.Mediator; +namespace UltraSpeedBus.Extensions.DepedencyInjection; + public static class UltraSpeedBusExtensions { - public static IServiceCollection AddUltraSpeedBus( this IServiceCollection services) + public static IServiceCollection AddUltraSpeedBus(this IServiceCollection services) { services.AddSingleton(); diff --git a/src/UltraSpeedBus/Mediator/DynamicHandler.cs b/src/UltraSpeedBus/Mediator/DynamicHandler.cs new file mode 100644 index 0000000..c6ee9b5 --- /dev/null +++ b/src/UltraSpeedBus/Mediator/DynamicHandler.cs @@ -0,0 +1,33 @@ +using UltraSpeedBus.Abstractions.Contracts; + +namespace UltraSppedBus.Abstractions.Mediator; + +/// +/// Dynamic handler for events. +/// +public partial class UltraMediator +{ + private sealed class DynamicHandler : IDynamicHandler + { + private readonly UltraMediator _mediator; + private readonly Func, Task> _handler; + + public DynamicHandler( + UltraMediator mediator, + Func, Task> handler) + { + _mediator = mediator; + _handler = handler; + } + + public Type MessageType => typeof(T); + + public Task Handle(object message) + { + var ctx = new ConsumeContext((T)message); + return _handler(ctx); + } + + public void Disconnect() => _mediator.RemoveDynamicHandler(this); + } +} diff --git a/src/UltraSpeedBus/Mediator/UltraMediator.cs b/src/UltraSpeedBus/Mediator/UltraMediator.cs index 26c6ed4..7efa207 100644 --- a/src/UltraSpeedBus/Mediator/UltraMediator.cs +++ b/src/UltraSpeedBus/Mediator/UltraMediator.cs @@ -3,157 +3,130 @@ namespace UltraSppedBus.Abstractions.Mediator; -public class UltraMediator : IMediator +/// +/// The main mediator implementation. +/// +public partial class UltraMediator : IMediator { - private readonly Dictionary>> _commandHandlers = new(); - private readonly Dictionary>> _queryHandlers = new(); - private readonly Dictionary>> _eventHandlers = new(); - private readonly Dictionary> _dynamicHandlers = new(); - - #region Implement ISend - // Publisher 1 command x 1 Consumer - // Publisher 1 query x 1 Consumer + private readonly Dictionary>> _commandHandlers = new (); + private readonly Dictionary>> _queryHandlers = new (); + private readonly Dictionary>> _eventHandlers = new (); + private readonly Dictionary> _dynamicHandlers = new (); + public Task SendAsync(TRequest request) { - var type = typeof(TRequest); + Type type = typeof(TRequest); - if (_commandHandlers.TryGetValue(type, out var handler)) + if (_commandHandlers.TryGetValue(type, out Func>? handler)) { return InvokeHandler(handler, request); } - if (_queryHandlers.TryGetValue(type, out var queryHandler)) + if (_queryHandlers.TryGetValue(type, out Func>? queryHandler)) { return InvokeHandler(queryHandler, request); } throw new InvalidOperationException($"No handler registered for {type.Name}"); } - #endregion - #region Implement IPublish - // Publisher 1 x Many Consumers public Task PublishAsync(TEvent message) { - if (message == null) throw new ArgumentException(nameof(message)); + ArgumentNullException.ThrowIfNull(message); - var type = typeof(TEvent); + Type type = typeof(TEvent); var tasks = new List(); - if (_eventHandlers.TryGetValue(type, out var eventHandlers)) + if (_eventHandlers.TryGetValue(type, out List>? eventHandlers)) { - foreach (var handler in eventHandlers) + foreach (Func handler in eventHandlers) + { tasks.Add(handler(message)); + } } // You can disable this one - if (_dynamicHandlers.TryGetValue(type, out var dynamicEventHandlers)) + if (_dynamicHandlers.TryGetValue(type, out List? dynamicEventHandlers)) { - foreach (var handler in dynamicEventHandlers.OfType>()) + foreach (DynamicHandler handler in dynamicEventHandlers.OfType>()) + { tasks.Add(handler.Handle(message)); + } } return Task.WhenAll(tasks); } - #endregion - #region Implement IConsumerConnector public IHandlerHandle ConnectHandlerAsync(Func, Task> handler) { var dynamicHandler = new DynamicHandler(this, handler); lock (_dynamicHandlers) { - if (!_dynamicHandlers.TryGetValue(typeof(TMessage), out var list)) + if (!_dynamicHandlers.TryGetValue(typeof(TMessage), out List? list)) { list = new List(); _dynamicHandlers.Add(typeof(TMessage), list); } + list.Add(dynamicHandler); } + return dynamicHandler; } - #endregion - #region Implement IConsumerRegister public void RegisterCommandHandler(Func, Task> handler) - { - _commandHandlers[typeof(TCommand)] = async (object cmd) => + => _commandHandlers[typeof(TCommand)] = async (object cmd) => { var typed = (TCommand)cmd; var ctx = new CommandContext(typed); - var resp = await handler(ctx); + TResponse? resp = await handler(ctx); return resp!; }; - } public void RegisterQueryHandler(Func, Task> handler) - { - _queryHandlers[typeof(TQuery)] = async q => - { - var typed = (TQuery)q; - var ctx = new QueryContext(typed); - var resp = await handler(ctx); - return resp!; - }; - } + => _queryHandlers[typeof(TQuery)] = async q => + { + var typed = (TQuery)q; + var ctx = new QueryContext(typed); + TResponse? resp = await handler(ctx); + return resp!; + }; public void RegisterEventHandler(Func, Task> handler) { - if (!_eventHandlers.TryGetValue(typeof(TEvent), out var list)) - _eventHandlers[typeof(TEvent)] = list = new List>(); - } - #endregion - - private async Task InvokeHandler( - Func> handler, - TRequest request - ) - { - if (request is null) throw new ArgumentNullException(nameof(request)); - - var response = await handler(request); - return (TResponse)response; + if (!_eventHandlers.TryGetValue(typeof(TEvent), out _)) + { + _eventHandlers[typeof(TEvent)] = _ = new List>(); + } } internal void RemoveDynamicHandler(IDynamicHandler handler) { lock (_dynamicHandlers) { - if (_dynamicHandlers.TryGetValue(handler.MessageType, out var list)) + if (_dynamicHandlers.TryGetValue(handler.MessageType, out List? list)) { list.Remove(handler); if (list.Count == 0) + { _dynamicHandlers.Remove(handler.MessageType); + } } } } - private class DynamicHandler : IDynamicHandler + private static async Task InvokeHandler( + Func> handler, + TRequest request) { - private readonly UltraMediator _mediator; - private readonly Func, Task> _handler; - - public DynamicHandler( - UltraMediator mediator, - Func, Task> handler) - { - _mediator = mediator; - _handler = handler; - } - - public Type MessageType => typeof(T); - // Pensa em uma interface para este método futuramente. Melhore o design - public Task Handle(object msg) + if (request is null) { - var ctx = new ConsumeContext((T)msg); - return _handler(ctx); + throw new ArgumentNullException(nameof(request)); } - public void Disconnect() - { - _mediator.RemoveDynamicHandler(this); - } + object response = await handler(request); + return (TResponse)response; } } From aa3f79d213f66ba63703a54098e36eb62fcb81f5 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 21:59:33 -0300 Subject: [PATCH 09/16] feat: refactor CommandContext to use primary constructor for command initialization --- src/UltraSpeedBus.Abstractions/Context/CommandContext.cs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs b/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs index 97d29cd..56aa68f 100644 --- a/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs +++ b/src/UltraSpeedBus.Abstractions/Context/CommandContext.cs @@ -1,8 +1,6 @@ namespace UltraSpeedBus.Abstractions.Contracts; - -public class CommandContext +public class CommandContext(TCommand command) { - public TCommand Command { get; } - public CommandContext(TCommand command) => Command = command; + public TCommand Command { get; } = command; } From 8ebd544bede023d3cea5b97e4b8651eea3049b83 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 21:59:47 -0300 Subject: [PATCH 10/16] feat: remove unnecessary whitespace in IMediator interface --- src/UltraSpeedBus.Abstractions/Mediator/IMediator.cs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/UltraSpeedBus.Abstractions/Mediator/IMediator.cs b/src/UltraSpeedBus.Abstractions/Mediator/IMediator.cs index 4641035..3d85f4e 100644 --- a/src/UltraSpeedBus.Abstractions/Mediator/IMediator.cs +++ b/src/UltraSpeedBus.Abstractions/Mediator/IMediator.cs @@ -8,5 +8,4 @@ public interface IMediator : IConsumerConnector, IConsumerRegister { - -} \ No newline at end of file +} From 528538e20eda5694ab631b6c5d73f6b0d079e8b2 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 22:00:46 -0300 Subject: [PATCH 11/16] feat: add newlines for improved readability in IConsumerRegister interface --- src/UltraSpeedBus.Abstractions/Contracts/IConsumerRegister.cs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/UltraSpeedBus.Abstractions/Contracts/IConsumerRegister.cs b/src/UltraSpeedBus.Abstractions/Contracts/IConsumerRegister.cs index 70a85cb..0ac4c07 100644 --- a/src/UltraSpeedBus.Abstractions/Contracts/IConsumerRegister.cs +++ b/src/UltraSpeedBus.Abstractions/Contracts/IConsumerRegister.cs @@ -3,6 +3,8 @@ namespace UltraSpeedBus.Abstractions.Contracts; public interface IConsumerRegister { void RegisterCommandHandler(Func, Task> handler); + void RegisterQueryHandler(Func, Task> handler); + void RegisterEventHandler(Func, Task> handler); -} \ No newline at end of file +} From 19d7c8fec929833487605fbd7cab616009eedfb1 Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 22:01:21 -0300 Subject: [PATCH 12/16] feat: refactor ConsumeContext and EventContext to use primary constructor for message initialization --- src/UltraSpeedBus.Abstractions/Context/ConsumeContext.cs | 5 ++--- src/UltraSpeedBus.Abstractions/Context/EventContext.cs | 5 ++--- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/src/UltraSpeedBus.Abstractions/Context/ConsumeContext.cs b/src/UltraSpeedBus.Abstractions/Context/ConsumeContext.cs index be4822b..ae8c5c2 100644 --- a/src/UltraSpeedBus.Abstractions/Context/ConsumeContext.cs +++ b/src/UltraSpeedBus.Abstractions/Context/ConsumeContext.cs @@ -1,7 +1,6 @@ namespace UltraSpeedBus.Abstractions.Contracts; -public class ConsumeContext +public class ConsumeContext(T message) { - public T Message { get; } - public ConsumeContext(T message) => Message = message; + public T Message { get; } = message; } diff --git a/src/UltraSpeedBus.Abstractions/Context/EventContext.cs b/src/UltraSpeedBus.Abstractions/Context/EventContext.cs index 19bf5e4..ff319bf 100644 --- a/src/UltraSpeedBus.Abstractions/Context/EventContext.cs +++ b/src/UltraSpeedBus.Abstractions/Context/EventContext.cs @@ -1,7 +1,6 @@ namespace UltraSpeedBus.Abstractions.Contracts; -public class EventContext +public class EventContext(TEvent @event) { - public TEvent Event { get; } - public EventContext(TEvent @event) => Event = @event; + public TEvent Event { get; } = @event; } From 56a7c66bb472f4e35f8b917c02f44c2e4383c2dd Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 22:01:41 -0300 Subject: [PATCH 13/16] feat: refactor QueryContext to use primary constructor for query initialization --- src/UltraSpeedBus.Abstractions/Context/QueryContext.cs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/UltraSpeedBus.Abstractions/Context/QueryContext.cs b/src/UltraSpeedBus.Abstractions/Context/QueryContext.cs index 6228d40..2ea82ba 100644 --- a/src/UltraSpeedBus.Abstractions/Context/QueryContext.cs +++ b/src/UltraSpeedBus.Abstractions/Context/QueryContext.cs @@ -1,7 +1,6 @@ namespace UltraSpeedBus.Abstractions.Contracts; -public class QueryContext +public class QueryContext(TQuery query) { - public TQuery Query { get; } - public QueryContext(TQuery query) => Query = query; + public TQuery Query { get; } = query; } From 5518e4fe3154b02f53e81fbe7075663da534e54e Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 22:04:33 -0300 Subject: [PATCH 14/16] feat: standardize property naming to lowercase for consistency across command and query records --- .../CommandHandlers/CreateOrderHandler.cs | 6 ++-- .../EventHandler/OrderCreatedEventHandler.cs | 2 +- sample/UltraSpeedBus.WebAPI/Program.cs | 29 +++++++++---------- .../QueryHandler/GetOrderQueryHandler.cs | 6 ++-- 4 files changed, 20 insertions(+), 23 deletions(-) diff --git a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs index 6e9596a..012822b 100644 --- a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs @@ -2,9 +2,9 @@ namespace UltraSpeedBus.WebAPI.CommandHandler; -public sealed record CreateOrder(string Product, int Quantity); -public sealed record OrderResult(int OrderId); -public sealed record OrderCreated(int OrderId); +public sealed record CreateOrder(string product, int quantity); +public sealed record OrderResult(int orderId); +public sealed record OrderCreated(int orderId); public class CreateOrderHandler : ICommandHandler { diff --git a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs index 3460579..61e7713 100644 --- a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs @@ -7,7 +7,7 @@ public class OrderCreatedEventHandler : IEventProcessor { public Task Handle(EventContext context) { - Console.WriteLine($"[Event] Order created → Id = {context.Event.OrderId}"); + Console.WriteLine($"[Event] Order created → Id = {context.Event.orderId}"); return Task.CompletedTask; } } diff --git a/sample/UltraSpeedBus.WebAPI/Program.cs b/sample/UltraSpeedBus.WebAPI/Program.cs index fa04a89..bd52536 100644 --- a/sample/UltraSpeedBus.WebAPI/Program.cs +++ b/sample/UltraSpeedBus.WebAPI/Program.cs @@ -5,7 +5,7 @@ using UltraSpeedBus.WebAPI.EventHandler; using UltraSpeedBus.WebAPI.QueryHandler; -var builder = WebApplication.CreateBuilder(args); +WebApplicationBuilder builder = WebApplication.CreateBuilder(args); builder.Services.AddEndpointsApiExplorer(); builder.Services.AddSwaggerGen(); @@ -15,7 +15,7 @@ builder.Services.AddSingleton, GetOrderQueryHandler>(); builder.Services.AddSingleton, OrderCreatedEventHandler>(); -var app = builder.Build(); +WebApplication app = builder.Build(); if (app.Environment.IsDevelopment()) { @@ -25,32 +25,31 @@ app.UseHttpsRedirection(); -var mediator = app.Services.GetRequiredService(); +IMediator mediator = app.Services.GetRequiredService(); mediator.RegisterCommandHandler( - (ctx) => app.Services.GetRequiredService>().Handle(ctx) -); + (ctx) => app.Services.GetRequiredService>().Handle(ctx)); mediator.RegisterQueryHandler( - (ctx) => app.Services.GetRequiredService>().Handle(ctx) -); + (ctx) => app.Services.GetRequiredService>().Handle(ctx)); mediator.RegisterEventHandler( - (ctx) => app.Services.GetRequiredService>().Handle(ctx) -); + (ctx) => app.Services.GetRequiredService>().Handle(ctx)); app.MapPost("/orders", async (CreateOrder command, ISend sender) => { - var result = await sender.SendAsync(command); + OrderResult result = await sender.SendAsync(command); return Results.Ok(result); }); // GET /orders/{id} -> Send Query app.MapGet("/orders/{id:int}", async (int id, ISend sender) => { - var result = await sender.SendAsync(new GetOrder(id)); + OrderDto? result = await sender.SendAsync(new GetOrder(id)); if (result is null) + { return Results.NotFound(); + } return Results.Ok(result); }); @@ -63,9 +62,7 @@ }); // Example: Dynamic event consumer (runtime registration) -mediator.ConnectHandlerAsync(async ctx => -{ - Console.WriteLine($"[Dynamic Consumer] Order created with {ctx.Message.OrderId}"); -}); +mediator.ConnectHandlerAsync(async ctx + => Console.WriteLine($"[Dynamic Consumer] Order created with {ctx.Message.orderId}")); -app.Run(); +await app.RunAsync(); diff --git a/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs b/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs index d3e515b..5dac645 100644 --- a/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/QueryHandler/GetOrderQueryHandler.cs @@ -2,14 +2,14 @@ namespace UltraSpeedBus.WebAPI.QueryHandler; -public sealed record GetOrder(int OrderId); -public sealed record OrderDto(int OrderId, string Description); +public sealed record GetOrder(int orderId); +public sealed record OrderDto(int orderId, string description); public class GetOrderQueryHandler : IQueryHandler { public Task Handle(QueryContext context) { - if (context.Query.OrderId == 42) + if (context.Query.orderId == 42) { return Task.FromResult(new OrderDto(42, "Example Order")); } From 1d8b535d172e741aca59febf92ed732ae3cbad6f Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 22:12:21 -0300 Subject: [PATCH 15/16] feat: update .editorconfig to disable SA1200 and SA1516 diagnostics --- .editorconfig | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/.editorconfig b/.editorconfig index 2083db8..3d998f9 100644 --- a/.editorconfig +++ b/.editorconfig @@ -281,4 +281,6 @@ dotnet_diagnostic.CA2327.severity = none # IDE0046: Convert to conditional expression dotnet_diagnostic.IDE0046.severity = none -dotnet_diagnostic.SA1200.severity = none \ No newline at end of file +dotnet_diagnostic.SA1200.severity = none + +dotnet_diagnostic.SA1516.severity = none \ No newline at end of file From 9bb9a84f5d56b17c3bfa1c417b92419eb4de019d Mon Sep 17 00:00:00 2001 From: Yuri Melo Date: Thu, 27 Nov 2025 22:40:59 -0300 Subject: [PATCH 16/16] feat: update event handling for order creation and inventory addition --- .../CommandHandlers/CreateOrderHandler.cs | 10 +++++++++- .../EventHandler/InventoryEventHandler.cs | 13 +++++++++++++ .../EventHandler/OrderCreatedEventHandler.cs | 4 ++-- sample/UltraSpeedBus.WebAPI/Program.cs | 14 +++++++++----- 4 files changed, 33 insertions(+), 8 deletions(-) create mode 100644 sample/UltraSpeedBus.WebAPI/EventHandler/InventoryEventHandler.cs diff --git a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs index 012822b..20de683 100644 --- a/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/CommandHandlers/CreateOrderHandler.cs @@ -4,15 +4,23 @@ namespace UltraSpeedBus.WebAPI.CommandHandler; public sealed record CreateOrder(string product, int quantity); public sealed record OrderResult(int orderId); -public sealed record OrderCreated(int orderId); +public sealed record OrderCreatedEvent(int orderId); +public sealed record OrderAddedToInventoryEvent(int orderId, int quantity, string sku); public class CreateOrderHandler : ICommandHandler { + private readonly IPublish _mediator; + + public CreateOrderHandler(IPublish mediator) => _mediator = mediator; + public Task Handle(CommandContext request) { // Simula criação de pedido int generatedId = Random.Shared.Next(1000, 9999); + _mediator.PublishAsync(new OrderCreatedEvent(generatedId)); + _mediator.PublishAsync(new OrderAddedToInventoryEvent(generatedId, request.Command.quantity, request.Command.product)); + return Task.FromResult(new OrderResult(generatedId)); } } diff --git a/sample/UltraSpeedBus.WebAPI/EventHandler/InventoryEventHandler.cs b/sample/UltraSpeedBus.WebAPI/EventHandler/InventoryEventHandler.cs new file mode 100644 index 0000000..8739533 --- /dev/null +++ b/sample/UltraSpeedBus.WebAPI/EventHandler/InventoryEventHandler.cs @@ -0,0 +1,13 @@ +using UltraSpeedBus.Abstractions.Contracts; +using UltraSpeedBus.WebAPI.CommandHandler; + +namespace UltraSpeedBus.WebAPI.EventHandler; + +public class InventoryEventHandler : IEventProcessor +{ + public Task Handle(EventContext context) + { + Console.WriteLine($"[Event] Order added to inventoty → Id = {context.Event.orderId}, Quantity = {context.Event.quantity}, SKU = {context.Event.sku}"); + return Task.CompletedTask; + } +} diff --git a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs index 61e7713..9e3bdb1 100644 --- a/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs +++ b/sample/UltraSpeedBus.WebAPI/EventHandler/OrderCreatedEventHandler.cs @@ -3,9 +3,9 @@ namespace UltraSpeedBus.WebAPI.EventHandler; -public class OrderCreatedEventHandler : IEventProcessor +public class OrderCreatedEventHandler : IEventProcessor { - public Task Handle(EventContext context) + public Task Handle(EventContext context) { Console.WriteLine($"[Event] Order created → Id = {context.Event.orderId}"); return Task.CompletedTask; diff --git a/sample/UltraSpeedBus.WebAPI/Program.cs b/sample/UltraSpeedBus.WebAPI/Program.cs index bd52536..a3b4fa6 100644 --- a/sample/UltraSpeedBus.WebAPI/Program.cs +++ b/sample/UltraSpeedBus.WebAPI/Program.cs @@ -13,7 +13,8 @@ builder.Services.AddSingleton, CreateOrderHandler>(); builder.Services.AddSingleton, GetOrderQueryHandler>(); -builder.Services.AddSingleton, OrderCreatedEventHandler>(); +builder.Services.AddSingleton, OrderCreatedEventHandler>(); +builder.Services.AddSingleton, InventoryEventHandler>(); WebApplication app = builder.Build(); @@ -33,8 +34,8 @@ mediator.RegisterQueryHandler( (ctx) => app.Services.GetRequiredService>().Handle(ctx)); -mediator.RegisterEventHandler( - (ctx) => app.Services.GetRequiredService>().Handle(ctx)); +mediator.RegisterEventHandler( + (ctx) => app.Services.GetRequiredService>().Handle(ctx)); app.MapPost("/orders", async (CreateOrder command, ISend sender) => { @@ -57,12 +58,15 @@ // POST /simulate -> Publish Event directly app.MapPost("/simulate", async (IPublish publisher) => { - await publisher.PublishAsync(new OrderCreated(999)); + await publisher.PublishAsync(new OrderCreatedEvent(999)); return Results.Ok("Event Published"); }); // Example: Dynamic event consumer (runtime registration) -mediator.ConnectHandlerAsync(async ctx +mediator.ConnectHandlerAsync(async ctx => Console.WriteLine($"[Dynamic Consumer] Order created with {ctx.Message.orderId}")); +mediator.ConnectHandlerAsync(async ctx + => Console.WriteLine($"[Dynamic Consumer] Order added to inventory with {ctx.Message.orderId}, quantity: {ctx.Message.quantity}, sku: {ctx.Message.sku}")); + await app.RunAsync();