Merge pull request #30 from uniteeio/feature/v10

v10

README.md

@@ -26,6 +26,7 @@ For now, we mainly focus on Redis as an event store because:
   - Scheduling messages
   - Treat pending messages at start
   - Recurring task (cron)
+  - Localized messages
 
 # How to use
 
@@ -144,13 +145,15 @@ services.AddTransient<IConsumer, UserRegisteredConsumer>();
 
 All consumers should be added using `AddTransient`. So, they all have their own scope since they are executed concurrently.
 
-If you want to your consumer to be able to reply, then, implement `IRedisStreamConsumerWithContext<TRequest, TResponse>` instead.
+If you want to your consumer to be able to reply or access metadata of the message, then, implement `IRedisStreamConsumerWithContext<TRequest, TResponse>` instead.
 
 ```csharp
-public class UserRegisteredConsumer : IRedisStreamConsumeWithContext<UserRegistered, MyResponse>
+public class UserRegisteredConsumer : IRedisStreamConsumeWithContext<UserRegistered, MyResponse> // Use object or anything if you didn't plan to respond to the message.
 {
     public async Task ConsumeAsync(UserRegistered message, IRedisStreamMessageContext context)
     {
+       _logger.LogInformation(context.Locale);
+
         await _email.Send(message.Email);
 
         await context.ReplyAsync(new MyResponse());

Unitee.EventDriven.Abstraction/Abstractions/IConsumer.cs

@@ -1,8 +1,8 @@
 namespace Unitee.EventDriven.Abstraction;
 
 /// <summary>
-/// Juste pour pouvoir récupérer la liste de tous les consumers depuis l'injection de dépendances.
-/// Ne doit jamais être implémenté directement sans passer par IConsummer<T>.
+/// Used to mark a class as a consumer.
+/// Should never be implemented directly without passing through IConsummer<T> / IConsumerWithContext<T> or IConsumerWithMetadata<T, TMetadata>
 /// </summary>
 public interface IConsumer { }
 
@@ -15,3 +15,4 @@ public interface IConsumer<T> : IConsumer
 {
     public Task ConsumeAsync(T message);
 }
+

Unitee.EventDriven.Abstraction/Abstractions/IMessageContext.cs

@@ -3,4 +3,4 @@ namespace Unitee.EventDriven.Abstraction;
 public interface IMessageContext<TReturn>
 {
     public Task<TReturn> ReplyAsync<TMessage>(TMessage message);
-}
+}

Unitee.EventDriven.Abstraction/Abstractions/IMessageHandler.cs

@@ -1,12 +1,17 @@
 namespace Unitee.EventDriven.Abstraction;
 
+
+///
+/// <summary>
+/// Used for Azure Service Bus messages only
+/// </summary>
 public interface IMessageHandler<T>
 {
     /// <summary>
-    /// Appelle le bon consumer enregistré pour le message de type T
+    /// Route to the right consumer.
     /// </summary>
     /// <returns>
-    /// True si un consumer a été trouvé et appelé, false sinon.
+    /// True if the message was handled, false otherwise.
     /// </returns>
     public Task<bool> HandleAsync(T originalMessage);
-}
+}

Unitee.EventDriven.Abstraction/Model/MessageOptions.cs

@@ -6,4 +6,6 @@ public record MessageOptions()
     public DateTimeOffset? ScheduledEnqueueTime { get; init; }
     public string? MessageId { get; init; }
     public string? SessionId { get; set; }
-}
+    public DateTimeOffset? ExpireAt { get; init; }
+    public string? Locale { get; init; }
+}

Unitee.EventDriven.Abstraction/Unitee.EventDriven.Abstraction.csproj

@@ -26,6 +26,7 @@
 
   <ItemGroup>
     <PackageReference Include="Azure.Messaging.ServiceBus" Version="7.15.0" />
+    <PackageReference Include="CSharpFunctionalExtensions" Version="2.40.0" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="7.0.0" />
     <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="7.0.0" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="7.0.1" />

Unitee.EventDriven.RedisStream.Tests.code-workspace

@@ -7,5 +7,7 @@
 			"path": "Unitee.EventDriven.RedisStream"
 		}
 	],
-	"settings": {}
+	"settings": {
+		"dotnet.defaultSolution": "/Users/tcreach/Documents/Projects/Unitee.EventDriven/Unitee.EventDriven.RedisStream.Tests/Unitee.EventDriven.RedisStream.Tests.sln"
+	}
 }