<?php
/**
 * Scheduled clean-up: temporary uploads, entry retention and the job queue.
 *
 * @package TFlexForms
 */

declare( strict_types = 1 );

namespace TFlexForms;

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

/**
 * Runs hourly through WP-Cron.
 */
final class Maintenance {

	public const HOOK = 'tflexforms_maintenance';

	/**
	 * Schedules the job if needed.
	 */
	public static function schedule(): void {
		if ( ! wp_next_scheduled( self::HOOK ) ) {
			wp_schedule_event( time() + 300, 'hourly', self::HOOK );
		}
	}

	/**
	 * Removes the scheduled events (hourly maintenance and the next job run).
	 */
	public static function unschedule(): void {
		wp_clear_scheduled_hook( self::HOOK );
		wp_clear_scheduled_hook( Jobs::HOOK );
	}

	/**
	 * The hourly job: delete stale temporary uploads and duplicate-submission
	 * keys, queue the retention clean-up, then run any due background jobs
	 * (a safety net for sites where the jobs' own cron event was missed).
	 */
	public static function run(): void {
		Uploads::cleanup_temp();
		Submission_Keys::purge();

		if ( (int) Settings::get( 'retention_days' ) > 0 && null === Jobs::find_pending( 'retention' ) ) {
			Jobs::enqueue( 'retention' );
		}
		Jobs::run();
		Jobs::purge();
	}

	/**
	 * Job handler: deletes entries past the retention period in bounded
	 * batches, and queues itself again while older entries remain.
	 */
	public static function retention_job(): bool {
		$days = (int) Settings::get( 'retention_days' );
		if ( $days <= 0 ) {
			return true;
		}
		for ( $i = 0; $i < 5; $i++ ) {
			$ids = Entry_Store::ids_older_than( $days, 200 );
			if ( array() === $ids ) {
				return true;
			}
			Entry_Store::delete( $ids );
		}
		if ( array() !== Entry_Store::ids_older_than( $days, 1 ) ) {
			Jobs::enqueue( 'retention' );
		}
		return true;
	}
}