Handler.cs 1.0 KB

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