| 12345678910111213141516171819202122232425262728293031 |
- using Application.Abstractions.Data;
- using Application.Abstractions.Messaging;
- using Domain.Entities.Donations.ValueObject;
- using Microsoft.EntityFrameworkCore;
- using SharedKernel.Results;
- namespace Application.Features.Api.DonationRemote.SkipCurrent;
- internal sealed class Handler(IAppDbContext db) : ICommandHandler<Command, Result<Response>>
- {
- public async Task<Result<Response>> Handle(Command request, CancellationToken ct)
- {
- var channelID = await db.Channel.AsNoTracking().Where(c => c.WidgetToken == request.WidgetToken).Select(c => c.ID).FirstOrDefaultAsync(ct);
- if (channelID == 0)
- {
- return new Response(null);
- }
- var playing = await db.DonationAlert.Where(a => a.Donation!.ChannelID == channelID && a.Status == AlertStatus.Playing).FirstOrDefaultAsync(ct);
- if (playing is null)
- {
- return new Response(null);
- }
- playing.MarkSkipped();
- await db.SaveChangesAsync(ct);
- return new Response(playing.ID);
- }
- }
|