<?php

/**
 * Workflow scheduler - processes queue via WordPress cron.
 *
 * @package AfroIT_Messaging_WorkflowAutomations
 */

namespace AfroIT\Messaging\WorkflowAutomations\Workflows;


if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

/**
 * Class WorkflowScheduler
 *
 * Registers cron hook and processes pending workflow jobs.
 */
final class WorkflowScheduler {

	private const CRON_HOOK = 'afromewo_process_workflow_queue';
	private const CRON_INTERVAL = 'every_minute';

	/**
	 * @var WorkflowQueue
	 */
	private WorkflowQueue $queue;

	/**
	 * Constructor.
	 *
	 * @param WorkflowQueue|null $queue Workflow queue.
	 */
	public function __construct( ?WorkflowQueue $queue = null ) {
		$this->queue = $queue ?? new WorkflowQueue();
	}

	/**
	 * Register cron schedule and hook.
	 *
	 * @return void
	 */
	public function register(): void {
        /*
		add_filter( 'cron_schedules', array( $this, 'addCronSchedule' ) );
		add_action( self::CRON_HOOK, array( $this, 'processWorkflowQueue' ) );

		if ( ! wp_next_scheduled( self::CRON_HOOK ) ) {
			wp_schedule_event( time(), self::CRON_INTERVAL, self::CRON_HOOK );
		}
        */
	}

	/**
	 * Add custom cron interval.
	 *
	 * @param array<string, array<string, int|string>> $schedules Cron schedules.
	 * @return array<string, array<string, int|string>>
	 */
	public function addCronSchedule( array $schedules ): array {
		$schedules[ self::CRON_INTERVAL ] = array(
			'interval' => 60,
			'display'  => __( 'Every Minute', 'afroit-messaging-workflows' ),
		);
		return $schedules;
	}

	/**
	 * Process pending workflow jobs.
	 *
	 * @return void
	 */
	public function processWorkflowQueue(): void {
		$this->queue->processPending( 10 );
	}
}