<?php
/**
 * Background jobs on Action Scheduler.
 *
 * @package Unbreak
 */

namespace Unbreak\Queue;

use Unbreak\Install\Lifecycle;

defined( 'ABSPATH' ) || exit;

/**
 * Registers Action Scheduler hooks and provides enqueue helpers.
 */
final class Jobs {

	/**
	 * Action Scheduler group for all Unbreak actions.
	 */
	public const GROUP = 'unbreak';

	/**
	 * Register hooks.
	 */
	public function register(): void {
		add_action( 'action_scheduler_init', array( $this, 'on_scheduler_ready' ) );
	}

	/**
	 * Runs once Action Scheduler's data store is available.
	 */
	public function on_scheduler_ready(): void {
		// The flag stays as an autoloaded 0 instead of being deleted: a missing option would cost a
		// query on every page view.
		if ( get_option( Lifecycle::FULL_SCAN_FLAG ) ) {
			update_option( Lifecycle::FULL_SCAN_FLAG, 0, true );
			do_action( 'unbreak_start_full_scan' );
		}
	}

	/**
	 * Whether this request may do scheduling housekeeping (checking that recurring actions exist).
	 * Those checks query Action Scheduler's table, so they never run on front-end page views.
	 */
	public static function is_background_context(): bool {
		return is_admin() || wp_doing_cron() || wp_doing_ajax() || ( defined( 'WP_CLI' ) && WP_CLI );
	}

	/**
	 * Cancel every pending action of a hook, whatever its arguments. (as_unschedule_all_actions() with a
	 * hook *and* a group only matches actions whose args are exactly the ones given.) All our hooks are
	 * prefixed with unbreak_, so cancelling by hook only touches our own actions.
	 *
	 * @param string $hook Hook name.
	 */
	public static function cancel( string $hook ): void {
		if ( function_exists( 'as_unschedule_all_actions' ) ) {
			as_unschedule_all_actions( $hook );
		}
	}

	/**
	 * Enqueue an async action once (no duplicate pending action with the same hook and args).
	 *
	 * @param string           $hook Hook name.
	 * @param array<int,mixed> $args Arguments.
	 */
	public static function enqueue_unique( string $hook, array $args = array() ): void {
		if ( ! function_exists( 'as_enqueue_async_action' ) ) {
			return;
		}
		if ( function_exists( 'as_has_scheduled_action' ) && as_has_scheduled_action( $hook, $args, self::GROUP ) ) {
			return;
		}
		as_enqueue_async_action( $hook, $args, self::GROUP );
	}
}