Set initialWaitTtl = 0; add $waitTtl param to withTtl()

composer.json

@@ -34,7 +34,7 @@
     },
     "require-dev": {
         "phpunit/phpunit": "^10.0",
-        "vimeo/psalm": "^5.9"
+        "vimeo/psalm": "^5.9 || ^6.0"
     },
     "autoload": {
         "psr-4": {

src/RandomTokenGenerator.php

@@ -14,6 +14,7 @@ public function __construct(
     ) {
     }
 
+    #[\Override]
     public function generate(): string
     {
         return \bin2hex(\random_bytes($this->length));

src/RoadRunnerStore.php

@@ -25,17 +25,18 @@ public function __construct(
         private readonly RR\LockInterface $lock,
         private readonly TokenGeneratorInterface $tokens = new RandomTokenGenerator(),
         private readonly float $initialTtl = 300.0,
-        private readonly float $initialWaitTtl = 60,
+        private readonly float $initialWaitTtl = 0,
     ) {
         \assert($this->initialTtl >= 0);
         \assert($this->initialWaitTtl >= 0);
     }
 
-    public function withTtl(float $ttl): self
+    public function withTtl(float $ttl, float $waitTtl = 0): self
     {
-        return new self($this->lock, $this->tokens, $ttl, $this->initialWaitTtl);
+        return new self($this->lock, $this->tokens, $ttl, $waitTtl);
     }
 
+    #[\Override]
     public function save(Key $key): void
     {
         \assert(false === $key->hasState(__CLASS__));
@@ -46,7 +47,7 @@ public function save(Key $key): void
             /** @var non-empty-string $resource */
             $resource = (string)$key;
 
-            $status = $this->lock->lock($resource, $lockId, $this->initialTtl);
+            $status = $this->lock->lock($resource, $lockId, $this->initialTtl, $this->initialWaitTtl);
 
             if (false === $status) {
                 throw new LockConflictedException('RoadRunner. Failed to make lock');
@@ -58,14 +59,15 @@ public function save(Key $key): void
         }
     }
 
+    #[\Override]
     public function saveRead(Key $key): void
     {
         \assert(false === $key->hasState(__CLASS__));
         $lockId = $this->getUniqueToken($key);
 
         /** @var non-empty-string $resource */
         $resource = (string)$key;
-        $status = $this->lock->lockRead($resource, $lockId, $this->initialTtl);
+        $status = $this->lock->lockRead($resource, $lockId, $this->initialTtl, $this->initialWaitTtl);
 
         if (false === $status) {
             throw new LockConflictedException('RoadRunner. Failed to make read lock');
@@ -74,6 +76,7 @@ public function saveRead(Key $key): void
         $key->setState(__CLASS__, $lockId);
     }
 
+    #[\Override]
     public function exists(Key $key): bool
     {
         \assert($key->hasState(__CLASS__));
@@ -86,6 +89,7 @@ public function exists(Key $key): bool
         return $this->lock->exists($resource, $lockId);
     }
 
+    #[\Override]
     public function putOffExpiration(Key $key, float $ttl): void
     {
         \assert($key->hasState(__CLASS__));
@@ -101,6 +105,7 @@ public function putOffExpiration(Key $key, float $ttl): void
         }
     }
 
+    #[\Override]
     public function delete(Key $key): void
     {
         \assert($key->hasState(__CLASS__));
@@ -111,6 +116,7 @@ public function delete(Key $key): void
         $this->lock->release($resource, $lockId);
     }
 
+    #[\Override]
     public function waitAndSave(Key $key): void
     {
         $lockId = $this->getUniqueToken($key);

tests/RoadRunnerStoreTest.php

@@ -166,7 +166,7 @@ public function testWaitAndSaveSuccess(): void
     {
         $this->rrLock->expects($this->once())
             ->method('lock')
-            ->with('resource-name', 'random-id', 300, 60)
+            ->with('resource-name', 'random-id', 300, 0)
             ->willReturn('lock-id');
 
         $store = new RoadRunnerStore($this->rrLock, $this->tokens);
@@ -184,7 +184,7 @@ public function testWaitAndSaveFail(): void
 
         $this->rrLock->expects($this->once())
             ->method('lock')
-            ->with('resource-name', 'random-id', 300, 60)
+            ->with('resource-name', 'random-id', 300, 0)
             ->willReturn(false);
 
         $store = new RoadRunnerStore($this->rrLock, $this->tokens);