Archivr\LockAdapter\ConnectionBasedLockAdapter

Complexity

Total Complexity

8

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	isLocked()	0	4	1
A	acquireLock()	0	13	3
A	releaseLock()	0	11	2
A	getLockFileName()	0	4	1

<?php

namespace Archivr\LockAdapter;

use Archivr\ConnectionAdapter\ConnectionAdapterInterface;

class ConnectionBasedLockAdapter extends AbstractLockAdapter
{
    /**
     * @var ConnectionAdapterInterface
     */
    protected $connectionAdapter;

    public function __construct(ConnectionAdapterInterface $connectionAdapter)
    {
        $this->connectionAdapter = $connectionAdapter;
    }

    public function isLocked(string $name): bool
    {
        return $this->connectionAdapter->exists($name . '.lock');
    }

    public function acquireLock(string $name): bool
    {
        $lockFileName = $this->getLockFileName($name);

        if (!$this->hasLock($name) && !$this->connectionAdapter->exists($lockFileName))
        {
            $this->connectionAdapter->write($lockFileName, $this->getLockLabel());

            $this->acquiredLocks[] = $name;
        }

        return $this->hasLock($name);
    }

    public function releaseLock(string $name): bool
    {
        if ($index = array_search($name, $this->acquiredLocks))
        {
            $this->connectionAdapter->unlink($this->getLockFileName($name));

            unset($this->acquiredLocks[$index]);
        }

        return !$this->hasLock($name);
    }

    protected function getLockFileName(string $lockName): string
    {
        return $lockName . '.lock';
    }
}