elias/booking-microservices
1
0
Fork 0
mirror of https://github.com/meysamhadeli/booking-microservices.git synced 2026-04-11 10:32:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

- add rate limit

Browse Source 
- refactor Program.cs
This commit is contained in:
meysamhadeli 2022-11-17 14:33:48 +03:30
parent 18f4d417a9
commit 17541fd3b4
24 changed files with 485 additions and 359 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
src/Services/Booking/src/Booking.Api/Program.cs
View File

@ -1,6 +1,7 @@
using Booking;
using Booking.Data;
using Booking.Extensions;
using Booking.Extensions.Infrastructure;
using BuildingBlocks.EventStoreDB;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
@ -21,66 +22,16 @@ using Prometheus;
using Serilog;
var builder = WebApplication.CreateBuilder(args);
var configuration = builder.Configuration;
var env = builder.Environment;
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddPersistMessage(configuration);
builder.Services.AddMongoDbContext<BookingReadDbContext>(configuration);
builder.AddCustomSerilog(env);
builder.Services.AddCore();
builder.Services.AddJwt();
builder.Services.AddHttpContextAccessor();
builder.Services.AddCustomSwagger(configuration, typeof(BookingRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(BookingRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(BookingRoot).Assembly);
builder.Services.AddCustomHealthCheck();
builder.Services.AddCustomMassTransit(typeof(BookingRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
builder.Services.AddTransient<AuthHeaderHandler>();
SnowFlakIdGenerator.Configure(3);
// ref: https://github.com/oskardudycz/EventSourcing.NetCore/tree/main/Sample/EventStoreDB/ECommerce
builder.Services.AddEventStore(configuration, typeof(BookingRoot).Assembly)
.AddEventStoreDBSubscriptionToAll();
builder.Services.AddGrpcClients();
builder.AddMinimalEndpoints();
builder.AddInfrastructure();
var app = builder.Build();
app.UseSerilogRequestLogging();
app.UseCorrelationId();
app.UseRouting();
app.UseHttpMetrics();
app.UseHttpsRedirection();
app.MapMinimalEndpoints();
app.UseAuthentication();
app.UseAuthorization();
app.UseProblemDetails();
app.UseCustomHealthCheck();
app.MapMinimalEndpoints();
app.UseEndpoints(endpoints =>
{
endpoints.MapMetrics();
});
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (app.Environment.IsDevelopment())
{
app.UseCustomSwagger();
}
app.UseInfrastructure();
app.Run();

23
src/Services/Booking/src/Booking/Extensions/CoreExtensions.cs
View File

@ -1,23 +0,0 @@
using BuildingBlocks.Core;
using BuildingBlocks.Utils;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
namespace Booking.Extensions;
public static class CoreExtensions
{
public static IServiceCollection AddCore(this IServiceCollection services)
{
services.AddScoped<ICurrentUserProvider, CurrentUserProvider>();
services.AddScoped<IEventMapper, EventMapper>();
services.AddScoped<IEventDispatcher, EventDispatcher>();
services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
return services;
}
}

2
src/Services/Booking/src/Booking/Extensions/GrpcClientExtensions.cs → src/Services/Booking/src/Booking/Extensions/Infrastructure/GrpcClientExtensions.cs
View File

@ -4,7 +4,7 @@ using Flight;
using Microsoft.Extensions.DependencyInjection;
using Passenger;
namespace Booking.Extensions;
namespace Booking.Extensions.Infrastructure;
public static class GrpcClientExtensions
{

113
src/Services/Booking/src/Booking/Extensions/Infrastructure/InfrastructureExtensions.cs Normal file
View File

@ -0,0 +1,113 @@
using System.Threading.RateLimiting;
using Booking.Data;
using BuildingBlocks.Core;
using BuildingBlocks.EventStoreDB;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
using BuildingBlocks.Jwt;
using BuildingBlocks.Logging;
using BuildingBlocks.Mapster;
using BuildingBlocks.MassTransit;
using BuildingBlocks.Mongo;
using BuildingBlocks.OpenTelemetry;
using BuildingBlocks.PersistMessageProcessor;
using BuildingBlocks.Swagger;
using BuildingBlocks.Utils;
using BuildingBlocks.Web;
using Figgle;
using FluentValidation;
using Hellang.Middleware.ProblemDetails;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Prometheus;
using Serilog;
namespace Booking.Extensions.Infrastructure;
public static class InfrastructureExtensions
{
public static WebApplicationBuilder AddInfrastructure(this WebApplicationBuilder builder)
{
var configuration = builder.Configuration;
var env = builder.Environment;
builder.Services.AddScoped<ICurrentUserProvider, CurrentUserProvider>();
builder.Services.AddScoped<IEventMapper, EventMapper>();
builder.Services.AddScoped<IEventDispatcher, EventDispatcher>();
builder.Services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddRateLimiter(options =>
{
options.GlobalLimiter = PartitionedRateLimiter.Create<HttpContext, string>(httpContext =>
RateLimitPartition.GetFixedWindowLimiter(
partitionKey: httpContext.User.Identity?.Name ?? httpContext.Request.Headers.Host.ToString(),
factory: partition => new FixedWindowRateLimiterOptions
{
AutoReplenishment = true, PermitLimit = 10, QueueLimit = 0, Window = TimeSpan.FromMinutes(1)
}));
});
builder.Services.AddPersistMessage(configuration);
builder.Services.AddMongoDbContext<BookingReadDbContext>(configuration);
builder.AddCustomSerilog(env);
builder.Services.AddJwt();
builder.Services.AddHttpContextAccessor();
builder.Services.AddCustomSwagger(configuration, typeof(BookingRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(BookingRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(BookingRoot).Assembly);
builder.Services.AddCustomHealthCheck();
builder.Services.AddCustomMassTransit(typeof(BookingRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
builder.Services.AddTransient<AuthHeaderHandler>();
SnowFlakIdGenerator.Configure(3);
// ref: https://github.com/oskardudycz/EventSourcing.NetCore/tree/main/Sample/EventStoreDB/ECommerce
builder.Services.AddEventStore(configuration, typeof(BookingRoot).Assembly)
.AddEventStoreDBSubscriptionToAll();
builder.Services.AddGrpcClients();
return builder;
}
public static WebApplication UseInfrastructure(this WebApplication app)
{
var env = app.Environment;
var appOptions = app.GetOptions<AppOptions>("AppOptions");
app.UseSerilogRequestLogging();
app.UseCorrelationId();
app.UseRouting();
app.UseHttpMetrics();
app.UseHttpsRedirection();
app.UseProblemDetails();
app.UseCustomHealthCheck();
app.MapMetrics();
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (env.IsDevelopment())
{
app.UseCustomSwagger();
}
return app;
}
}

3
src/Services/Booking/src/Booking/Extensions/MediatRExtensions.cs → src/Services/Booking/src/Booking/Extensions/Infrastructure/MediatRExtensions.cs
View File

@ -1,10 +1,9 @@
using BuildingBlocks.EFCore;
using BuildingBlocks.Logging;
using BuildingBlocks.Validation;
using MediatR;
using Microsoft.Extensions.DependencyInjection;
namespace Booking.Extensions;
namespace Booking.Extensions.Infrastructure;
public static class MediatRExtensions
{

3
src/Services/Booking/src/Booking/Extensions/ProblemDetailsExtensions.cs → src/Services/Booking/src/Booking/Extensions/Infrastructure/ProblemDetailsExtensions.cs
View File

@ -5,9 +5,8 @@ using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Newtonsoft.Json;
namespace Booking.Extensions;
namespace Booking.Extensions.Infrastructure;
public static class ProblemDetailsExtensions
{

91
src/Services/Flight/src/Flight.Api/Program.cs
View File

@ -1,99 +1,18 @@
using System.Reflection;
using BuildingBlocks.Caching;
using BuildingBlocks.EFCore;
using BuildingBlocks.Exception;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
using BuildingBlocks.Jwt;
using BuildingBlocks.Logging;
using BuildingBlocks.Mapster;
using BuildingBlocks.MassTransit;
using BuildingBlocks.Mongo;
using BuildingBlocks.OpenTelemetry;
using BuildingBlocks.PersistMessageProcessor;
using BuildingBlocks.Swagger;
using BuildingBlocks.Web;
using Figgle;
using Flight;
using Flight.Data;
using Flight.Data.Seed;
using Flight.Extensions;
using Flight.Flights.Features.CreateFlight.Endpoints.V1;
using Flight.GrpcServer.Services;
using FluentValidation;
using Hellang.Middleware.ProblemDetails;
using Microsoft.AspNetCore.Mvc.ApiExplorer;
using Prometheus;
using Serilog;
using Flight.Extensions.Infrastructure;
var builder = WebApplication.CreateBuilder(args);
var configuration = builder.Configuration;
var env = builder.Environment;
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddCustomDbContext<FlightDbContext>(configuration);
builder.Services.AddScoped<IDataSeeder, FlightDataSeeder>();
builder.Services.AddMongoDbContext<FlightReadDbContext>(configuration);
builder.Services.AddPersistMessage(configuration);
builder.AddCustomSerilog(env);
builder.Services.AddCore();
builder.Services.AddJwt();
builder.Services.AddCustomSwagger(configuration, typeof(FlightRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(FlightRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(FlightRoot).Assembly);
builder.Services.AddHttpContextAccessor();
builder.Services.AddCustomMassTransit(typeof(FlightRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
builder.Services.AddRouting(options => options.LowercaseUrls = true);
builder.Services.AddCustomHealthCheck();
builder.Services.AddGrpc(options =>
{
options.Interceptors.Add<GrpcExceptionInterceptor>();
});
SnowFlakIdGenerator.Configure(1);
builder.Services.AddCachingRequest(new List<Assembly> {typeof(FlightRoot).Assembly});
builder.Services.AddEasyCaching(options => { options.UseInMemory(configuration, "mem"); });
builder.AddMinimalEndpoints();
builder.AddInfrastructure();
var app = builder.Build();
app.UseSerilogRequestLogging();
app.UseCorrelationId();
app.UseRouting();
app.UseHttpMetrics();
app.UseMigration<FlightDbContext>(env);
app.UseProblemDetails();
app.UseHttpsRedirection();
app.UseCustomHealthCheck();
// ref: https://learn.microsoft.com/en-us/aspnet/core/fundamentals/routing?view=aspnetcore-7.0#routing-basics
app.MapMinimalEndpoints();
app.UseAuthentication();
app.UseAuthorization();
app.MapMinimalEndpoints();
app.UseEndpoints(endpoints =>
{
endpoints.MapMetrics();
endpoints.MapGrpcService<FlightGrpcServices>();
});
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (app.Environment.IsDevelopment())
{
app.UseCustomSwagger();
}
app.UseInfrastructure();
app.Run();

2
src/Services/Flight/src/Flight/Aircrafts/Features/CreateAircraft/Endpoints/V1/CreateAircraftEndpoint.cs
View File

@ -9,6 +9,8 @@ using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Routing;
using Swashbuckle.AspNetCore.Annotations;
namespace Flight.Aircrafts.Features.CreateAircraft.Endpoints.V1;
public class CreateAircraftEndpoint : IMinimalEndpoint
{
public IEndpointRouteBuilder MapEndpoint(IEndpointRouteBuilder endpoints)

2
src/Services/Flight/src/Flight/Airports/Features/CreateAirport/Endpoints/V1/CreateAirportEndpoint.cs
View File

@ -9,6 +9,8 @@ using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Routing;
using Swashbuckle.AspNetCore.Annotations;
namespace Flight.Airports.Features.CreateAirport.Endpoints.V1;
public class CreateAirportEndpoint : IMinimalEndpoint
{
public IEndpointRouteBuilder MapEndpoint(IEndpointRouteBuilder endpoints)

23
src/Services/Flight/src/Flight/Extensions/CoreExtensions.cs
View File

@ -1,23 +0,0 @@
using BuildingBlocks.Core;
using BuildingBlocks.Utils;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
namespace Flight.Extensions;
public static class CoreExtensions
{
public static IServiceCollection AddCore(this IServiceCollection services)
{
services.AddScoped<ICurrentUserProvider, CurrentUserProvider>();
services.AddScoped<IEventMapper, EventMapper>();
services.AddScoped<IEventDispatcher, EventDispatcher>();
services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
return services;
}
}

125
src/Services/Flight/src/Flight/Extensions/Infrastructure/InfrastructureExtensions.cs Normal file
View File

@ -0,0 +1,125 @@
using System;
using System.Collections.Generic;
using System.Reflection;
using System.Threading.RateLimiting;
using BuildingBlocks.Caching;
using BuildingBlocks.Core;
using BuildingBlocks.EFCore;
using BuildingBlocks.Exception;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
using BuildingBlocks.Jwt;
using BuildingBlocks.Logging;
using BuildingBlocks.Mapster;
using BuildingBlocks.MassTransit;
using BuildingBlocks.Mongo;
using BuildingBlocks.OpenTelemetry;
using BuildingBlocks.PersistMessageProcessor;
using BuildingBlocks.Swagger;
using BuildingBlocks.Utils;
using BuildingBlocks.Web;
using Figgle;
using Flight.Data;
using Flight.Data.Seed;
using Flight.GrpcServer.Services;
using FluentValidation;
using Hellang.Middleware.ProblemDetails;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Prometheus;
using Serilog;
namespace Flight.Extensions.Infrastructure;
public static class InfrastructureExtensions
{
public static WebApplicationBuilder AddInfrastructure(this WebApplicationBuilder builder)
{
var configuration = builder.Configuration;
var env = builder.Environment;
builder.Services.AddScoped<ICurrentUserProvider, CurrentUserProvider>();
builder.Services.AddScoped<IEventMapper, EventMapper>();
builder.Services.AddScoped<IEventDispatcher, EventDispatcher>();
builder.Services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
builder.Services.AddCustomMediatR();
builder.Services.AddCustomProblemDetails();
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddRateLimiter(options =>
{
options.GlobalLimiter = PartitionedRateLimiter.Create<HttpContext, string>(httpContext =>
RateLimitPartition.GetFixedWindowLimiter(
partitionKey: httpContext.User.Identity?.Name ?? httpContext.Request.Headers.Host.ToString(),
factory: partition => new FixedWindowRateLimiterOptions
{
AutoReplenishment = true, PermitLimit = 10, QueueLimit = 0, Window = TimeSpan.FromMinutes(1)
}));
});
builder.Services.AddCustomDbContext<FlightDbContext>(configuration);
builder.Services.AddScoped<IDataSeeder, FlightDataSeeder>();
builder.Services.AddMongoDbContext<FlightReadDbContext>(configuration);
builder.Services.AddPersistMessage(configuration);
builder.AddCustomSerilog(env);
builder.Services.AddJwt();
builder.Services.AddCustomSwagger(configuration, typeof(FlightRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddValidatorsFromAssembly(typeof(FlightRoot).Assembly);
builder.Services.AddCustomMapster(typeof(FlightRoot).Assembly);
builder.Services.AddHttpContextAccessor();
builder.Services.AddCustomMassTransit(typeof(FlightRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
builder.Services.AddCustomHealthCheck();
builder.Services.AddGrpc(options =>
{
options.Interceptors.Add<GrpcExceptionInterceptor>();
});
SnowFlakIdGenerator.Configure(1);
builder.Services.AddCachingRequest(new List<Assembly> {typeof(FlightRoot).Assembly});
builder.Services.AddEasyCaching(options => { options.UseInMemory(configuration, "mem"); });
return builder;
}
public static WebApplication UseInfrastructure(this WebApplication app)
{
var env = app.Environment;
var appOptions = app.GetOptions<AppOptions>("AppOptions");
app.UseSerilogRequestLogging();
app.UseCorrelationId();
app.UseHttpMetrics();
app.UseMigration<FlightDbContext>(env);
app.UseProblemDetails();
app.UseHttpsRedirection();
app.MapMetrics();
app.UseCustomHealthCheck();
app.MapGrpcService<FlightGrpcServices>();
app.UseRateLimiter();
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (env.IsDevelopment())
{
app.UseCustomSwagger();
}
return app;
}
}

2
src/Services/Flight/src/Flight/Extensions/MediatRExtensions.cs → src/Services/Flight/src/Flight/Extensions/Infrastructure/MediatRExtensions.cs
View File

@ -5,7 +5,7 @@ using BuildingBlocks.Validation;
using MediatR;
using Microsoft.Extensions.DependencyInjection;
namespace Flight.Extensions;
namespace Flight.Extensions.Infrastructure;
public static class MediatRExtensions
{

0
src/Services/Flight/src/Flight/Extensions/ProblemDetailsExtensions.cs → src/Services/Flight/src/Flight/Extensions/Infrastructure/ProblemDetailsExtensions.cs
View File

74
src/Services/Identity/src/Identity.Api/Program.cs
View File

@ -1,85 +1,21 @@
using BuildingBlocks.EFCore;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
using BuildingBlocks.Logging;
using BuildingBlocks.Mapster;
using BuildingBlocks.MassTransit;
using BuildingBlocks.OpenTelemetry;
using BuildingBlocks.PersistMessageProcessor;
using BuildingBlocks.Swagger;
using BuildingBlocks.Web;
using Figgle;
using FluentValidation;
using Hellang.Middleware.ProblemDetails;
using Identity;
using Identity.Data;
using Identity.Data.Seed;
using Identity.Extensions;
using Prometheus;
using Serilog;
using Identity.Extensions.Infrastructure;
var builder = WebApplication.CreateBuilder(args);
var configuration = builder.Configuration;
var env = builder.Environment;
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddPersistMessage(configuration);
builder.Services.AddCustomDbContext<IdentityContext>(configuration);
builder.Services.AddScoped<IDataSeeder, IdentityDataSeeder>();
builder.Services.AddCore();
builder.Services.AddControllers();
builder.AddCustomSerilog(env);
builder.Services.AddCustomSwagger(configuration, typeof(IdentityRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(IdentityRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(IdentityRoot).Assembly);
builder.Services.AddCustomHealthCheck();
builder.Services.AddCustomMassTransit(typeof(IdentityRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
SnowFlakIdGenerator.Configure(4);
builder.Services.AddIdentityServer(env);
builder.AddMinimalEndpoints();
builder.AddInfrastructure();
var app = builder.Build();
app.UseSerilogRequestLogging();
app.UseMigration<IdentityContext>(env);
app.UseCorrelationId();
app.UseRouting();
app.UseHttpMetrics();
app.UseProblemDetails();
app.UseHttpsRedirection();
app.UseCustomHealthCheck();
app.MapMinimalEndpoints();
app.UseAuthentication();
app.UseAuthorization();
app.UseIdentityServer();
app.MapMinimalEndpoints();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
endpoints.MapMetrics();
});
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (app.Environment.IsDevelopment())
{
app.UseCustomSwagger();
}
app.UseInfrastructure();
app.Run();
namespace Identity.Api
{
public partial class Program {}
public partial class Program { }
}

21
src/Services/Identity/src/Identity/Extensions/CoreExtensions.cs
View File

@ -1,21 +0,0 @@
using BuildingBlocks.Core;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
namespace Identity.Extensions;
public static class CoreExtensions
{
public static IServiceCollection AddCore(this IServiceCollection services)
{
services.AddScoped<IEventMapper, EventMapper>();
services.AddScoped<IEventDispatcher, EventDispatcher>();
services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
return services;
}
}

2
src/Services/Identity/src/Identity/Extensions/IdentityServerExtensions.cs → src/Services/Identity/src/Identity/Extensions/Infrastructure/IdentityServerExtensions.cs
View File

@ -5,7 +5,7 @@ using Microsoft.AspNetCore.Identity;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
namespace Identity.Extensions;
namespace Identity.Extensions.Infrastructure;
public static class IdentityServerExtensions
{

106
src/Services/Identity/src/Identity/Extensions/Infrastructure/InfrastructureExtensions.cs Normal file
View File

@ -0,0 +1,106 @@
using System;
using System.Threading.RateLimiting;
using BuildingBlocks.Core;
using BuildingBlocks.EFCore;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
using BuildingBlocks.Logging;
using BuildingBlocks.Mapster;
using BuildingBlocks.MassTransit;
using BuildingBlocks.OpenTelemetry;
using BuildingBlocks.PersistMessageProcessor;
using BuildingBlocks.Swagger;
using BuildingBlocks.Web;
using Figgle;
using FluentValidation;
using Hellang.Middleware.ProblemDetails;
using Identity.Data;
using Identity.Data.Seed;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Prometheus;
using Serilog;
namespace Identity.Extensions.Infrastructure;
public static class InfrastructureExtensions
{
public static WebApplicationBuilder AddInfrastructure(this WebApplicationBuilder builder)
{
var configuration = builder.Configuration;
var env = builder.Environment;
builder.Services.AddScoped<IEventMapper, EventMapper>();
builder.Services.AddScoped<IEventDispatcher, EventDispatcher>();
builder.Services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddRateLimiter(options =>
{
options.GlobalLimiter = PartitionedRateLimiter.Create<HttpContext, string>(httpContext =>
RateLimitPartition.GetFixedWindowLimiter(
partitionKey: httpContext.User.Identity?.Name ?? httpContext.Request.Headers.Host.ToString(),
factory: partition => new FixedWindowRateLimiterOptions
{
AutoReplenishment = true, PermitLimit = 10, QueueLimit = 0, Window = TimeSpan.FromMinutes(1)
}));
});
builder.Services.AddControllers();
builder.Services.AddPersistMessage(configuration);
builder.Services.AddCustomDbContext<IdentityContext>(configuration);
builder.Services.AddScoped<IDataSeeder, IdentityDataSeeder>();
builder.AddCustomSerilog(env);
builder.Services.AddCustomSwagger(configuration, typeof(IdentityRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(IdentityRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(IdentityRoot).Assembly);
builder.Services.AddCustomHealthCheck();
builder.Services.AddCustomMassTransit(typeof(IdentityRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
SnowFlakIdGenerator.Configure(4);
builder.Services.AddIdentityServer(env);
return builder;
}
public static WebApplication UseInfrastructure(this WebApplication app)
{
var env = app.Environment;
var appOptions = app.GetOptions<AppOptions>("AppOptions");
app.UseSerilogRequestLogging();
app.UseMigration<IdentityContext>(env);
app.UseCorrelationId();
app.UseHttpMetrics();
app.UseProblemDetails();
app.UseHttpsRedirection();
app.UseCustomHealthCheck();
app.UseIdentityServer();
app.MapMetrics();
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (env.IsDevelopment())
{
app.UseCustomSwagger();
}
return app;
}
}

3
src/Services/Identity/src/Identity/Extensions/MediatRExtensions.cs → src/Services/Identity/src/Identity/Extensions/Infrastructure/MediatRExtensions.cs
View File

@ -1,10 +1,9 @@
using BuildingBlocks.EFCore;
using BuildingBlocks.Logging;
using BuildingBlocks.Validation;
using MediatR;
using Microsoft.Extensions.DependencyInjection;
namespace Identity.Extensions;
namespace Identity.Extensions.Infrastructure;
public static class MediatRExtensions
{

2
src/Services/Identity/src/Identity/Extensions/ProblemDetailsExtensions.cs → src/Services/Identity/src/Identity/Extensions/Infrastructure/ProblemDetailsExtensions.cs
View File

@ -5,7 +5,7 @@ using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
namespace Identity.Extensions;
namespace Identity.Extensions.Infrastructure;
public static class ProblemDetailsExtensions
{

55
src/Services/Passenger/src/Passenger.Api/Program.cs
View File

@ -18,70 +18,23 @@ using Microsoft.AspNetCore.Mvc.ApiExplorer;
using Passenger;
using Passenger.Data;
using Passenger.Extensions;
using Passenger.Extensions.Infrastructure;
using Passenger.GrpcServer.Services;
using Prometheus;
using Serilog;
var builder = WebApplication.CreateBuilder(args);
var configuration = builder.Configuration;
var env = builder.Environment;
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddCustomDbContext<PassengerDbContext>(configuration);
builder.Services.AddMongoDbContext<PassengerReadDbContext>(configuration);
builder.Services.AddPersistMessage(configuration);
builder.AddCustomSerilog(env);
builder.Services.AddCore();
builder.Services.AddJwt();
builder.Services.AddCustomSwagger(configuration, typeof(PassengerRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(PassengerRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(PassengerRoot).Assembly);
builder.Services.AddHttpContextAccessor();
builder.Services.AddCustomHealthCheck();
builder.Services.AddCustomMassTransit(typeof(PassengerRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
builder.Services.AddGrpc(options =>
{
options.Interceptors.Add<GrpcExceptionInterceptor>();
});
SnowFlakIdGenerator.Configure(2);
builder.AddMinimalEndpoints();
builder.AddInfrastructure();
var app = builder.Build();
app.UseSerilogRequestLogging();
app.UseMigration<PassengerDbContext>(env);
app.UseCorrelationId();
app.UseRouting();
app.UseHttpMetrics();
app.UseProblemDetails();
app.UseHttpsRedirection();
app.MapMinimalEndpoints();
app.UseAuthentication();
app.UseAuthorization();
app.UseCustomHealthCheck();
app.MapMinimalEndpoints();
app.UseEndpoints(endpoints =>
{
endpoints.MapMetrics();
endpoints.MapGrpcService<PassengerGrpcServices>();
});
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (app.Environment.IsDevelopment())
{
app.UseCustomSwagger();
}
app.UseInfrastructure();
app.Run();

23
src/Services/Passenger/src/Passenger/Extensions/CoreExtensions.cs
View File

@ -1,23 +0,0 @@
using BuildingBlocks.Core;
using BuildingBlocks.Utils;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
namespace Passenger.Extensions;
public static class CoreExtensions
{
public static IServiceCollection AddCore(this IServiceCollection services)
{
services.AddScoped<ICurrentUserProvider, CurrentUserProvider>();
services.AddScoped<IEventMapper, EventMapper>();
services.AddScoped<IEventDispatcher, EventDispatcher>();
services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
return services;
}
}

112
src/Services/Passenger/src/Passenger/Extensions/Infrastructure/InfrastructureExtensions.cs Normal file
View File

@ -0,0 +1,112 @@
using System.Threading.RateLimiting;
using BuildingBlocks.Core;
using BuildingBlocks.EFCore;
using BuildingBlocks.Exception;
using BuildingBlocks.HealthCheck;
using BuildingBlocks.IdsGenerator;
using BuildingBlocks.Jwt;
using BuildingBlocks.Logging;
using BuildingBlocks.Mapster;
using BuildingBlocks.MassTransit;
using BuildingBlocks.Mongo;
using BuildingBlocks.OpenTelemetry;
using BuildingBlocks.PersistMessageProcessor;
using BuildingBlocks.Swagger;
using BuildingBlocks.Utils;
using BuildingBlocks.Web;
using Figgle;
using FluentValidation;
using Hellang.Middleware.ProblemDetails;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Passenger.Data;
using Passenger.GrpcServer.Services;
using Prometheus;
using Serilog;
namespace Passenger.Extensions.Infrastructure;
public static class InfrastructureExtensions
{
public static WebApplicationBuilder AddInfrastructure(this WebApplicationBuilder builder)
{
var configuration = builder.Configuration;
var env = builder.Environment;
builder.Services.AddScoped<ICurrentUserProvider, CurrentUserProvider>();
builder.Services.AddScoped<IEventMapper, EventMapper>();
builder.Services.AddScoped<IEventDispatcher, EventDispatcher>();
builder.Services.Configure<ApiBehaviorOptions>(options =>
{
options.SuppressModelStateInvalidFilter = true;
});
var appOptions = builder.Services.GetOptions<AppOptions>("AppOptions");
Console.WriteLine(FiggleFonts.Standard.Render(appOptions.Name));
builder.Services.AddRateLimiter(options =>
{
options.GlobalLimiter = PartitionedRateLimiter.Create<HttpContext, string>(httpContext =>
RateLimitPartition.GetFixedWindowLimiter(
partitionKey: httpContext.User.Identity?.Name ?? httpContext.Request.Headers.Host.ToString(),
factory: partition => new FixedWindowRateLimiterOptions
{
AutoReplenishment = true, PermitLimit = 10, QueueLimit = 0, Window = TimeSpan.FromMinutes(1)
}));
});
builder.Services.AddCustomDbContext<PassengerDbContext>(configuration);
builder.Services.AddMongoDbContext<PassengerReadDbContext>(configuration);
builder.Services.AddPersistMessage(configuration);
builder.AddCustomSerilog(env);
builder.Services.AddJwt();
builder.Services.AddCustomSwagger(configuration, typeof(PassengerRoot).Assembly);
builder.Services.AddCustomVersioning();
builder.Services.AddCustomMediatR();
builder.Services.AddValidatorsFromAssembly(typeof(PassengerRoot).Assembly);
builder.Services.AddCustomProblemDetails();
builder.Services.AddCustomMapster(typeof(PassengerRoot).Assembly);
builder.Services.AddHttpContextAccessor();
builder.Services.AddCustomHealthCheck();
builder.Services.AddCustomMassTransit(typeof(PassengerRoot).Assembly, env);
builder.Services.AddCustomOpenTelemetry();
builder.Services.AddGrpc(options =>
{
options.Interceptors.Add<GrpcExceptionInterceptor>();
});
SnowFlakIdGenerator.Configure(2);
return builder;
}
public static WebApplication UseInfrastructure(this WebApplication app)
{
var env = app.Environment;
var appOptions = app.GetOptions<AppOptions>("AppOptions");
app.UseSerilogRequestLogging();
app.UseMigration<PassengerDbContext>(env);
app.UseCorrelationId();
app.UseHttpMetrics();
app.UseProblemDetails();
app.UseHttpsRedirection();
app.UseCustomHealthCheck();
app.MapMetrics();
app.MapGrpcService<PassengerGrpcServices>();
app.MapGet("/", x => x.Response.WriteAsync(appOptions.Name));
if (env.IsDevelopment())
{
app.UseCustomSwagger();
}
return app;
}
}

0
src/Services/Passenger/src/Passenger/Extensions/MediatRExtensions.cs → src/Services/Passenger/src/Passenger/Extensions/Infrastructure/MediatRExtensions.cs
View File

0
src/Services/Passenger/src/Passenger/Extensions/ProblemDetailsExtensions.cs → src/Services/Passenger/src/Passenger/Extensions/Infrastructure/ProblemDetailsExtensions.cs
View File