<?php
/**
 * Scheduler backed by Action Scheduler, which ships with WooCommerce.
 *
 * @package Fitzaro
 */

namespace Fitzaro\Job;

defined( 'ABSPATH' ) || exit;

/**
 * Action Scheduler runs on WP-Cron and on its own async loopback requests, keeps a log, and is
 * visible to store owners under Tools → Scheduled Actions (group "fitzaro").
 */
final class ActionSchedulerQueue implements Scheduler {

	public const GROUP = 'fitzaro';

	public const RUN_HOOK  = 'fitzaro/run_request';
	public const POLL_HOOK = 'fitzaro/poll_request';
	public const REAP_HOOK = 'fitzaro/reap';

	public const CLEANUP_HOOK = 'fitzaro/cleanup';

	/**
	 * Seconds between reaper runs.
	 */
	public const REAP_INTERVAL = 300;

	/**
	 * Seconds between cleanup runs.
	 */
	public const CLEANUP_INTERVAL = 3600;

	private const CHECKED = 'fitzaro_recurring_checked';

	/**
	 * Runs the request as soon as a worker is free.
	 *
	 * @param string $id Request UUID.
	 */
	public function run_now( string $id ): void {
		as_enqueue_async_action( self::RUN_HOOK, array( $id ), self::GROUP, true );
	}

	/**
	 * Polls the provider for the request after $delay seconds.
	 *
	 * @param string $id    Request UUID.
	 * @param int    $delay Seconds.
	 */
	public function poll_later( string $id, int $delay ): void {
		as_schedule_single_action( time() + max( 0, $delay ), self::POLL_HOOK, array( $id ), self::GROUP, true );
	}

	/**
	 * Makes sure the recurring reaper and cleanup exist. Cheap: checked at most once an hour.
	 */
	public static function ensure_recurring(): void {
		if ( false !== get_transient( self::CHECKED ) ) {
			return;
		}

		$recurring = array(
			self::REAP_HOOK    => self::REAP_INTERVAL,
			self::CLEANUP_HOOK => self::CLEANUP_INTERVAL,
		);
		foreach ( $recurring as $hook => $interval ) {
			if ( ! as_has_scheduled_action( $hook, array(), self::GROUP ) ) {
				as_schedule_recurring_action( time() + 60, $interval, $hook, array(), self::GROUP, true );
			}
		}

		set_transient( self::CHECKED, 1, HOUR_IN_SECONDS );
	}

	/**
	 * Removes every Fitzaro action. Used on deactivation.
	 */
	public static function clear(): void {
		foreach ( array( self::RUN_HOOK, self::POLL_HOOK, self::REAP_HOOK, self::CLEANUP_HOOK ) as $hook ) {
			as_unschedule_all_actions( $hook, array(), self::GROUP );
		}

		delete_transient( self::CHECKED );
	}
}