Skip to content

Instantly share code, notes, and snippets.

@dcomartin
Created Mar 9, 2022
Embed
What would you like to do?
public class ArriveHandler : IRequestHandler<Arrive>
{
private readonly ShipmentDbContext _dbContext;
private readonly IBus _bus;
public ArriveHandler(ShipmentDbContext dbContext, IBus bus)
{
_dbContext = dbContext;
_bus = bus;
}
public async Task<Unit> Handle(Arrive request, CancellationToken cancellationToken)
{
var allStops = await _dbContext.Stops.Where(x => x.ShipmentId == request.ShipmentId).ToArrayAsync();
var stop = allStops.SingleOrDefault(x => x.StopId == request.StopId);
if (stop == null)
{
throw new InvalidOperationException("Stop does not exist.");
}
if (stop.Status != StopStatus.InTransit)
{
throw new InvalidOperationException("Stop has already arrived.");
}
var previousStopsAreNotDeparted = allStops
.Where(x => x.Scheduled < stop.Scheduled)
.Any(x => x.Status != StopStatus.Departed);
if (previousStopsAreNotDeparted)
{
throw new InvalidOperationException("Previous stops have not departed.");
}
stop.Status = StopStatus.Arrived;
stop.Arrived = request.Arrived;
await _dbContext.SaveChangesAsync();
await _bus.Publish(new Arrived(stop.StopId, stop.Arrived));
return Unit.Value;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment