reprise /rɪˈpriːz/ noun [French] A repeated part of something, especially a piece of music
Reprise is a micro-framework that brings the REPR (Request-Endpoint-Response) pattern and vertical slice architecture into the ASP.NET Core 6/7 Minimal APIs. It aims to be unopinionated towards API behavior and to provide a thin layer of abstractions that encourages the creation of convention-based and modular implementations.
-
Create a new ASP.NET Core 6/7 empty project.
-
Install the Reprise NuGet package.
-
Add
Reprise
as a global using. -
Modify your
Program.cs
to use Reprise.
var builder = WebApplication.CreateBuilder();
builder.ConfigureServices();
var app = builder.Build();
app.UseExceptionHandling();
app.MapEndpoints();
app.Run();
- Create an endpoint
Endpoints/GetHelloEndpoint.cs
.
[Endpoint]
public class GetHelloEndpoint
{
[Get("/")]
public static string Handle() => "Hello, world!";
}
- Run the application.
An endpoint is a public class that is decorated with the EndpointAttribute
.
It should contain a public static Handle
method which should be decorated
with one of the HTTP method and route attributes. These are:
GetAttribute
PostAttribute
PutAttribute
PatchAttribute
DeleteAttribute
MapAttribute
- for other/multiple HTTP methods. You can derive your own attributes from this one.
The Handle
method can be synchronous as well as asynchronous and can have
any signature and any return type.
[Endpoint]
public class UpdateUserEndpoint
{
[Put("/users/{id}")]
public static IResult Handle(int id, UserDto userDto, DataContext context)
{
// ...
}
}
In the example id
comes from the route, userDto
- from the body, and
context
- from the DI container. Check
the documentation
for more information about parameter binding.
Reprise lets you modularize the setup of the DI container.
Any class (including an endpoint) that has a public parameterless constructor
and implements IServiceConfgurator
can configure services.
[Endpoint]
public class GetWeatherEndpoint : IServiceConfigurator
{
public void ConfigureServices(WebApplicationBuilder builder)
{
builder.Services.AddWeatherService();
}
[Get("/weather")]
public static async Task<WeatherForecast[]> Handle(IWeatherService weatherService)
{
return await weatherService.GetForecast();
}
}
You can bind a strongly typed hierarchical configuration using the ConfigurationAttribute
.
A simple example would look like this:
[Endpoint]
public class GetGreetingsEndpoint
{
[Get("/greetings")]
public static IEnumerable<string> Handle(GreetingConfiguration configuration)
{
return configuration.Names.Select(name => string.Format(configuration.Message, name));
}
}
[Configuration("Greeting")]
public class GreetingConfiguration
{
public string Message { get; set; } = null!;
public List<string> Names { get; set; } = null!;
}
The GreetingConfiguration
is added to the DI container with a singleton lifetime and
is bound to the following section in appsettings.json
:
{
"Greeting": {
"Message": "Hello, {0}!",
"Names": [ "Alice", "John", "Skylar" ]
}
}
Deeper nested sub-sections could as well be bound using a key like "Foo:Bar"
. Check
the documentation
for more information about configuration.
Reprise supports global and endpoint-specific filters that implement IEndpointFilter
.
The filter execution order is determined by an order value that is set implicitly or explicitly. A higher value means the filter will be executed after the ones with a lower value. Filters having equal order values are run in an arbitrary order.
Global filters are implicitly assigned an incrementing order value starting from 0
according to the registration order.
app.MapEndpoints(options =>
{
options.AddEndpointFilter<FilterA>(); // implicit order 0
options.AddEndpointFilter<FilterB>(); // implicit order 1
options.AddEndpointFilter<FilterC>(); // implicit order 2
options.AddEndpointFilter<FilterD>(100); // explicit order 100
});
Endpoint-specific filters are implicitly assigned an order value of int.MaxValue
.
[Endpoint]
public class DeleteUserEndpoint
{
[Delete("/users/{id}")]
[Filter(typeof(FilterE))] // implicit order int.MaxValue
[Filter(typeof(FilterF))] // implicit order int.MaxValue
[Filter(typeof(FilterG), -1)] // explicit order -1
public static IResult Handle(int id, DataContext context)
{
// ...
}
}
Check the documentation for more information about filters.
Reprise relies on FluentValidation. On application startup, all IValidator<T>
implementations are
added with a singleton lifetime. You can then inject the validator in your Handle
method.
[Endpoint]
public class CreateUserEndpoint
{
[Post("/users")]
public static IResult Handle(UserDto userDto, IValidator<UserDto> validator, DataContext context)
{
validator.ValidateAndThrow(userDto);
// ...
}
}
public class UserDtoValidator : AbstractValidator<UserDto>
{
public UserDtoValidator()
{
RuleFor(u => u.FirstName).NotEmpty();
RuleFor(u => u.LastName).NotEmpty();
}
}
Check the documentation for more information about FluentValidation.
It's also possible to add a global validation filter. This way, you don't need to manually inject validators and validate.
app.MapEndpoints(options => options.AddValidationFilter());
The filter is registered using an endpoint filter factory, so it will be invoked only on endpoints having one or more parameters that are validatable.
Reprise offers an easy way to do object-to-object mapping. On application startup, all IMapper<T1, T2>
implementations are
added with a singleton lifetime. You can then inject the mapper in your Handle
method.
[Endpoint]
public class CreateUserEndpoint
{
[Post("/users")]
public static IResult Handle(UserDto userDto, IMapper<User, UserDto> mapper, DataContext context)
{
var user = mapper.Map(userDto);
// ...
}
}
public class UserMapper : IMapper<User, UserDto>
{
public User Map(UserDto source) => new User(source.FirstName, source.LastName);
public UserDto Map(User source) => throw new NotImplementedException();
public void Map(UserDto source, User destination) => throw new NotImplementedException();
public void Map(User source, UserDto destination) => throw new NotImplementedException();
}
By default, the exception handler returns no body and:
- On
BadHttpRequestException
(e.g. thrown when the request body couldn't be deserialized) logs an error and returns status code400
. - On
ValidationException
returns status code400
. - On all other exceptions logs an error and returns status code
500
.
To customize exception logging, you can implement IExceptionLogger
.
Similarly, you can customize the response body by implementing IErrorResponseFactory
.
There are two ways to secure your API. You can require authorization only for specific
endpoints by decorating the Handle
method with the AuthorizeAttribute
from
Microsoft.AspNetCore.Authorization
. Alternatively, you can require authorization
for all endpoints and opt-out for specific ones using the AllowAnonymousAttribute
.
app.MapEndpoints(options => options.RequireAuthorization());
Check the documentation for more information about authentication and authorization.
The CORS middleware and attributes work with Reprise exactly the same way as when using pure Minimal APIs.
Check the documentation for more information about CORS.
There are two ways to set rate limits for your API. You can rate limit only specific
endpoints by decorating the Handle
method with the EnableRateLimitingAttribute
from
Microsoft.AspNetCore.RateLimiting
. Alternatively, you can set rate limits
for all endpoints and opt-out for specific ones using the DisableRateLimitingAttribute
.
app.MapEndpoints(options => options.RequireRateLimiting("FixedWindowOneSecond"));
Check the documentation for more information about rate limiting.
You can enhance the OpenAPI description of your endpoints by decorating the Handle
method with attributes.
-
TagsAttribute
assigns custom tags that are typically used to group operations in the Swagger UI. If no attribute is found, Reprise extracts a tag from the route of every endpoint. The first segment that is not "api" (case insensitive) or a parameter is capitalized and set as a tag. "/" is used when no match is found. -
NameAttribute
assigns a name that is used for link generation and is also treated as the operation ID in the OpenAPI description. -
ProducesAttribute
describes a response returned from an API endpoint. You can derive your own attributes from this one. NB: Make sure you are using the Reprise' attribute and not the one fromMicrosoft.AspNetCore.Mvc
. -
ExcludeFromDescriptionAttribute
marks an endpoint that is excluded from the OpenAPI description.
Check the documentation for more information about OpenAPI.
Events provide an elegant way to do some work using the publish-subscribe pattern. An event is handled by one or more handlers in parallel. All event handlers are added to the DI container with a scoped lifetime.
public record Greeting(string Message) : IEvent;
public class GreetingHandler : IEventHandler<Greeting>
{
private readonly ILogger<GreetingHandler> _Logger;
public GreetingHandler(ILogger<GreetingHandler> logger)
{
_Logger = logger;
}
public async Task Handle(Greeting payload, CancellationToken cancellationToken)
{
await Task.Delay(1_000, cancellationToken);
_Logger.LogInformation("Received greeting with message: {Message}", payload.Message);
}
}
You can publish events via the IEventBus
. It has two methods:
-
Publish
does not wait for the handlers to finish execution. All matching handlers are resolved in a newIServiceScope
.IHostApplicationLifetime.ApplicationStopping
is passed to the handlers as a cancellation token. If a handler throws, the exception is logged. -
PublishAndWait
waits for all handlers to finish execution. All matching handlers are resolved in the currentIServiceScope
. If one or more handlers throw, all exceptions are packed into anAggregateException
.
Jobs are an easy way to do work in the background. They implement IJob
and are added
to the DI container with a scoped lifetime.
[Cron("* * * * *")]
public class HeartbeatJob : IJob
{
private readonly ILogger<HeartbeatJob> _Logger;
public HeartbeatJob(ILogger<HeartbeatJob> logger)
{
_Logger = logger;
}
public Task Run(CancellationToken cancellationToken)
{
_Logger.LogInformation("HeartbeatJob invoked.");
return Task.CompletedTask;
}
}
A job can have one or more triggers. They are set via attributes:
-
RunBeforeStartAttribute
marks a job to be run before the app's request processing pipeline is configured andIApplicationLifetime.ApplicationStarted
is triggered. All such jobs run in parallel. -
RunOnStartAttribute
marks a job that runs after the server is started. -
CronAttribute
marks a job that runs on a schedule defined via a cron expression. You can derive your own attributes from this one. Check the documentation for more details on the cron expression syntax.
Regardless of its triggers, every job runs in its own scope.
Reprise tries to make sure the API will behave exactly the way you would expect. For this reason,
it performs various self-checks on application startup and throws an InvalidOperationException
when a problem is encountered. The problems covered by those checks include:
- Programming errors (e.g., an endpoint has no public static
Handle
method) - Misconfigurations (e.g., a configuration model could not be bound)
- Code duplications (e.g., a model is validated by multiple validators)
- Ambiguities (e.g., an HTTP method and route combination is handled by more than one endpoint).
Besides the assembly scan at application startup when configuring the DI container and discovering endpoints, Reprise doesn't add any performance overhead when handling requests.
Method | Mean | Error | StdDev | Gen0 | Gen1 | Allocated |
---|---|---|---|---|---|---|
Reprise | 4.520 ms | 0.3130 ms | 0.9228 ms | 31.2500 | 31.2500 | 306.06 KB |
Carter | 4.254 ms | 0.2409 ms | 0.7102 ms | 31.2500 | 31.2500 | 263.99 KB |
FastEndpoints | 5.517 ms | 0.4689 ms | 1.3825 ms | 31.2500 | 31.2500 | 359.46 KB |
MinimalApis | 4.193 ms | 0.2336 ms | 0.6888 ms | 31.2500 | 31.2500 | 283.74 KB |
Method | Mean | Error | StdDev | Gen0 | Allocated |
---|---|---|---|---|---|
Reprise | 118.4 μs | 1.24 μs | 1.16 μs | 5.6152 | 17.01 KB |
Carter | 119.4 μs | 0.66 μs | 0.55 μs | 5.3711 | 16.51 KB |
FastEndpoints | 126.3 μs | 2.19 μs | 2.05 μs | 5.8594 | 17.84 KB |
MinimalApis | 121.1 μs | 0.93 μs | 0.77 μs | 5.3711 | 16.54 KB |
For bug reports and feature requests, please use the issue tracker. For questions, ideas and other topics, please check the discussions.