Handler.cs 749 B

123456789101112131415161718192021
  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 playing = await db.DonationAlert.Where(a => a.Donation!.ChannelID == request.ChannelID && a.Status == AlertStatus.Playing).FirstOrDefaultAsync(ct);
  11. if (playing is null)
  12. {
  13. throw new KeyNotFoundException("재생 중인 알림이 없습니다.");
  14. }
  15. playing.MarkSkipped();
  16. await db.SaveChangesAsync(ct);
  17. }
  18. }