Booking System

public async Task<BookSeatResponse> Handle(BookSeatCommand request, CancellationToken cancellationToken)
{
    Trip trip = await tripRepository.GetAsync(request.TripId, cancellationToken)
                ?? throw new ArgumentException("الرحلة غير موجودة");

    if (!string.Equals(trip.Status?.Trim(), TripStatuses.Scheduled, StringComparison.OrdinalIgnoreCase))
    {
        throw new InvalidOperationException("لا يمكن حجز مقعد في رحلة غير مجدولة");
    }

    int clampedAvailable = Math.Min(Math.Max(trip.AvailableSeatCount, 0), trip.TotalSeats);
    int clampedReserved = Math.Min(Math.Max(trip.ReservedSeatCount, 0), trip.TotalSeats);
    int availableForBooking = Math.Max(0, clampedAvailable - clampedReserved);
    
    if (availableForBooking < request.RequestedSeatsCount)
    {
        throw new InvalidOperationException("عدد المقاعد المتاحة غير كافٍ لإتمام الحجز");
    }

trip.ReservedSeatCount += request.RequestedSeatsCount;
logger.LogInformation("Created booking {BookingId} with {RequestedSeatsCount} requested seats", 
    bookingId, bookingMaster.RequestedSeatsCount);

if (paymentMethod == PaymentMethods.Wallet)
{
    await BookingPaymentValidator.ValidateWalletBalanceAsync(
        request.PassengerId, tripCurrency, totalPrice,
        passengerWalletRepository, cancellationToken);
}

string[] allowedExtensions = [".jpg", ".jpeg", ".png", ".gif", ".webp"];
string extension = Path.GetExtension(receiptImage.FileName).ToLowerInvariant();

if (!allowedExtensions.Contains(extension))
{
    return Results.BadRequest(new BookSeatResponse
    {
        Success = false,
        Message = "نوع الملف غير مدعوم. الأنواع المسموح بها: JPG, JPEG, PNG, GIF, WEBP"
    });
}

if (receiptImage.Length > 10 * 1024 * 1024)
{
    return Results.BadRequest(new BookSeatResponse
    {
        Success = false,
        Message = "حجم الملف كبير جداً. الحد الأقصى 10 ميجابايت"
    });
}

using (DataConnectionTransaction transaction = await db.BeginTransactionAsync(cancellationToken))
{
    try
    {
        await bookingRepository.AddBookingAsync(bookingMaster, cancellationToken);
        await tripRepository.UpdateAsync(trip, cancellationToken);

        if (paymentMethod == PaymentMethods.Moyasar)
        {
            var paymentOrder = new PaymentOrder { /* ... */ };
            await paymentOrderRepository.CreatePaymentOrderAsync(paymentOrder, cancellationToken);
        }

        if (paymentMethod == PaymentMethods.BankTransfer)
        {
            var bankTransfer = new BankTransfer { /* ... */ };
            await bankTransferRepository.AddBankTransferAsync(bankTransfer, cancellationToken);
        }

        await transaction.CommitAsync(cancellationToken);
    }
    catch (Exception ex)
    {
        await transaction.RollbackAsync(cancellationToken);
        trip.ReservedSeatCount -= request.RequestedSeatsCount;
        throw;
    }
}

public async Task<AcceptBookingResponse> Handle(AcceptBookingCommand request, CancellationToken cancellationToken)
{
    Booking? booking = await bookingRepository.GetBookingAsync(request.BookingId, cancellationToken);
    
    if (booking.Status != BookingStatuses.Pending)
    {
        return new AcceptBookingResponse { 
            Success = false, 
            Message = "لا يمكن قبول طلب حجز غير معلق" 
        };
    }

    var context = new BookingAcceptanceContext(
        booking, trip,
        PerformedById: request.DriverId,
        PerformedByType: PerformedByTypes.User,
        DriverNotes: request.DriverNotes ?? string.Empty,
        RejectionReason: request.Reason);

    BookingAcceptanceResult result = await acceptanceService.ProcessAcceptanceAsync(context, cancellationToken);
    
    // Payment processing and wallet updates happen here
}

if (paymentMethod != PaymentMethods.Moyasar)
{
    var notification = new BookingCreatedNotification(
        bookingMaster.Id,
        trip.Id,
        trip.DriverId,
        request.PassengerId,
        bookingMaster.PassengerName,
        request.RequestedSeatsCount,
        totalPrice,
        trip.From,
        trip.To,
        trip.DepartureTimeUtc);
    await messageBus.PublishAsync(notification);
}

if (result.PaymentBranch == "Wallet" && result.PassengerWalletResult != null)
{
    var walletNotification = new WalletDeductedNotification(
        booking.Id, trip.Id, booking.PassengerId,
        booking.TotalPrice, tripCurrency, result.PassengerWalletResult.BalanceAfter,
        trip.From, trip.To);
    await messageBus.PublishAsync(walletNotification);
}