Implement the NamingPolicy for the event of event storage

src/Configurations/BaseEventOptions.cs

@@ -1,6 +1,6 @@
 using System.Text.Json;
 using System.Text.Json.Serialization;
-using EventBus.RabbitMQ.Models;
+using EventStorage.Models;
 
 namespace EventBus.RabbitMQ.Configurations;
 

src/Configurations/RabbitMqHostSettings.cs

@@ -1,7 +1,7 @@
 using System.Reflection;
 using System.Security.Authentication;
 using System.Text.Json;
-using EventBus.RabbitMQ.Models;
+using EventStorage.Models;
 
 namespace EventBus.RabbitMQ.Configurations;
 
@@ -165,32 +165,13 @@ internal string GetCorrectEventNameBasedOnNamingPolicy(string eventName)
     /// <summary>
     /// Gets JsonNamingPolicy to use on naming police for serializing and deserializing the name of Event 
     /// </summary>
-    internal JsonNamingPolicy GetEventNamingPolicy()
+    private JsonNamingPolicy GetEventNamingPolicy()
     {
         if (_isEventNamingPolicyInitialized)
             return _eventNamingPolicy;
 
-        switch (EventNamingPolicy)
-        {
-            case NamingPolicyType.CamelCase:
-                _eventNamingPolicy = JsonNamingPolicy.CamelCase;
-                break;
-            case NamingPolicyType.SnakeCaseLower:
-                _eventNamingPolicy = JsonNamingPolicy.SnakeCaseLower;
-                break;
-            case NamingPolicyType.SnakeCaseUpper:
-                _eventNamingPolicy = JsonNamingPolicy.SnakeCaseUpper;
-                break;
-            case NamingPolicyType.KebabCaseLower:
-                _eventNamingPolicy = JsonNamingPolicy.KebabCaseLower;
-                break;
-            case NamingPolicyType.KebabCaseUpper:
-                _eventNamingPolicy = JsonNamingPolicy.KebabCaseUpper;
-                break;
-            default:
-                _eventNamingPolicy = null;
-                break;
-        }
+        var eventNamingPolicyType = EventNamingPolicy ?? NamingPolicyType.PascalCase;
+        _eventNamingPolicy = NamingPolicyTypeNames.GetEventNamingPolicy(eventNamingPolicyType.ToString());
 
         _isEventNamingPolicyInitialized = true;
 

src/Configurations/RabbitMqOptionsConstant.cs

@@ -1,5 +1,5 @@
 using System.Security.Authentication;
-using EventBus.RabbitMQ.Models;
+using EventStorage.Models;
 
 namespace EventBus.RabbitMQ.Configurations;
 

src/EventBus.RabbitMQ.csproj

@@ -18,7 +18,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="AlifCapital.EventStorage" Version="9.0.4" />
+        <PackageReference Include="AlifCapital.EventStorage" Version="9.0.6" />
         <PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="9.0.0" />
         <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.0" />
         <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="9.0.0" />

src/Subscribers/Consumers/EventConsumerService.cs

@@ -150,7 +150,7 @@ private async Task Consumer_Received(object sender, BasicDeliverEventArgs eventA
                             $"The RabbitMQ is configured to use the Inbox for received events, but the Inbox functionality of the EventStorage is not enabled. So, the {info.eventHandlerType.Name} event subscriber of an event will be executed immediately for the event id: {eventId};");
 
                     _ = eventReceiverManager.Received(eventId, info.eventType.Name, eventArgs.RoutingKey,
-                        EventProviderType.MessageBroker, payload: eventPayload, headers: headersAsJson);
+                        EventProviderType.MessageBroker, payload: eventPayload, headers: headersAsJson, namingPolicyType: info.eventSettings.PropertyNamingPolicy ?? NamingPolicyType.PascalCase);
                 }
                 else
                 {

tests/UnitTests/Subscribers/EventSubscriberOptionsTests.cs

@@ -1,6 +1,6 @@
 using EventBus.RabbitMQ.Configurations;
-using EventBus.RabbitMQ.Models;
 using EventBus.RabbitMQ.Subscribers.Options;
+using EventStorage.Models;
 using FluentAssertions;
 
 namespace EventBus.RabbitMQ.Tests.UnitTests.Subscribers;