<?php

/**
 * Async event dispatcher - queues events instead of dispatching synchronously.
 *
 * @package AfroIT_Messaging_WorkflowAutomations
 */

namespace AfroIT\Messaging\WorkflowAutomations\Async;


use AfroIT\Messaging\WorkflowAutomations\Events\Event;
use AfroIT\Messaging\WorkflowAutomations\ExecutionEngine\ExecutionBootstrap;
use AfroIT\Messaging\WorkflowAutomations\Logging\Log;

if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

/**
 * Class AsyncEventDispatcher
 *
 * Stores events in the event queue table for later processing by the
 * local execution engine. Keeps WooCommerce checkout fast by deferring work.
 */
final class AsyncEventDispatcher {

	/**
	 * @var EventQueueRepository
	 */
	private EventQueueRepository $repository;

	/**
	 * Constructor.
	 *
	 * @param EventQueueRepository|null $repository Event queue repository.
	 */
	public function __construct( ?EventQueueRepository $repository = null ) {
		$this->repository = $repository ?? new EventQueueRepository();
	}

	/**
	 * Dispatch an event asynchronously (enqueue for later processing).
	 *
	 * @param Event $event The event to dispatch.
	 * @return int|false Queue record ID or false on failure.
	 */
	public function dispatch( Event $event ) {
		$event_name  = $event->getName();
		$payload     = $event->getPayload();
		$payload['event_class'] = get_class( $event );
		$payload_json = wp_json_encode( $payload );

		$id = $this->repository->enqueue( $event_name, $payload_json );

		if ( false !== $id ) {
			Log::info( 'Event queued for async processing', array(
				'event' => $event_name,
				'queue_id' => $id,
			) );
			ExecutionBootstrap::request_tick();
		}

		return $id;
	}
}