<?php
/**
 * Change booking status (approve, confirm, complete, no-show).
 *
 * @package Bookline
 */

declare( strict_types=1 );

namespace Bookline\Application\Booking;

use Bookline\Application\Bus;
use Bookline\Domain\Booking\Booking;
use Bookline\Domain\Booking\BookingRepository;
use Bookline\Domain\Booking\BookingStatus;
use Bookline\Domain\Booking\Events\BookingStatusChanged;
use Bookline\Domain\Shared\Clock;
use Bookline\Domain\Shared\DomainException;
use Bookline\Infrastructure\Persistence\TransactionManager;

/**
 * Status transitions that are not cancel/reschedule.
 *
 * @since 0.1.0
 */
final class ChangeBookingStatusHandler {

	/**
	 * Constructor.
	 *
	 * @param BookingRepository  $bookings Booking port.
	 * @param TransactionManager $tx       Transactions.
	 * @param Bus                $bus      Event bus.
	 * @param Clock              $clock    Clock.
	 */
	public function __construct(
		private readonly BookingRepository $bookings,
		private readonly TransactionManager $tx,
		private readonly Bus $bus,
		private readonly Clock $clock,
	) {}

	/**
	 * Change status.
	 *
	 * @param int           $booking_id       Booking id.
	 * @param BookingStatus $status           New status.
	 * @param bool          $notify_customer  Whether to notify the customer.
	 *
	 * @throws DomainException On failure.
	 *
	 * @since 0.1.0
	 */
	public function handle( int $booking_id, BookingStatus $status, bool $notify_customer = true ): Booking {
		$now     = $this->clock->now();
		$booking = $this->bookings->find_by_id( $booking_id );
		if ( null === $booking ) {
			throw new DomainException( 'booking.not_found', 'Booking not found.' );
		}

		$from = $booking->status();
		if ( $from === $status ) {
			return $booking;
		}

		$updated = $this->tx->run(
			function () use ( $booking, $status, $now ): Booking {
				$booking->change_status( $status, $now );
				$this->bookings->save( $booking, false );
				return $booking;
			}
		);

		$this->bus->dispatch(
			new BookingStatusChanged(
				(int) $updated->id(),
				$updated->uuid(),
				$from,
				$updated->status(),
				$now,
				$notify_customer
			)
		);

		return $updated;
	}
}