<?php
namespace JVBase\managers\queue;
use wpdb;

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

class Locker
{
	private string $lockKey;
	private int $timeout;
	protected wpdb $wpdb;
	private ?string $token = null;

	public function __construct(string $key = 'queue', int $timeout = 0)
	{
		$this->lockKey = BASE . $key . '_lock';
		$this->timeout = $timeout;
		global $wpdb;
		$this->wpdb = $wpdb;
	}

	/**
	 * Execute callback with lock, auto-release after
	 */
	public function withLock(callable $callback): void
	{
		$acquired = $this->wpdb->get_var(
			$this->wpdb->prepare(
				'SELECT GET_LOCK(%s, %d)',
				$this->lockKey,
				$this->timeout
			)
		);

		if ((int) $acquired !== 1) {
			// Lock already held — just exit quietly
			return;
		}

		try {
			$callback();
		} finally {
			$this->unlock();
		}
	}

	public function unlock():void
	{
		$this->wpdb->get_var(
			$this->wpdb->prepare(
				'SELECT RELEASE_LOCK(%s)',
				$this->lockKey
			)
		);
	}
}