wip

Author: gam6itko

.gitattributes

@@ -0,0 +1 @@
+/tests export-ignore

.github/workflows/phpunit.yml

@@ -0,0 +1,17 @@
+on:
+  push:
+    branches:
+      - master
+
+name: phpunit
+
+jobs:
+  phpunit:
+    uses: spiral/gh-actions/.github/workflows/phpunit.yml@master
+    with:
+      os: >-
+        ['ubuntu-latest']
+      php: >-
+        ['8.1', '8.2']
+      stability: >-
+        ['prefer-stable']

.github/workflows/psalm.yml

@@ -0,0 +1,15 @@
+on:
+  push:
+    branches:
+      - master
+
+name: static analysis
+
+jobs:
+  psalm:
+    uses: spiral/gh-actions/.github/workflows/psalm.yml@master
+    with:
+      os: >-
+        ['ubuntu-latest']
+      php: >-
+        ['8.1']

.gitignore

@@ -0,0 +1,21 @@
+# IDEA
+.idea/
+*.iml
+
+# Composer
+composer.phar
+vendor
+composer.lock
+
+# OS
+.DS_Store
+Thumbs.db
+*.exe
+
+# Other
+.phpunit.result.cache
+.php_cs.cache
+clover.xml
+.env
+builds
+

composer.json

@@ -0,0 +1,61 @@
+{
+  "name": "spiral/symfony-lock-driver",
+  "type": "library",
+  "description": "RoadRunner: HTTP and PSR-7 worker",
+  "license": "MIT",
+  "authors": [
+    {
+      "name": "Pavel Buchnev (butschster)",
+      "email": "pavel.buchnev@spiralscout.com"
+    },
+    {
+      "name": "Alexander Strizhak",
+      "email": "gam6itko@gmail.com"
+    }
+  ],
+  "homepage": "https://spiral.dev/",
+  "support": {
+    "docs": "https://roadrunner.dev/docs",
+    "issues": "https://github.com/roadrunner-server/roadrunner/issues",
+    "forum": "https://forum.roadrunner.dev/",
+    "chat": "https://discord.gg/V6EK4he"
+  },
+  "require": {
+    "php": ">=8.1",
+    "roadrunner-php/lock": "^1.0",
+    "symfony/lock": "^6.0"
+  },
+  "require-dev": {
+    "phpunit/phpunit": "^10.0",
+    "vimeo/psalm": "^5.9"
+  },
+  "autoload": {
+    "psr-4": {
+      "Spiral\\RoadRunner\\Symfony\\Lock\\": "src"
+    }
+  },
+  "autoload-dev": {
+    "psr-4": {
+      "Spiral\\RoadRunner\\Symfony\\Lock\\Tests\\": "tests"
+    }
+  },
+  "funding": [
+    {
+      "type": "github",
+      "url": "https://github.com/sponsors/roadrunner-server"
+    }
+  ],
+  "scripts": {
+    "analyze": "psalm"
+  },
+  "config": {
+    "sort-packages": true
+  },
+  "minimum-stability": "dev",
+  "prefer-stable": true,
+  "extra": {
+    "branch-alias": {
+      "dev-main": "1.0-dev"
+    }
+  }
+}

src/RoadRunnerStore.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunner\Symfony\Lock;
+
+use RoadRunner\Lock\LockInterface as RrLockInterface;
+use Symfony\Component\Lock\Key;
+use Symfony\Component\Lock\PersistingStoreInterface;
+use Symfony\Component\Lock\SharedLockStoreInterface;
+
+final class RoadRunnerStore implements SharedLockStoreInterface
+{
+    private string $processId;
+
+    public function __construct(
+        private readonly RrLockInterface $rrLock,
+        ?string $processId = null
+    ) {
+        $this->processId = $processId ?? '*';
+    }
+
+    public function save(Key $key): void
+    {
+        $this->rrLock->lock((string) $key, $this->processId);
+    }
+
+    public function exists(Key $key): bool
+    {
+        return $this->rrLock->exists((string) $key, $this->processId);
+    }
+
+    public function putOffExpiration(Key $key, float $ttl): void
+    {
+        $this->rrLock->updateTTL((string) $key, $this->processId, $ttl);
+    }
+
+    public function delete(Key $key): void
+    {
+        $this->rrLock->forceRelease((string) $key);
+    }
+
+    public function saveRead(Key $key): void
+    {
+        $this->rrLock->lockRead((string) $key, $this->processId);
+    }
+}

tests/RoadRunnerStoreTest.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunner\Symfony\Lock;
+
+use PHPUnit\Framework\TestCase;
+
+final class RoadRunnerStoreTest extends TestCase
+{
+
+}