<?php
/**
 * Background jobs on WP-Cron. When another plugin loads Action Scheduler (WooCommerce, an add-on …),
 * jobs use it instead.
 *
 * @package StreamSera
 */

namespace StreamSera\Jobs;

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

/**
 * Thin scheduling wrapper: Action Scheduler when it is loaded, WP-Cron otherwise.
 */
class Scheduler {

	const GROUP = 'streamsera';

	/**
	 * Whether Action Scheduler functions are usable.
	 *
	 * @return bool
	 */
	public static function has_as() {
		return function_exists( 'as_schedule_recurring_action' ) && function_exists( 'as_has_scheduled_action' );
	}

	/**
	 * Ensure a recurring job exists.
	 *
	 * @param string $hook     Action hook.
	 * @param int    $interval Seconds.
	 * @param array  $args     Args.
	 */
	public static function ensure_recurring( $hook, $interval, $args = array() ) {
		if ( self::has_as() ) {
			if ( ! as_has_scheduled_action( $hook, $args, self::GROUP ) ) {
				as_schedule_recurring_action( time() + 10, $interval, $hook, $args, self::GROUP );
			}
			return;
		}
		if ( ! wp_next_scheduled( $hook, $args ) ) {
			wp_schedule_event( time() + 10, self::interval_name( $interval ), $hook, $args );
		}
	}

	/**
	 * Queue a one-off job.
	 *
	 * @param string $hook Hook.
	 * @param array  $args Args.
	 * @param int    $delay Seconds from now.
	 */
	public static function enqueue( $hook, $args = array(), $delay = 0 ) {
		if ( self::has_as() ) {
			as_schedule_single_action( time() + max( 0, (int) $delay ), $hook, $args, self::GROUP );
			return;
		}
		wp_schedule_single_event( time() + max( 0, (int) $delay ), $hook, $args );
	}

	/**
	 * Remove all jobs for a hook.
	 *
	 * @param string $hook Hook.
	 */
	public static function cancel( $hook ) {
		if ( self::has_as() ) {
			as_unschedule_all_actions( $hook, array(), self::GROUP );
		}
		wp_clear_scheduled_hook( $hook );
	}

	/**
	 * Register custom WP-Cron intervals used as fallback.
	 *
	 * @param array $schedules Schedules.
	 * @return array
	 */
	public static function cron_schedules( $schedules ) {
		foreach ( array( 60, 300, 900, 3600 ) as $seconds ) {
			$schedules[ self::interval_name( $seconds ) ] = array(
				'interval' => $seconds,
				/* translators: %d: interval in seconds. */
				'display'  => sprintf( _n( 'StreamSera: every %d second', 'StreamSera: every %d seconds', $seconds, 'streamsera' ), $seconds ),
			);
		}
		return $schedules;
	}

	/**
	 * Interval → schedule name.
	 *
	 * @param int $seconds Seconds.
	 * @return string
	 */
	private static function interval_name( $seconds ) {
		return 'streamsera_' . (int) $seconds;
	}
}