Handler.cs 933 B

12345678910111213141516171819202122232425262728293031
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.Donations.ValueObject;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Api.DonationRemote.SkipCurrent;
  6. internal sealed class Handler(IAppDbContext db) : ICommandHandler<Command>
  7. {
  8. public async Task Handle(Command request, CancellationToken ct)
  9. {
  10. var channelID = await db.Channel.AsNoTracking()
  11. .Where(c => c.WidgetToken == request.WidgetToken)
  12. .Select(c => c.ID)
  13. .FirstOrDefaultAsync(ct);
  14. if (channelID == 0)
  15. {
  16. return;
  17. }
  18. var playing = await db.DonationAlert.Where(a => a.Donation!.ChannelID == channelID && a.Status == AlertStatus.Playing).FirstOrDefaultAsync(ct);
  19. if (playing is null)
  20. {
  21. return;
  22. }
  23. playing.MarkSkipped();
  24. await db.SaveChangesAsync(ct);
  25. }
  26. }