<?php
/**
 * Throttle operational-event writes that can fire on every request.
 *
 * @package Kayvandra\MarginBeacon
 */

declare(strict_types=1);

namespace Kayvandra\MarginBeacon\Infrastructure\Persistence;

/**
 * Dedupe noisy operational events (cron schedule failures, etc.).
 */
final class OperationalEventThrottle {

	const OPTION = 'aksmb_operational_event_throttle';

	/**
	 * @param string $key              Throttle key.
	 * @param int    $interval_seconds Minimum seconds between records.
	 * @return bool True when a new record should be written.
	 */
	public static function allow( $key, $interval_seconds = 3600 ) {
		$log = get_option( self::OPTION, array() );
		if ( ! is_array( $log ) ) {
			$log = array();
		}
		$now  = time();
		$prev = isset( $log[ $key ] ) ? (int) $log[ $key ] : 0;
		if ( $prev > 0 && ( $now - $prev ) < (int) $interval_seconds ) {
			return false;
		}
		$log[ (string) $key ] = $now;
		update_option( self::OPTION, $log, false );
		return true;
	}
}