adding InMemoryFifoQueueStore

Author: clegginabox

README.md

@@ -1,13 +1,11 @@
-# airlock-php
+# airlock-php - Distributed locking with manners
+
 [![Codacy Badge](https://app.codacy.com/project/badge/Grade/cdc12dbceac04dc8bbece4012222cd3d)](https://app.codacy.com/gh/clegginabox/airlock-php/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_grade)
 ![Tests](https://github.com/clegginabox/airlock-php/actions/workflows/tests.yaml/badge.svg)
 [![Codacy Badge](https://app.codacy.com/project/badge/Coverage/cdc12dbceac04dc8bbece4012222cd3d)](https://app.codacy.com/gh/clegginabox/airlock-php/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_coverage)
 
 <img width="830" height="453" alt="airlock-php-red" src="https://github.com/user-attachments/assets/361fb9d2-00a4-4a11-b8cf-cde4fc951b9f" />
 
-
-# Distributed locking with manners
-
 British-style queuing for your code and infrastructure. First come, first served. As it should be.
 
 (Not to be confused with a message queue. Airlock doesn’t process messages — it just decides who’s coming in and who’s staying outside in the rain.)

rector.php

@@ -3,7 +3,6 @@
 declare(strict_types=1);
 
 use Rector\Config\RectorConfig;
-use Rector\PHPUnit\Set\PHPUnitSetList;
 
 return RectorConfig::configure()
     ->withComposerBased()

src/Bridge/Symfony/Seal/SymfonySemaphoreSeal.php

@@ -5,7 +5,6 @@
 namespace Clegginabox\Airlock\Bridge\Symfony\Seal;
 
 use Clegginabox\Airlock\Exception\LeaseExpiredException;
-use Clegginabox\Airlock\Exception\SealAcquiringException;
 use Clegginabox\Airlock\Exception\SealReleasingException;
 use Clegginabox\Airlock\Seal\RefreshableSeal;
 use Clegginabox\Airlock\Seal\ReleasableSeal;
@@ -28,7 +27,7 @@ public function __construct(
     ) {
     }
 
-    public function tryAcquire(): SymfonySemaphoreToken
+    public function tryAcquire(): ?SymfonySemaphoreToken
     {
         $key = new Key($this->resource, $this->limit, $this->weight);
         $semaphore = $this->factory->createSemaphoreFromKey(
@@ -38,7 +37,7 @@ public function tryAcquire(): SymfonySemaphoreToken
         );
 
         if (!$semaphore->acquire()) {
-            throw new SealAcquiringException('Unable to acquire semaphore');
+            return null;
         }
 
         return new SymfonySemaphoreToken($key);

src/Queue/Storage/Fifo/InMemoryFifoQueueStore.php

@@ -0,0 +1,56 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Clegginabox\Airlock\Queue\Storage\Fifo;
+
+class InMemoryFifoQueueStore implements FifoQueueStorage
+{
+    /**
+     * @var list<string>
+     */
+    private array $queue = [];
+
+    public function addToBack(string $identifier): int
+    {
+        if (!in_array($identifier, $this->queue, true)) {
+            $this->queue[] = $identifier;
+        }
+
+        return $this->getPosition($identifier);
+    }
+
+    public function remove(string $identifier): void
+    {
+        $this->queue = array_values(
+            array_filter($this->queue, static fn ($id) => $id !== $identifier)
+        );
+    }
+
+    public function peekFront(): ?string
+    {
+        return $this->queue[0] ?? null;
+    }
+
+    public function popFront(): ?string
+    {
+        return array_shift($this->queue);
+    }
+
+    public function getPosition(string $identifier): ?int
+    {
+        $index = array_search($identifier, $this->queue, true);
+
+        return $index === false ? null : $index + 1;
+    }
+
+    public function contains(string $identifier): bool
+    {
+        return in_array($identifier, $this->queue, true);
+    }
+
+    public function clear(): void
+    {
+        $this->queue = [];
+    }
+}

…orage/Fifo/Redis/RedisFifoQueueStore.php …eue/Storage/Fifo/RedisFifoQueueStore.phpsrc/Queue/Storage/Fifo/Redis/RedisFifoQueueStore.php renamed to src/Queue/Storage/Fifo/RedisFifoQueueStore.php src/Queue/Storage/Fifo/Redis/RedisFifoQueueStore.php renamed to src/Queue/Storage/Fifo/RedisFifoQueueStore.php

@@ -2,9 +2,8 @@
 
 declare(strict_types=1);
 
-namespace Clegginabox\Airlock\Queue\Storage\Fifo\Redis;
+namespace Clegginabox\Airlock\Queue\Storage\Fifo;
 
-use Clegginabox\Airlock\Queue\Storage\Fifo\FifoQueueStorage;
 use Redis;
 
 /**

…Lottery/Redis/RedisLotteryQueueStore.php …orage/Lottery/RedisLotteryQueueStore.phpsrc/Queue/Storage/Lottery/Redis/RedisLotteryQueueStore.php renamed to src/Queue/Storage/Lottery/RedisLotteryQueueStore.php src/Queue/Storage/Lottery/Redis/RedisLotteryQueueStore.php renamed to src/Queue/Storage/Lottery/RedisLotteryQueueStore.php

@@ -2,9 +2,8 @@
 
 declare(strict_types=1);
 
-namespace Clegginabox\Airlock\Queue\Storage\Lottery\Redis;
+namespace Clegginabox\Airlock\Queue\Storage\Lottery;
 
-use Clegginabox\Airlock\Queue\Storage\Lottery\LotteryQueueStorage;
 use Redis;
 
 class RedisLotteryQueueStore implements LotteryQueueStorage

src/Seal/InMemorySeal.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Clegginabox\Airlock\Seal;
+
+class InMemorySeal implements ReleasableSeal, RefreshableSeal
+{
+    public function tryAcquire(): ?SealToken
+    {
+    }
+
+    public function refresh(SealToken $token, ?float $ttlInSeconds = null): SealToken
+    {
+        // TODO: Implement refresh() method.
+    }
+
+    public function release(SealToken $token): void
+    {
+        // TODO: Implement release() method.
+    }
+}

src/Seal/InMemorySealToken.php

@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Clegginabox\Airlock\Seal;
+
+class InMemorySealToken implements SealToken
+{
+    public function getResource(): string
+    {
+        // TODO: Implement getResource() method.
+    }
+
+    public function getId(): string
+    {
+        // TODO: Implement getId() method.
+    }
+
+    public function __toString()
+    {
+        // TODO: Implement __toString() method.
+    }
+}

tests/Integration/Bridge/Symfony/SymfonySemaphoreSealTest.php

@@ -6,7 +6,6 @@
 
 use Clegginabox\Airlock\Bridge\Symfony\Seal\SymfonySemaphoreSeal;
 use Clegginabox\Airlock\Exception\LeaseExpiredException;
-use Clegginabox\Airlock\Exception\SealAcquiringException;
 use Clegginabox\Airlock\Tests\Factory\RedisFactory;
 use PHPUnit\Framework\TestCase;
 use Redis;
@@ -48,9 +47,9 @@ public function testItRespectsCapacityLimit(): void
         $token2 = $this->constraint->tryAcquire();
         $this->assertNotNull($token2, 'Should acquire 2nd slot');
 
-        // 3. Try third slot -> Should FAIL (throw SealAcquiringException)
-        $this->expectException(SealAcquiringException::class);
-        $this->constraint->tryAcquire();
+        // 3. Try third slot -> Should FAIL (returns null)
+        $token3 = $this->constraint->tryAcquire();
+        $this->assertNull($token3, 'Should not acquire 3rd slot');
     }
 
     public function testReleaseOpensSlot(): void
@@ -60,8 +59,8 @@ public function testReleaseOpensSlot(): void
         $this->constraint->tryAcquire();
 
         // Verify full
-        $this->expectException(SealAcquiringException::class);
-        $this->constraint->tryAcquire();
+        $token2 = $this->constraint->tryAcquire();
+        $this->assertNull($token2);
 
         // Release one
         $this->constraint->release($token1);

tests/Integration/Queue/FifoQueueTest.php

@@ -6,7 +6,7 @@
 
 use Clegginabox\Airlock\Queue\FifoQueue;
 use Clegginabox\Airlock\Queue\RedisFifoQueue;
-use Clegginabox\Airlock\Queue\Storage\Fifo\Redis\RedisFifoQueueStore;
+use Clegginabox\Airlock\Queue\Storage\Fifo\RedisFifoQueueStore;
 use Clegginabox\Airlock\Tests\Factory\RedisFactory;
 use PHPUnit\Framework\TestCase;
 use Redis;