diff --git a/src/Services/Booking/src/Booking/BookingProjection.cs b/src/Services/Booking/src/Booking/BookingProjection.cs index 82edb22..d046a5e 100644 --- a/src/Services/Booking/src/Booking/BookingProjection.cs +++ b/src/Services/Booking/src/Booking/BookingProjection.cs @@ -30,7 +30,7 @@ public class BookingProjection : IProjectionProcessor private async Task Apply(BookingCreatedDomainEvent @event, CancellationToken cancellationToken = default) { var reservation = - await _bookingDbContext.Bookings.SingleOrDefaultAsync(x => x.Id == @event.Id && !x.IsDeleted, + await _bookingDbContext.Bookings.SingleOrDefaultAsync(x => x.Id == @event.Id, cancellationToken); if (reservation == null) diff --git a/src/Services/Flight/src/Flight/Flights/Features/CreateFlight/CreateFlightCommandHandler.cs b/src/Services/Flight/src/Flight/Flights/Features/CreateFlight/CreateFlightCommandHandler.cs index 859764a..4f942ab 100644 --- a/src/Services/Flight/src/Flight/Flights/Features/CreateFlight/CreateFlightCommandHandler.cs +++ b/src/Services/Flight/src/Flight/Flights/Features/CreateFlight/CreateFlightCommandHandler.cs @@ -31,7 +31,7 @@ public class CreateFlightCommandHandler : ICommandHandler x.Id == command.Id && !x.IsDeleted, + var flight = await _flightDbContext.Flights.SingleOrDefaultAsync(x => x.Id == command.Id, cancellationToken); if (flight is not null) diff --git a/src/Services/Flight/src/Flight/Flights/Features/GetAvailableFlights/GetAvailableFlightsQueryHandler.cs b/src/Services/Flight/src/Flight/Flights/Features/GetAvailableFlights/GetAvailableFlightsQueryHandler.cs index c5c403d..717169f 100644 --- a/src/Services/Flight/src/Flight/Flights/Features/GetAvailableFlights/GetAvailableFlightsQueryHandler.cs +++ b/src/Services/Flight/src/Flight/Flights/Features/GetAvailableFlights/GetAvailableFlightsQueryHandler.cs @@ -29,7 +29,7 @@ public class GetAvailableFlightsQueryHandler : IQueryHandler !x.IsDeleted).ToListAsync(cancellationToken); + var flight = await _flightDbContext.Flights.ToListAsync(cancellationToken); if (!flight.Any()) throw new FlightNotFountException(); diff --git a/src/Services/Flight/src/Flight/Flights/Features/GetFlightById/GetFlightByIdQueryHandler.cs b/src/Services/Flight/src/Flight/Flights/Features/GetFlightById/GetFlightByIdQueryHandler.cs index 968ffa4..ee41c89 100644 --- a/src/Services/Flight/src/Flight/Flights/Features/GetFlightById/GetFlightByIdQueryHandler.cs +++ b/src/Services/Flight/src/Flight/Flights/Features/GetFlightById/GetFlightByIdQueryHandler.cs @@ -27,7 +27,7 @@ public class GetFlightByIdQueryHandler : IQueryHandler x.Id == query.Id && !x.IsDeleted, cancellationToken); + await _flightDbContext.Flights.SingleOrDefaultAsync(x => x.Id == query.Id, cancellationToken); if (flight is null) throw new FlightNotFountException(); diff --git a/src/Services/Flight/src/Flight/Flights/Features/UpdateFlight/UpdateFlightCommandHandler.cs b/src/Services/Flight/src/Flight/Flights/Features/UpdateFlight/UpdateFlightCommandHandler.cs index a2cbe6a..09baa0e 100644 --- a/src/Services/Flight/src/Flight/Flights/Features/UpdateFlight/UpdateFlightCommandHandler.cs +++ b/src/Services/Flight/src/Flight/Flights/Features/UpdateFlight/UpdateFlightCommandHandler.cs @@ -28,7 +28,7 @@ public class UpdateFlightCommandHandler : ICommandHandler x.Id == command.Id && !x.IsDeleted, + var flight = await _flightDbContext.Flights.SingleOrDefaultAsync(x => x.Id == command.Id, cancellationToken); if (flight is null) diff --git a/src/Services/Flight/src/Flight/Seats/Features/CreateSeat/CreateSeatCommandHandler.cs b/src/Services/Flight/src/Flight/Seats/Features/CreateSeat/CreateSeatCommandHandler.cs index 320844a..59eb3bc 100644 --- a/src/Services/Flight/src/Flight/Seats/Features/CreateSeat/CreateSeatCommandHandler.cs +++ b/src/Services/Flight/src/Flight/Seats/Features/CreateSeat/CreateSeatCommandHandler.cs @@ -31,7 +31,7 @@ public class CreateSeatCommandHandler : IRequestHandler x.Id == command.Id && !x.IsDeleted, cancellationToken); + var seat = await _flightDbContext.Seats.SingleOrDefaultAsync(x => x.Id == command.Id, cancellationToken); if (seat is not null) throw new SeatAlreadyExistException(); diff --git a/src/Services/Flight/src/Flight/Seats/Features/GetAvailableSeats/GetAvailableSeatsQueryHandler.cs b/src/Services/Flight/src/Flight/Seats/Features/GetAvailableSeats/GetAvailableSeatsQueryHandler.cs index 2d4cac7..c88bf71 100644 --- a/src/Services/Flight/src/Flight/Seats/Features/GetAvailableSeats/GetAvailableSeatsQueryHandler.cs +++ b/src/Services/Flight/src/Flight/Seats/Features/GetAvailableSeats/GetAvailableSeatsQueryHandler.cs @@ -28,7 +28,7 @@ public class GetAvailableSeatsQueryHandler : IRequestHandler x.FlightId == query.FlightId && !x.IsDeleted).ToListAsync(cancellationToken); + var seats = await _flightDbContext.Seats.Where(x => x.FlightId == query.FlightId).ToListAsync(cancellationToken); if (!seats.Any()) throw new AllSeatsFullException(); diff --git a/src/Services/Flight/src/Flight/Seats/Features/ReserveSeat/ReserveSeatCommandHandler.cs b/src/Services/Flight/src/Flight/Seats/Features/ReserveSeat/ReserveSeatCommandHandler.cs index 8fdd692..04dd257 100644 --- a/src/Services/Flight/src/Flight/Seats/Features/ReserveSeat/ReserveSeatCommandHandler.cs +++ b/src/Services/Flight/src/Flight/Seats/Features/ReserveSeat/ReserveSeatCommandHandler.cs @@ -25,8 +25,7 @@ public class ReserveSeatCommandHandler : IRequestHandler x.SeatNumber == command.SeatNumber && x.FlightId == command.FlightId - && !x.IsDeleted, cancellationToken); + var seat = await _flightDbContext.Seats.SingleOrDefaultAsync(x => x.SeatNumber == command.SeatNumber && x.FlightId == command.FlightId, cancellationToken); if (seat is null) throw new SeatNumberIncorrectException();