From 47e77f9fac1155c536b2b87fec552c7fcce66fa6 Mon Sep 17 00:00:00 2001
From: Jake Vanderwerf <get@jakevanderwerf.ca>
Date: Mon, 01 Jun 2026 18:06:34 +0000
Subject: [PATCH] =Timeline block fixes. Next up: adding article schema classes
---
inc/managers/queue/Locker.php | 61 ++++++++++--------------------
1 files changed, 20 insertions(+), 41 deletions(-)
diff --git a/inc/managers/queue/Locker.php b/inc/managers/queue/Locker.php
index cd527ad..4d4b5d6 100644
--- a/inc/managers/queue/Locker.php
+++ b/inc/managers/queue/Locker.php
@@ -1,65 +1,44 @@
<?php
namespace JVBase\managers\queue;
+
if (!defined('ABSPATH')) {
exit;
}
-
class Locker
{
private string $lockKey;
- private int $ttl;
+ private int $timeout;
private ?string $token = null;
- public function __construct(string $key = 'queue_processor', int $ttl = 300)
+ public function __construct(string $key = 'queue', int $timeout = 60)
{
- $this->lockKey = BASE . '_lock_' . $key;
- $this->ttl = $ttl;
+ $this->lockKey = BASE . $key . '_lock';
+ $this->timeout = $timeout;
}
- public function acquire(): bool
+ public function withLock(callable $callback): void
{
- // Generate unique token for this process
- $this->token = uniqid(gethostname() . '_', true);
+ if (!$this->acquire()) return;
- // SET NX with TTL - atomic "set if not exists"
- $result = wp_cache_add($this->lockKey, $this->token, 'locks', $this->ttl);
-
- return $result === true;
- }
-
- public function release(): void
- {
- if (!$this->token) {
- return;
+ try {
+ $callback();
+ } finally {
+ $this->unlock();
}
+ }
- // Only release if we own the lock
+ private function acquire(): bool
+ {
+ $this->token = bin2hex(random_bytes(8));
+ return (bool) wp_cache_add($this->lockKey, $this->token, 'locks', $this->timeout);
+ }
+
+ public function unlock(): void
+ {
$current = wp_cache_get($this->lockKey, 'locks');
if ($current === $this->token) {
wp_cache_delete($this->lockKey, 'locks');
}
-
$this->token = null;
}
-
- public function isLocked(): bool
- {
- return wp_cache_get($this->lockKey, 'locks') !== false;
- }
-
- /**
- * Execute callback with lock, auto-release after
- */
- public function withLock(callable $callback): mixed
- {
- if (!$this->acquire()) {
- return null;
- }
-
- try {
- return $callback();
- } finally {
- $this->release();
- }
- }
}
--
Gitblit v1.10.0