<?php
/** Best-effort local post-commit events, with no customer identity or bearer data. */
namespace Abientot\Support;
use Abientot\Repositories\BookingLock;
if ( ! defined( 'ABSPATH' ) ) {
	exit;
}
final class BookingEvents {
	private static array $pending = array();
	private const FIELDS          = array( 'id', 'service_id', 'staff_id', 'location_id', 'status_id', 'start_utc', 'end_utc', 'timezone', 'duration_minutes', 'price_cents', 'currency', 'payment_status', 'source' );
	public static function dispatch( string $operation, int $id, ?array $before = null, array $after = array() ): void {
		if ( $id <= 0 ) {
			return;
		}
		$snapshot = static fn( array $row ): array => array_intersect_key( $row, array_flip( self::FIELDS ) );
		$event    = array( sanitize_key( $operation ), $id, $before === null ? null : $snapshot( $before ), $snapshot( $after ) );
		if ( BookingLock::is_held() ) {
			// Caller-owned locks may outlive the handler. No listener runs under that mutex.
			self::$pending[] = $event;
			add_action( 'abientot_booking_lock_released', array( self::class, 'flush' ) );
			return;
		}
		self::emit( $event );
	}
	public static function flush(): void {
		if ( BookingLock::is_held() ) {
			return;
		}
		$pending       = self::$pending;
		self::$pending = array();
		foreach ( $pending as $event ) {
			self::emit( $event );
		}
	}
	private static function emit( array $event ): void {
		try {
			do_action( 'abientot_booking_committed', ...$event );
		} catch ( \Throwable $error ) {
					/* Persistence succeeded; listeners own durable retries. */
		}
	}
	/** Request-local notification follows committed event listeners and actual mutex release. */
	public static function notify_after_unlock( callable $send ): void {
		if ( ! BookingLock::is_held() ) {
			try {
					$send();
			} catch ( \Throwable $error ) {
			}
			return;
		}
		$callback = null;
		$callback = static function () use ( &$callback, $send ): void {
			remove_action( 'abientot_booking_lock_released', $callback, 20 );
			try {
				$send();
			} catch ( \Throwable $error ) {
			}
		};
		add_action( 'abientot_booking_lock_released', $callback, 20 );
	}
}