Add Tags to IExecutionContext

Changelog.md

@@ -1,5 +1,8 @@
 # Changelog
 
+## v.0.24.1
+- Add `Tags` to `IExecutionContext`.
+
 ## v.0.24.0
 - Upgraded to .NET 8.
 

src/Directory.Build.props

@@ -5,7 +5,7 @@
         <LangVersion>latest</LangVersion>
         <Authors>A. Shafie</Authors>
         <PackageTags>mediator;cqrs</PackageTags>
-        <VersionPrefix>0.24.0</VersionPrefix>
+        <VersionPrefix>0.24.1</VersionPrefix>
         <PackageIcon>icon.png</PackageIcon>
         <Description>LiteBus is an easy-to-use and ambitious in-process mediator providing the foundation to implement Command Query Separation (CQS). It is implemented with minimal reflection and instead utilizes covariance and contravariance to provide its core functionality.</Description>
         <PackageProjectUrl>https://github.com/litenova/LiteBus</PackageProjectUrl>

src/LiteBus.Messaging.Abstractions/Contexts/Execution/IExecutionContext.cs

@@ -19,4 +19,9 @@ public interface IExecutionContext
     /// Gets a key/value collection that can be used to share data within the scope of this execution.
     /// </summary>
     IDictionary<object, object?> Items { get; }
+
+    /// <summary>
+    /// Gets the collection of specified tags used to filter message handlers (i.e., pre, main and post) during mediation.
+    /// </summary>
+    IReadOnlyCollection<string> Tags { get; }
 }

src/LiteBus.Messaging/Internal/Contexts/Execution/ExecutionContext.cs

@@ -1,32 +1,28 @@
 #nullable enable
 
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using LiteBus.Messaging.Abstractions;
 
 namespace LiteBus.Messaging.Internal.Contexts.Execution;
 
-/// <summary>
-/// Represents the execution context for a specific operation or task.
-/// </summary>
+/// <inheritdoc cref="IExecutionContext"/> 
 internal sealed class ExecutionContext : IExecutionContext
 {
     /// <summary>
     /// Initializes a new instance of the <see cref="ExecutionContext"/> class with the specified cancellation token.
     /// </summary>
     /// <param name="cancellationToken">The cancellation token associated with the execution context.</param>
-    public ExecutionContext(CancellationToken cancellationToken)
+    public ExecutionContext(CancellationToken cancellationToken, IEnumerable<string> tags)
     {
         CancellationToken = cancellationToken;
+        Tags = tags.ToList();
     }
 
-    /// <summary>
-    /// Gets the cancellation token associated with the execution context.
-    /// </summary>
     public CancellationToken CancellationToken { get; }
 
-    /// <summary>
-    /// Gets or sets a key/value collection that can be used to share data within the scope of this execution.
-    /// </summary>
     public IDictionary<object, object?> Items { get; } = new Dictionary<object, object?>();
+
+    public IReadOnlyCollection<string> Tags { get; }
 }

src/LiteBus.Messaging/Internal/Mediator/MessageMediator.cs

@@ -25,7 +25,7 @@ public TMessageResult Mediate<TMessage, TMessageResult>(TMessage message,
         var originalExecutionContext = AmbientExecutionContext.Current;
 
         // Create a new execution context for the current scope
-        AmbientExecutionContext.Current = new ExecutionContext(options.CancellationToken);
+        AmbientExecutionContext.Current = new ExecutionContext(options.CancellationToken, options.Tags);
 
         // Get the actual type of the message
         var messageType = message.GetType();