Zenstruck\ScheduleBundle\Schedule\Extension\LockingExtension

Complexity

Total Complexity

6

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	releaseLock()	0	6	2
A	__construct()	0	3	1
A	acquireLock()	0	15	3

<?php

namespace Zenstruck\ScheduleBundle\Schedule\Extension;

use Symfony\Component\Lock\LockFactory;
use Symfony\Component\Lock\LockInterface;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
abstract class LockingExtension
{
    private $ttl;

    /** @var LockInterface|null */
    private $lock;

    public function __construct(int $ttl)
    {
        $this->ttl = $ttl;
    }

    final public function acquireLock(LockFactory $lockFactory, string $mutex): bool
    {
        if (null !== $this->lock) {
            throw new \LogicException('A lock is already in place.');
        }

        $this->lock = $lockFactory->createLock('symfony-schedule-'.$mutex, $this->ttl);

        if ($this->lock->acquire()) {
            return true;
        }

        $this->lock = null;

        return false;
    }

    final public function releaseLock(): void
    {
        if ($this->lock) {
            $this->lock->release();

            $this->lock = null;
        }
    }
}