<?php
declare(strict_types=1);

namespace WP_Rocket\Engine\Common\JobManager\Queue;

use WP_Rocket\Engine\Common\Queue\AbstractASQueue;

/**
 * Queue
 *
 * A job queue using WordPress actions.
 *
 * @version 3.11.0
 */
class Queue extends AbstractASQueue {

	/**
	 * Queue group.
	 *
	 * @var string
	 */
	protected $group = 'rocket-rucss';

	/**
	 * Pending jobs cron hook.
	 *
	 * @var string
	 */
	private $pending_job_cron = 'rocket_saas_pending_jobs_cron';

	/**
	 * Cron hook name for checking the status of jobs asynchronously.
	 *
	 * @var string
	 */
	private $check_job_status_hook = 'rocket_saas_job_check_status';

	/**
	 * Check if pending jobs cron is scheduled.
	 *
	 * @return bool
	 */
	public function is_pending_jobs_cron_scheduled() {
		return $this->is_scheduled( $this->pending_job_cron );
	}

	/**
	 * Cancel pending jobs cron.
	 *
	 * @return void
	 */
	public function cancel_pending_jobs_cron() {
		$this->cancel_all( $this->pending_job_cron );
	}

	/**
	 * Schedule pending jobs cron.
	 *
	 * @param int $interval Cron interval in seconds.
	 *
	 * @return int
	 */
	public function schedule_pending_jobs_cron( int $interval ) {
		return $this->schedule_recurring( time(), $interval, $this->pending_job_cron );
	}

	/**
	 * Add Async job with DB row ID.
	 *
	 * @param string  $url Url from DB row.
	 * @param boolean $is_mobile Is mobile from DB row.
	 * @param string  $optimization_type The type of optimization request to send.
	 *
	 * @return int
	 */
	public function add_job_status_check_async( string $url, bool $is_mobile, string $optimization_type ) {
		return $this->add_async(
			$this->check_job_status_hook,
			[
				$url,
				$is_mobile,
				$optimization_type,
			]
		);
	}

	/**
	 * Schedule a single task to check the status of an optimization request.
	 *
	 * @param int    $time The timestamp when the job will run.
	 * @param string $url The URL from the DB row.
	 * @param bool   $is_mobile Whether the request is for mobile.
	 * @param string $optimization_type The type of optimization request to schedule.
	 *
	 * @return int The action ID.
	 */
	public function schedule_job_status_single_task( int $time, string $url, bool $is_mobile, string $optimization_type ) {
		return $this->schedule_single(
			$time,
			$this->check_job_status_hook,
			[
				$url,
				$is_mobile,
				$optimization_type,
			]
		);
	}
}