<?php
/**
 * Cancel open runs when cancel-if events fire (docs/20 §6.2).
 *
 * @package Bookline
 */

declare( strict_types=1 );

namespace Bookline\Application\Automation;

use Bookline\Domain\Automation\AutomationRepository;
use Bookline\Domain\Automation\AutomationRunRepository;
use Bookline\Domain\Automation\SkipReason;
use Bookline\Domain\Automation\SubjectType;

/**
 * Walks open runs for a subject and cancels those that listen for the event.
 *
 * @since 0.1.0
 */
final class AutomationCancelService {

	/**
	 * Constructor.
	 *
	 * @param AutomationRepository    $automations Automations.
	 * @param AutomationRunRepository $runs        Runs.
	 * @param AutomationExecutor      $executor    Executor.
	 */
	public function __construct(
		private readonly AutomationRepository $automations,
		private readonly AutomationRunRepository $runs,
		private readonly AutomationExecutor $executor,
	) {}

	/**
	 * Apply cancel-if.
	 *
	 * @param string      $event        Event identifier.
	 * @param SubjectType $subject_type Subject type.
	 * @param int         $subject_id   Subject id.
	 * @param int|null    $customer_id  Customer id for customer-scoped cancel-if.
	 *
	 * @since 0.1.0
	 */
	public function handle( string $event, SubjectType $subject_type, int $subject_id, ?int $customer_id = null ): void {
		$seen = [];
		foreach ( $this->runs->find_open_for_subject( $subject_type, $subject_id ) as $run ) {
			$this->maybe_cancel( $run, $event );
			$id = $run->id();
			if ( null !== $id ) {
				$seen[ $id ] = true;
			}
		}
		if ( null === $customer_id || $customer_id < 1 ) {
			return;
		}
		foreach ( $this->runs->find_open_for_customer( $customer_id ) as $run ) {
			$rid = $run->id();
			if ( null !== $rid && isset( $seen[ $rid ] ) ) {
				continue;
			}
			$this->maybe_cancel( $run, $event );
		}
	}

	/**
	 * Cancel one run if the automation listens for the event.
	 *
	 * @param \Bookline\Domain\Automation\AutomationRun $run   Run.
	 * @param string                                    $event Event.
	 */
	private function maybe_cancel( \Bookline\Domain\Automation\AutomationRun $run, string $event ): void {
		$automation = $this->automations->find_by_id( $run->automation_id() );
		if ( null === $automation ) {
			return;
		}
		$cancel = $automation->cancel_if();
		if ( null === $cancel || ! $cancel->matches( $event ) ) {
			return;
		}
		$this->executor->cancel_run( $run, SkipReason::CancelIf );
	}
}