Stratara.Mediator 4.3.1

Prefix Reserved
dotnet add package Stratara.Mediator --version 4.3.1
                    
NuGet\Install-Package Stratara.Mediator -Version 4.3.1
                    
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Stratara.Mediator" Version="4.3.1" />
                    
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="Stratara.Mediator" Version="4.3.1" />
                    
Directory.Packages.props
<PackageReference Include="Stratara.Mediator" />
                    
Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add Stratara.Mediator --version 4.3.1
                    
#r "nuget: Stratara.Mediator, 4.3.1"
                    
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
#:package Stratara.Mediator@4.3.1
                    
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=Stratara.Mediator&version=4.3.1
                    
Install as a Cake Addin
#tool nuget:?package=Stratara.Mediator&version=4.3.1
                    
Install as a Cake Tool

Stratara.Mediator

Derived. The behaviour described here is specified under openspec/specs/. Those specifications are the source; this page explains and illustrates them.

License: MIT.

In-process mediator with DI-resolved handlers and pipeline behaviors. Drop-in replacement for MediatR-style routing without the runtime cost of MethodInfo.Invoke — uses a typed wrapper cache and direct DI dispatch.

Quick start

services.AddMediator()
    .AddCommandHandlersFromAssemblyContaining<Program>()
    .AddQueryHandlersFromAssemblyContaining<Program>()
    .AddPipelineBehaviorWithResult(typeof(LoggingBehavior<,>))
    .AddPipelineBehavior(typeof(LoggingBehavior<>));

// Optional: wrap in authorization decorator
services.AddAuthorizingMediator<MyAuthorizationProvider>();

Every dispatch is traced as a span named Handle <RequestType>. The spans come from the Stratara.Application activity source — subscribe to it and they appear; register your own OpenTelemetry Tracer and the mediator uses that instead. Nothing has to be registered for the mediator to start.

IMediator is registered scoped. Resolve it from a scope (a request scope in ASP.NET Core, or an explicit IServiceProvider.CreateScope() in a console host) — resolving it from the root provider throws.

What's in the box

  • IMediator.HandleAsync<TResult>(IRequest<TResult>, CancellationToken) — routes queries and commands-with-result to IQueryHandler<TRequest, TResult> through any registered IPipelineBehavior<TRequest, TResult> chain.
  • IMediator.HandleAsync<TRequest>(TRequest, CancellationToken) — routes void commands to ICommandHandler<TRequest> through any registered IPipelineBehavior<TRequest> chain.
  • AuthorizingMediator decorator — checks [RequireRole] attributes via IAuthorizationProvider and [RequirePermission] attributes via IPermissionResolver (both AND) on the request's runtime type before delegating to the inner mediator. Its startup validator fails fast when a permission-guarded type is registered without an authorizing mediator or without a resolver, so a guard can never be silently skipped.
  • BucketLockPool — concurrency primitive that serialises IAggregateScopedCommand dispatch per bucket id. Used by message-bus consumers (e.g. the MediatorCommandWorker in Stratara.Outbox.RabbitMQ) to keep aggregate writes single-writer.

Pipeline behavior contract

Behaviors run outer-to-inner in DI registration order:

public sealed class LoggingBehavior<TRequest, TResult> : IPipelineBehavior<TRequest, TResult>
    where TRequest : IRequest<TResult>
{
    public async Task<TResult> HandleAsync(
        TRequest request, Func<Task<TResult>> next, CancellationToken cancellationToken)
    {
        // before
        var result = await next();
        // after
        return result;
    }
}

Tenant isolation

AddStrataraTenantIsolation() registers a pipeline behavior that enforces tenant isolation at the mediator entrance — before the handler runs — for any request that opts in by implementing the ITenantScopedRequest marker. Requests that do not implement the marker pass through untouched.

public sealed record GetCustomerQuery(Guid CustomerId, Guid TenantId)
    : IQuery<CustomerDto>, ITenantScopedRequest;

services
    .AddStrataraValidation()           // validation stays outermost
    .AddStrataraTenantIsolation();     // then tenant isolation

The behavior compares the request's TenantId (the data owner) against the ambient session's data-owner tenant (SessionContext.TenantId), not the actor tenant (SessionContext.ActorTenantId). A request whose payload names a different tenant than the established session subject is rejected with TenantAccessDeniedException (translated to HTTP 403 on ASP.NET hosts that register AddStrataraProblemDetails() from Stratara.ServiceDefaults.AspNetCore, or 401 for a caller that is not authenticated; surfaced through the message-failure path on workers).

Default vs. strict mode

  • TenantIsolationMode.Default — enforces only the subject match. A privileged cross-tenant operation (actor tenant ≠ data-owner tenant) passes, because the calling endpoint is expected to have promoted the session's data-owner tenant to the target before dispatch.
  • TenantIsolationMode.Strict — additionally routes every cross-tenant operation through an ICrossTenantAuthorizer. Stratara registers a deny-all default (via TryAdd), so strict mode rejects all cross-tenant access until you register your own authorizer that grants it:
services.AddStrataraTenantIsolation(o => o.Mode = TenantIsolationMode.Strict);
services.AddScoped<ICrossTenantAuthorizer, PlatformAdminCrossTenantAuthorizer>();
internal sealed class PlatformAdminCrossTenantAuthorizer(IHttpContextAccessor http)
    : ICrossTenantAuthorizer
{
    public ValueTask<bool> IsCrossTenantAllowedAsync(SessionContext session, CancellationToken ct) =>
        ValueTask.FromResult(http.HttpContext?.User.IsInRole("PlatformAdmin") ?? false);
}

The behavior runs both in-process (queries via IMediator at the endpoint, where HttpContext is available) and worker-side (commands dispatched through the outbox, where there is no HttpContext). An ICrossTenantAuthorizer that needs request-role state should be applied on the in-process path; the worker path must base its decision on the SessionContext alone.

Dependencies

  • Stratara.Abstractions — for IMediator/IRequest/ICommand/IQuery/IPipelineBehavior contracts, plus ITenantScopedRequest/ICrossTenantAuthorizer/TenantAccessDeniedException.
  • Stratara.Diagnostics — log-event IDs for the tenant-isolation behavior.
  • Microsoft.Extensions.DependencyInjection.Abstractions.
  • Microsoft.Extensions.Logging.Abstractions.
  • OpenTelemetry.Api — emits an Activity per dispatch under the Stratara.Application source.

No EF Core, no message bus, no event sourcing. Library-safe.

Product Compatible and additional computed target framework versions.
.NET net10.0 is compatible.  net10.0-android was computed.  net10.0-browser was computed.  net10.0-ios was computed.  net10.0-maccatalyst was computed.  net10.0-macos was computed.  net10.0-tvos was computed.  net10.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (3)

Showing the top 3 NuGet packages that depend on Stratara.Mediator:

Package Downloads
Stratara.Validation

Vendor-neutral request validation for the Stratara framework — a mediator pipeline behavior that runs IValidator<T> implementations before the handler and throws an aggregated StrataraValidationException on failure. No FluentValidation dependency; an optional adapter is shipped separately.

Stratara.Outbox.RabbitMQ

Outbox-pattern command and event dispatch for the Stratara event-sourced stack — RabbitMQ IMessageBus implementation, retry worker, mediator command worker, and Redis-coordinated projection-replay state. Azure Service Bus support ships as the sibling Stratara.Outbox.AzureServiceBus package.

Stratara.Infrastructure

Infrastructure glue for the Stratara framework — authorization decorators, configuration providers, and DI composition helpers that wire Mediator, Outbox, Identity, and EF Core into a hosted app.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last Updated
4.3.1 54 9/25/2026
4.3.0 342 9/23/2026
4.2.0 191 9/18/2026
4.1.1 128 9/16/2026
4.1.0 129 9/16/2026
4.0.4 946 9/14/2026
4.0.3 223 9/3/2026
4.0.2 654 9/3/2026
4.0.1 298 9/2/2026
4.0.0 681 8/31/2026
4.0.0-preview.1 88 8/31/2026
3.4.0 174 8/28/2026
3.3.0 377 8/25/2026
3.2.3 164 8/22/2026
3.2.2 774 8/14/2026
3.2.1 412 8/2/2026
3.2.0 166 7/18/2026
3.1.7 313 7/1/2026
3.1.6 589 6/22/2026
3.1.5 172 6/22/2026
Loading failed

A correctness release. A projection replay could apply a stream's later fact before its first and
then fail on every attempt, leaving the read models it had emptied empty; the two backfills that
prepare existing history for the Orleans execution model's commit-order readers took the same wrong
order. Beyond that, the setting store no longer needs declared settings, and a setting or permission
vocabulary can be declared in parts.

**Upgrading:**
- **If you replay projections, upgrade.** A store in which one save appended several versions of a
 stream can hold sequence numbers that run against those versions, and a replay over it could not
 complete. No entry is rewritten and no migration is needed.
- **If you implement `IEventStreamRepository` yourself,** override
 `GetManyAfterSequenceInStreamOrderAsync` to give your replay the same guarantee; the default keeps
 sequence order.
- **If you backfilled a store for a commit-order reader before this release,** the Orleans migration
 guide gives the query that tells whether that history holds a stream out of version order, and how
 to repair it.
- **A host that declared an empty `SettingCatalog` as a workaround can drop it.** A host that
 registers a catalog through a factory and then calls `AddSettingCatalog` or `AddPermissionCatalog`
 now fails at registration instead of replacing that catalog.
- No schema change.

### Added

- **`IEventStreamRepository.GetManyAfterSequenceInStreamOrderAsync`**: a range of the store in the order a
 replay applies it — each stream's entries in version order, the streams interleaved as their sequence numbers
 interleave them, and the range extended until it no longer ends between two versions of one stream. The default
 implementation returns `GetManyAfterSequenceAsync`, sequence order, so a repository of your own compiles and
 behaves as before; override the member to give your replay the guarantee.

### Fixed

- **A projection replay applies each stream in version order.** A save does not number its entries in version
 order — EF Core chooses the statement order and the identity column numbers the rows as they arrive — and the
 replay walked the store by sequence number, so it met a stream's later fact before its first. A projection that
 reports a missing preceding fact then failed the batch on every attempt, and because a replay empties the read
 models first, each attempt left the read side empty. On a store where many saves wrote several versions of one
 stream, no replay could complete. The replay now reads through the new repository member; a batch can hold more
 entries than `Projections:BatchSize`. No entry is rewritten and no migration is needed.
- **Both commit-order backfills keep each stream in version order.** `CommitTransactionIdBackfill` could end a
 batch between two versions of one stream, stamping the later one with the earlier transaction.
 `PartitionCounterBackfill` handed out positions in sequence order, so every save it positioned that the store
 had numbered against its versions was read inverted by the portable reader. Both now extend a batch until it no
 longer ends inside a stream, and the portable backfill positions each stream's entries in version order.
 History backfilled with an earlier version is not revisited, because checkpoints stand on its commit records and
 positions; the Orleans migration guide gives the query that tells whether a store holds such a stream.
- **The setting store works without declared settings.** `AddSettingStore<TContext>()` and
 `AddSettingStoreFromContextFactory<TContext>()` resolved the `SettingCatalog` inside a factory, so a
 host that registered the store and `AddStrataraErasure()` but declared no settings built, passed
 `ValidateOnBuild` and every start-up check, and failed on its first erasure with *No service for type
 `SettingCatalog` has been registered*. The store now registers an empty catalog when none is declared:
 the store works, erasure included, and reading any setting through `ISettingProvider` fails as
 undeclared. The example on `AddStrataraErasure` was exactly that composition. A host that declared an
 empty catalog as a workaround can drop it.
- **A second `AddSettingCatalog` or `AddPermissionCatalog` call no longer replaces the first.** Each
 call registered a new catalog and the last one won, so a host declaring its vocabulary per module kept
 only the last module's — the others' settings failed as undeclared and their permissions were denied
 without a word. Every call now adds to the one registered catalog, in whichever order it runs relative
 to the setting store. A setting name declared in two parts throws as a duplicate; a redeclared
 permission has no effect and grants to one role accumulate. A catalog registered as a factory cannot be
 added to, and the next call now throws `InvalidOperationException` saying so instead of replacing it.