Symfony cache lock strategy

UPGRADE.md

@@ -1,10 +1,19 @@
 UPGRADE
 =======
 
+- [2.0.0](#2.0.0) 
 - [1.2.0](#1.2.0)
 - [1.1.0](#1.1.0)
 - [0.4.0](#0.4.0)
 
+### 2.0.0 (unreleased)
+
+For the utf8mb4 compatibility with mysql some fields need to be shorten:
+
+```bash
+bin/console doctrine:schema:update
+```
+
 ### 1.2.0
 
 In the database table `ta_task_executions` a new field was introduced. Run following

composer.json

@@ -18,7 +18,8 @@
         "symfony/config": "^2.8 || ^3.4 || ^4.0",
         "symfony/console": "^2.8 || ^3.4 || ^4.0",
         "symfony/process": "^2.8 || ^3.4 || ^4.0",
-        "doctrine/orm": "^2.5"
+        "doctrine/orm": "^2.5",
+        "symfony/cache": " ^2.8 || ^3.4 || ^4.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^4.8 || ^5.0",
@@ -39,5 +40,11 @@
         "psr-4": {
             "Task\\TaskBundle\\Tests\\": "tests"
         }
+    },
+    "minimum-stability": "dev",
+    "extra": {
+        "branch-alias": {
+            "dev-develop": "2.0-dev"
+        }
     }
 }

src/Locking/CacheLockStorage.php

@@ -0,0 +1,79 @@
+<?php
+
+/*
+ * This file is part of php-task library.
+ *
+ * (c) php-task
+ *
+ * This source file is subject to the MIT license that is bundled
+ * with this source code in the file LICENSE.
+ */
+
+namespace Task\TaskBundle\Locking;
+
+use Psr\Cache\CacheItemInterface;
+use Psr\Cache\InvalidArgumentException;
+use Symfony\Contracts\Cache\CacheInterface;
+use Task\Lock\LockStorageInterface;
+
+/**
+ * Save locks in Symfony Cache.
+ */
+class CacheLockStorage implements LockStorageInterface
+{
+
+    /**
+     * Avoid key collision with a key prefix.
+     */
+    const KEY_PREFIX = 'php_task_lock__';
+
+    /**
+     * @var CacheInterface
+     */
+    protected $cache;
+
+    /**
+     * @param CacheInterface $cache
+     */
+    public function __construct($cache)
+    {
+        $this->cache = $cache;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function save($key, $ttl)
+    {
+        /** @var CacheItemInterface $cacheItem */
+        $cacheItem = $this->cache->getItem(self::KEY_PREFIX . $key);
+        $cacheItem->set('LOCK');
+        $cacheItem->expiresAfter($ttl);
+        $this->cache->save($cacheItem);
+        return true;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function delete($key)
+    {
+        try {
+            return $this->cache->deleteItem(self::KEY_PREFIX . $key);
+        } catch (InvalidArgumentException $e) {
+            return false;
+        }
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function exists($key)
+    {
+        /** @var CacheItemInterface $cacheItem */
+        $cacheItem = $this->cache->getItem(self::KEY_PREFIX . $key);
+        return $cacheItem->isHit();
+    }
+
+}
+

src/Resources/config/doctrine/Task.orm.xml

@@ -17,7 +17,7 @@
         <field name="intervalExpression" type="string" length="255" nullable="true"/>
         <field name="firstExecution" type="datetime" nullable="true"/>
         <field name="lastExecution" type="datetime" nullable="true"/>
-        <field name="systemKey" type="string" nullable="true" unique="true"/>
+        <field name="systemKey" type="string" nullable="true" unique="true" length="191"/>
         <field name="workload" type="object"/>
 
     </entity>

src/Resources/config/locking/storages.xml

@@ -8,5 +8,9 @@
 
             <tag name="task.lock.storage" alias="file"/>
         </service>
+        <service id="task.lock.storage.cache" class="Task\TaskBundle\Locking\CacheLockStorage" public="true">
+            <argument type="service" id="cache.app"></argument>
+            <tag name="task.lock.storage" alias="cache"/>
+        </service>
     </services>
 </container>