Skip to content

Commit 00c6d37

Browse files
stevsharpstevsharp
committed
.
1 parent 0961cf4 commit 00c6d37

21 files changed

+303
-0
lines changed

‎ApiPerfComparison.sln

+9
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "TestProject1", "TestProject
1111
EndProject
1212
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "TestJwt", "TestJwt\TestJwt.csproj", "{1B49B886-C6F0-44D1-8727-9E1272CC317B}"
1313
EndProject
14+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MinimalApiUsingMediatR", "MinimalApiUsingMediatR\MinimalApiUsingMediatR.csproj", "{FB10C2D3-CE4D-43FD-B932-CFA7AD79B3C6}"
15+
EndProject
1416
Global
1517
GlobalSection(SolutionConfigurationPlatforms) = preSolution
1618
Debug|Any CPU = Debug|Any CPU
@@ -33,8 +35,15 @@ Global
3335
{1B49B886-C6F0-44D1-8727-9E1272CC317B}.Debug|Any CPU.Build.0 = Debug|Any CPU
3436
{1B49B886-C6F0-44D1-8727-9E1272CC317B}.Release|Any CPU.ActiveCfg = Release|Any CPU
3537
{1B49B886-C6F0-44D1-8727-9E1272CC317B}.Release|Any CPU.Build.0 = Release|Any CPU
38+
{FB10C2D3-CE4D-43FD-B932-CFA7AD79B3C6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
39+
{FB10C2D3-CE4D-43FD-B932-CFA7AD79B3C6}.Debug|Any CPU.Build.0 = Debug|Any CPU
40+
{FB10C2D3-CE4D-43FD-B932-CFA7AD79B3C6}.Release|Any CPU.ActiveCfg = Release|Any CPU
41+
{FB10C2D3-CE4D-43FD-B932-CFA7AD79B3C6}.Release|Any CPU.Build.0 = Release|Any CPU
3642
EndGlobalSection
3743
GlobalSection(SolutionProperties) = preSolution
3844
HideSolutionNode = FALSE
3945
EndGlobalSection
46+
GlobalSection(ExtensibilityGlobals) = postSolution
47+
SolutionGuid = {4F59DEDD-6854-41F0-88A4-FDADBC4D3A34}
48+
EndGlobalSection
4049
EndGlobal

‎MinimalApiUsingMediatR/Commaand/CreateContactCommand.cs

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
using MediatR;
2+
3+
using MinimalApiUsingMediatR.Model;
4+
5+
namespace MinimalApiUsingMediatR.Commaand;
6+
7+
public record CreateContactCommand(string Name, string Email) : IRequest<ContactItem>;

‎MinimalApiUsingMediatR/Commaand/DeleteContactCommand.cs

+5
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
using MediatR;
2+
3+
namespace MinimalApiUsingMediatR.Commaand;
4+
5+
public record DeleteContactCommand(int Id) : IRequest<bool>;

‎MinimalApiUsingMediatR/Commaand/UpdateContactCommand.cs

+10
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
using MediatR;
2+
3+
namespace MinimalApiUsingMediatR.Commaand;
4+
5+
public record UpdateContactCommand : IRequest<bool>
6+
{
7+
public int Id { get; set; }
8+
public string Name { get; set; }
9+
public string Email { get; set; }
10+
}

‎MinimalApiUsingMediatR/DbContext/AppDbContext.cs

+11
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
using Microsoft.EntityFrameworkCore;
2+
3+
using MinimalApiUsingMediatR.Model;
4+
5+
namespace MinimalApiUsingMediatR;
6+
7+
public class AppDbContext : DbContext
8+
{
9+
public AppDbContext(DbContextOptions<AppDbContext> options) : base(options) { }
10+
public DbSet<ContactItem> Contacts { get; set; }
11+
}

‎MinimalApiUsingMediatR/Endpoints/ContactItems.cs

+21
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
using MediatR;
2+
using MinimalApiUsingMediatR.Commaand;
3+
using MinimalApiUsingMediatR.Query;
4+
5+
namespace MinimalApiUsingMediatR.Endpoints;
6+
7+
public static class ContactEndpoints
8+
{
9+
public static void MapContactEndpoints(this WebApplication app)
10+
{
11+
app.MapGet("/contacts", async (IMediator mediator) => await mediator.Send(new GetContactsQuery()));
12+
app.MapGet("/contacts/{id}", async (IMediator mediator, int id) => await mediator.Send(new GetContactByIdQuery(id)));
13+
app.MapPost("/contacts", async (IMediator mediator, CreateContactCommand command) => await mediator.Send(command));
14+
app.MapPut("/contacts/{id}", async (IMediator mediator, int id, UpdateContactCommand command) =>
15+
{
16+
command.Id = id;
17+
return await mediator.Send(command);
18+
});
19+
app.MapDelete("/contacts/{id}", async (IMediator mediator, int id) => await mediator.Send(new DeleteContactCommand(id)));
20+
}
21+
}

‎MinimalApiUsingMediatR/Handlers/CreateContactHandler.cs

+19
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
using MediatR;
2+
3+
using MinimalApiUsingMediatR.Commaand;
4+
using MinimalApiUsingMediatR.Model;
5+
6+
namespace MinimalApiUsingMediatR.Handlers;
7+
8+
public class CreateContactHandler(AppDbContext context) : IRequestHandler<CreateContactCommand, ContactItem>
9+
{
10+
private readonly AppDbContext _context = context;
11+
12+
public async Task<ContactItem> Handle(CreateContactCommand request, CancellationToken cancellationToken)
13+
{
14+
var contact = new ContactItem { Name = request.Name, Email = request.Email };
15+
_context.Contacts.Add(contact);
16+
await _context.SaveChangesAsync(cancellationToken);
17+
return contact;
18+
}
19+
}

‎MinimalApiUsingMediatR/Handlers/DeleteContactHandler.cs

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
using MediatR;
2+
3+
using MinimalApiUsingMediatR.Commaand;
4+
5+
namespace MinimalApiUsingMediatR.Handlers
6+
{
7+
public class DeleteContactHandler(AppDbContext context) : IRequestHandler<DeleteContactCommand, bool>
8+
{
9+
private readonly AppDbContext _context = context;
10+
11+
public async Task<bool> Handle(DeleteContactCommand request, CancellationToken cancellationToken)
12+
{
13+
var contact = await _context.Contacts.FindAsync([request.Id], cancellationToken);
14+
if (contact == null) return false;
15+
_context.Contacts.Remove(contact);
16+
await _context.SaveChangesAsync(cancellationToken);
17+
return true;
18+
}
19+
}
20+
}

‎MinimalApiUsingMediatR/Handlers/GetContactByIdHandler.cs

+15
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
using MediatR;
2+
3+
using MinimalApiUsingMediatR.Model;
4+
using MinimalApiUsingMediatR.Query;
5+
6+
namespace MinimalApiUsingMediatR.Handlers
7+
{
8+
public class GetContactByIdHandler(AppDbContext context) : IRequestHandler<GetContactByIdQuery, ContactItem>
9+
{
10+
private readonly AppDbContext _context = context;
11+
12+
public async Task<ContactItem> Handle(GetContactByIdQuery request, CancellationToken cancellationToken)
13+
=> await _context.Contacts.FindAsync([request.Id], cancellationToken);
14+
}
15+
}

‎MinimalApiUsingMediatR/Handlers/GetContactsHandler.cs

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
using MediatR;
2+
3+
using Microsoft.EntityFrameworkCore;
4+
5+
using MinimalApiUsingMediatR.Model;
6+
using MinimalApiUsingMediatR.Query;
7+
8+
namespace MinimalApiUsingMediatR.Handlers;
9+
10+
public class GetContactsHandler(AppDbContext context) : IRequestHandler<GetContactsQuery, List<ContactItem>>
11+
{
12+
private readonly AppDbContext _context = context;
13+
14+
public async Task<List<ContactItem>> Handle(GetContactsQuery request, CancellationToken cancellationToken)
15+
=> await _context.Contacts.ToListAsync(cancellationToken);
16+
}

‎MinimalApiUsingMediatR/Handlers/UpdateContactHandler.cs

+25
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
using MediatR;
2+
using Microsoft.EntityFrameworkCore;
3+
4+
using MinimalApiUsingMediatR.Commaand;
5+
using MinimalApiUsingMediatR.Model;
6+
using MinimalApiUsingMediatR.Query;
7+
8+
namespace MinimalApiUsingMediatR.Handlers;
9+
10+
public class UpdateContactHandler(AppDbContext context) : IRequestHandler<UpdateContactCommand, bool>
11+
{
12+
private readonly AppDbContext _context = context;
13+
14+
public async Task<bool> Handle(UpdateContactCommand request, CancellationToken cancellationToken)
15+
{
16+
var contact = await _context.Contacts.FindAsync([request.Id], cancellationToken);
17+
if (contact == null) return false;
18+
19+
contact.Name = request.Name;
20+
contact.Email = request.Email;
21+
22+
return (await _context.SaveChangesAsync(cancellationToken)) > 0;
23+
24+
}
25+
}

‎MinimalApiUsingMediatR/MinimalApiUsingMediatR.csproj

+18
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
<Project Sdk="Microsoft.NET.Sdk.Web">
2+
3+
<PropertyGroup>
4+
<TargetFramework>net9.0</TargetFramework>
5+
<Nullable>enable</Nullable>
6+
<ImplicitUsings>enable</ImplicitUsings>
7+
</PropertyGroup>
8+
9+
<ItemGroup>
10+
<PackageReference Include="MediatR" Version="12.4.1" />
11+
<PackageReference Include="MediatR.Extensions.Microsoft.DependencyInjection" Version="11.1.0" />
12+
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.2" />
13+
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.2" />
14+
<PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="9.0.2" />
15+
<PackageReference Include="Swashbuckle.AspNetCore" Version="7.2.0" />
16+
</ItemGroup>
17+
18+
</Project>

‎MinimalApiUsingMediatR/MinimalApiUsingMediatR.csproj.user

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
<?xml version="1.0" encoding="utf-8"?>
2+
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
3+
<PropertyGroup>
4+
<ActiveDebugProfile>https</ActiveDebugProfile>
5+
</PropertyGroup>
6+
</Project>

‎MinimalApiUsingMediatR/MinimalApiUsingMediatR.http

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
@MinimalApiUsingMediatR_HostAddress = http://localhost:5179
2+
3+
GET {{MinimalApiUsingMediatR_HostAddress}}/weatherforecast/
4+
Accept: application/json
5+
6+
###

‎MinimalApiUsingMediatR/Model/ContactItem.cs

+8
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
namespace MinimalApiUsingMediatR.Model;
2+
3+
public class ContactItem
4+
{
5+
public int Id { get; set; }
6+
public string Name { get; set; }
7+
public string Email { get; set; }
8+
}

‎MinimalApiUsingMediatR/Program.cs

+54
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,54 @@
1+
using MediatR;
2+
3+
using Microsoft.EntityFrameworkCore;
4+
using Microsoft.OpenApi.Models;
5+
6+
using MinimalApiUsingMediatR;
7+
using MinimalApiUsingMediatR.Endpoints;
8+
9+
using System.Reflection;
10+
11+
try
12+
{
13+
14+
var builder = WebApplication.CreateBuilder(args);
15+
16+
// Add services to the container.
17+
// Learn more about configuring OpenAPI at https://aka.ms/aspnet/openapi
18+
builder.Services.AddEndpointsApiExplorer();
19+
builder.Services.AddSwaggerGen(c =>
20+
21+
22+
{
23+
c.SwaggerDoc("v1", new OpenApiInfo { Title = "Minimal API Using MediatR", Version = "v1" });
24+
});
25+
26+
27+
builder.Services.AddDbContext<AppDbContext>(options =>
28+
options.UseInMemoryDatabase("ContactsDb"));
29+
builder.Services.AddMediatR(cfg => cfg.RegisterServicesFromAssemblies(Assembly.GetExecutingAssembly()));
30+
31+
var app = builder.Build();
32+
33+
app.MapContactEndpoints();
34+
35+
// Configure the HTTP request pipeline.
36+
if (app.Environment.IsDevelopment())
37+
{
38+
app.UseSwagger();
39+
app.UseSwaggerUI(c => c.SwaggerEndpoint("/swagger/v1/swagger.json", "Minimal API Using MediatR v1"));
40+
app.MapOpenApi();
41+
}
42+
43+
app.UseHttpsRedirection();
44+
45+
app.Run();
46+
}
47+
catch (Exception ex)
48+
{
49+
var exception = ex;
50+
throw;
51+
}
52+
53+
54+

‎MinimalApiUsingMediatR/Properties/launchSettings.json

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
{
2+
"$schema": "https://json.schemastore.org/launchsettings.json",
3+
"profiles": {
4+
"http": {
5+
"commandName": "Project",
6+
"dotnetRunMessages": true,
7+
"launchBrowser": true,
8+
"applicationUrl": "http://localhost:5179",
9+
"environmentVariables": {
10+
"ASPNETCORE_ENVIRONMENT": "Development"
11+
}
12+
},
13+
"https": {
14+
"commandName": "Project",
15+
"dotnetRunMessages": true,
16+
"launchBrowser": true,
17+
"applicationUrl": "https://localhost:7212;http://localhost:5179",
18+
"environmentVariables": {
19+
"ASPNETCORE_ENVIRONMENT": "Development"
20+
}
21+
}
22+
}
23+
}

‎MinimalApiUsingMediatR/Query/GetContactByIdQuery.cs

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
using MediatR;
2+
using MinimalApiUsingMediatR.Model;
3+
4+
namespace MinimalApiUsingMediatR.Query;
5+
6+
public record GetContactByIdQuery(int Id) : IRequest<ContactItem>;

‎MinimalApiUsingMediatR/Query/GetContactsQuery.cs

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
using MediatR;
2+
3+
using MinimalApiUsingMediatR.Model;
4+
5+
namespace MinimalApiUsingMediatR.Query;
6+
7+
public record GetContactsQuery : IRequest<List<ContactItem>>;

‎MinimalApiUsingMediatR/appsettings.Development.json

+8
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
{
2+
"Logging": {
3+
"LogLevel": {
4+
"Default": "Information",
5+
"Microsoft.AspNetCore": "Warning"
6+
}
7+
}
8+
}

‎MinimalApiUsingMediatR/appsettings.json

+9
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
{
2+
"Logging": {
3+
"LogLevel": {
4+
"Default": "Information",
5+
"Microsoft.AspNetCore": "Warning"
6+
}
7+
},
8+
"AllowedHosts": "*"
9+
}

0 commit comments

Comments
 (0)