=Starting the Favourites.js setup, converting previous Northeh stuff to new...

Jake Vanderwerf

4 days ago 0afb2c0046b55c123eafb4ab9ee77efa68d12463

 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();
      }
   }
}