Reviews & Ratings

public async Task<CreateDriverReviewResponse> Handle(
    CreateDriverReviewCommand request, 
    CancellationToken ct)
{
    ThrowWhen(string.IsNullOrWhiteSpace(request.DriverId), "يجب تحديد معرف السائق");
    ThrowWhen(request.Rating < 1 || request.Rating > 5, "التقييم يجب أن يكون بين 1 و 5");

    var (driverId, isCompleted) = await ResolveTripDriverAsync(request.TripId, request.DriverId, ct);

    ThrowWhen(!string.Equals(driverId, request.DriverId, StringComparison.OrdinalIgnoreCase), 
        "معرف السائق لا يطابق سائق هذه الرحلة");
    ThrowWhen(!isCompleted, "يمكن تقييم السائق فقط بعد إكمال الرحلة");

    var hasValidBooking = await HasValidBookingAsync(request.TripId, request.PassengerId, ct);
    ThrowWhen(!hasValidBooking, 
        "يمكن تقييم السائق فقط من قبل الركاب الذين لديهم حجز مؤكد أو مكتمل في رحلة مكتملة");

    var existingReview = await driverReviewRepository.GetDriverReviewByTripAndPassengerAsync(
        request.TripId, request.PassengerId, ct);
    ThrowWhen(existingReview is not null, "لقد قمت بتقييم هذه الرحلة مسبقاً");

    var review = DriverReview.Create(
        request.DriverId, request.PassengerId, request.TripId, 
        request.Rating, request.Comment);
    await driverReviewRepository.AddDriverReviewAsync(review, ct);

    await UpdateDriverOverallRatingAsync(request.DriverId, ct);
}

public async Task<CreatePassengerReviewResponse> Handle(
    CreatePassengerReviewCommand request, 
    CancellationToken ct)
{
    ThrowWhen(string.IsNullOrWhiteSpace(request.PassengerId), "يجب تحديد معرف الراكب");
    ThrowWhen(request.Rating < 1 || request.Rating > 5, "التقييم يجب أن يكون بين 1 و 5");

    var (driverId, isCompleted) = await ResolveTripDriverAsync(
        request.TripId, request.DriverId, ct);

    ThrowWhen(!string.Equals(driverId, request.DriverId, StringComparison.OrdinalIgnoreCase), 
        "يمكنك تقييم الركاب فقط في رحلاتك الخاصة");
    ThrowWhen(!isCompleted, "يمكن تقييم الراكب فقط بعد إكمال الرحلة");

    var hasValidBooking = await HasValidBookingAsync(request.TripId, request.PassengerId, ct);
    ThrowWhen(!hasValidBooking, 
        "الراكب المحدد ليس لديه حجز مؤكد أو مكتمل في هذه الرحلة");

    var existingReview = await passengerReviewRepository
        .GetPassengerReviewByTripDriverAndPassengerAsync(
            request.TripId, request.DriverId, request.PassengerId, ct);
    ThrowWhen(existingReview is not null, "لقد قمت بتقييم هذا الراكب في هذه الرحلة مسبقاً");

    var review = PassengerReview.Create(
        request.PassengerId, request.DriverId, request.TripId, 
        request.Rating, request.Comment);
    await passengerReviewRepository.AddPassengerReviewAsync(review, ct);

    await UpdatePassengerOverallRatingAsync(request.PassengerId, ct);
}

app.MapDelete("/api/passenger-reviews/{reviewId}", async (
    string reviewId,
    [FromServices] IMediator mediator,
    CancellationToken cancellationToken) =>
{
    var command = new DeletePassengerReviewCommand { ReviewId = reviewId };
    DeletePassengerReviewResponse result = await mediator.Send(command, cancellationToken);
    return result.Success ? Results.Ok(result) : Results.BadRequest(result);
})

private async Task PublishNotificationAsync(
    DriverReview review, string tripId, string driverId, string passengerId, CancellationToken ct)
{
    var driver = await usersApiService.GetDriverAsync(driverId, ct);
    var passenger = await usersApiService.GetPassengerAsync(passengerId, ct);

    await messageBus.PublishAsync(new DriverReviewCreatedNotification(
        review.Id, tripId, driverId, passengerId,
        review.Rating, review.Comment, driver?.Name, passenger?.Name));
}