<?php
/** Shared lifecycle and short-lived scan locks. @package VidalSecurityAI */
if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

/** All recurring and continuation jobs owned by this plugin. */
function vsai_cron_hooks() {
	return array( 'vsai_send_events', 'vsai_daily_round', 'vsai_sensor_send', 'vsai_bot_prune', 'vsai_pay_watch', 'vsai_file_watch', 'vsai_digest', 'vsai_deep_scan', 'vsai_deep_tick' );
}

function vsai_clear_cron() {
	foreach ( vsai_cron_hooks() as $hook ) {
		// Includes jobs carrying arguments, including jobs from older releases.
		wp_unschedule_hook( $hook );
	}
}

/** Atomic option lock. Expired leases are removed by compare-and-delete. */
function vsai_lock_acquire( $name ) {
	global $wpdb;
	$key = 'vsai_lock_' . sanitize_key( $name );
	$old = get_option( $key );
	if ( is_array( $old ) && isset( $old['expires'] ) && $old['expires'] < time() ) {
		$wpdb->query( $wpdb->prepare( "DELETE FROM {$wpdb->options} WHERE option_name = %s AND option_value = %s", $key, maybe_serialize( $old ) ) );
		wp_cache_delete( $key, 'options' );
	}
	$lease = array( 'token' => wp_generate_uuid4(), 'expires' => time() + 300 );
	return add_option( $key, $lease, '', false ) ? $lease : false;
}

function vsai_lock_release( $name, $lease ) {
	global $wpdb;
	$key = 'vsai_lock_' . sanitize_key( $name );
	$wpdb->query( $wpdb->prepare( "DELETE FROM {$wpdb->options} WHERE option_name = %s AND option_value = %s", $key, maybe_serialize( $lease ) ) );
	wp_cache_delete( $key, 'options' );
}

/** Acknowledge only the sent entries, retaining entries added during HTTP I/O. */
function vsai_ack_queue( $name, $sent, $field = '' ) {
	global $wpdb;
	if ( ! in_array( $name, array( 'vsai_events', 'vsai_sensor' ), true ) ) {
		return false;
	}
	for ( $attempt = 0; $attempt < 5; $attempt++ ) {
		$raw = $wpdb->get_var( $wpdb->prepare( "SELECT option_value FROM {$wpdb->options} WHERE option_name = %s", $name ) );
		if ( null === $raw ) {
			return true; // Consent may have been revoked while the request was running.
		}
		$value = maybe_unserialize( $raw );
		if ( ! is_array( $value ) || ( $field && 'on' !== ( $value['estado'] ?? '' ) ) ) {
			return false;
		}
		$queue = $field ? (array) ( $value[ $field ] ?? array() ) : $value;
		foreach ( $sent as $event ) {
			$index = array_search( $event, $queue, true );
			if ( false !== $index ) {
				unset( $queue[ $index ] );
			}
		}
		if ( $field ) {
			$value[ $field ] = array_values( $queue );
			$value['enviados'] = (int) ( $value['enviados'] ?? 0 ) + count( $sent );
			$value['ultimo_envio'] = time();
		} else {
			$value = array_values( $queue );
		}
		if ( maybe_serialize( $value ) === $raw ) {
			return true;
		}
		$changed = $wpdb->query( $wpdb->prepare( "UPDATE {$wpdb->options} SET option_value = %s WHERE option_name = %s AND option_value = %s", maybe_serialize( $value ), $name, $raw ) );
		if ( $changed ) {
			wp_cache_delete( $name, 'options' );
			wp_cache_delete( 'alloptions', 'options' );
			return true;
		}
	}
	return false; // Leave queued data intact if another writer keeps winning.
}