<?php

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

require_once __DIR__ . '/services/class-epicformbuilder-services-pending-values.php';

/**
 * Scheduled maintenance for values recorded before a submission existed.
 *
 * @since 1.0.0
 *
 * @package    Epicformbuilder
 * @subpackage Epicformbuilder/includes
 */
class Epicformbuilder_Cron {

	/**
	 * Hook fired on each purge pass.
	 *
	 * @var string
	 */
	public const HOOK = 'epicforms_purge_pending_values';

	/**
	 * Schedules the purge if it is not already scheduled.
	 *
	 * @since 1.0.0
	 *
	 * @return void
	 */
	public static function schedule() {
		if ( ! wp_next_scheduled( self::HOOK ) ) {
			wp_schedule_event( time() + HOUR_IN_SECONDS, 'hourly', self::HOOK );
		}
	}

	/**
	 * Removes the scheduled purge.
	 *
	 * @since 1.0.0
	 *
	 * @return void
	 */
	public static function unschedule() {
		wp_clear_scheduled_hook( self::HOOK );
	}

	/**
	 * Deletes expired rows, then announces each batch.
	 *
	 * An expired row can represent a real uploaded object or a real payment, so
	 * addons are told about every batch, and the rows are already gone when
	 * they are told — deleting first means a fatal in a listener cannot make
	 * the purge loop forever on the same rows.
	 *
	 * @since 1.0.0
	 *
	 * @return int Number of rows removed.
	 */
	public static function purge(): int {
		$rows = Epicformbuilder_Services_Pending_Values::purge_expired();

		if ( empty( $rows ) ) {
			return 0;
		}

		$by_submission = [];

		foreach ( $rows as $row ) {
			$by_submission[ $row['submission_uid'] ][] = [
				'field_id' => $row['field_id'],
				'item_key' => $row['item_key'],
				'value'    => $row['value'],
				'meta'     => $row['meta'],
			];
		}

		foreach ( $by_submission as $submission_uid => $items ) {
			/** This action is documented in includes/handlers/class-epicformbuilder-handlers-rest-api-form-submission-create.php */
			do_action( 'epicforms_pending_values_released', $items, (string) $submission_uid );
		}

		return count( $rows );
	}
}