Handler.cs 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.Developers;
  4. using Microsoft.EntityFrameworkCore;
  5. using SharedKernel.Results;
  6. namespace Application.Features.Admin.Developers.OverrideRateLimit;
  7. internal sealed class Handler(IAppDbContext db) : ICommandHandler<Command, Result>
  8. {
  9. public async Task<Result> Handle(Command request, CancellationToken ct)
  10. {
  11. if (request.LimitPerMinute <= 0 || request.LimitPerMinute > 100000)
  12. {
  13. return Result.Failure(Error.Problem("RateLimit.Invalid", "LimitPerMinute must be 1-100000."));
  14. }
  15. var appExists = await db.ApiApplication.AnyAsync(c => c.ID == request.AppID, ct);
  16. if (!appExists)
  17. {
  18. return Result.Failure(Error.NotFound("App.NotFound", "App not found."));
  19. }
  20. var existing = await db.ApiRateLimit
  21. .AsTracking()
  22. .FirstOrDefaultAsync(c => c.ApplicationID == request.AppID, ct);
  23. if (existing is null)
  24. {
  25. await db.ApiRateLimit.AddAsync(ApiRateLimit.Create(request.AppID, request.LimitPerMinute), ct);
  26. }
  27. else
  28. {
  29. existing.SetLimit(request.LimitPerMinute);
  30. }
  31. await db.SaveChangesAsync(ct);
  32. return Result.Success();
  33. }
  34. }