Archivr\LockAdapter\ConnectionBasedLockAdapter

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	doGetLock()	0	9	2
A	doAcquireLock()	0	14	2
A	doReleaseLock()	0	4	1
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;
    }

    protected function doGetLock(string $name)
    {
        if (!$this->connectionAdapter->exists($this->getLockFileName($name)))
        {
            return null;
        }

        return Lock::fromPayload($this->connectionAdapter->read($this->getLockFileName($name)));
    }

    protected function doAcquireLock(string $name): bool
    {
        $lockFileName = $this->getLockFileName($name);
        $payload = $this->getNewLockPayload($name);

        if ($this->connectionAdapter->exists($lockFileName))
        {
            return false;
        }

        $this->connectionAdapter->write($lockFileName, $payload);

        return true;
    }

    protected function doReleaseLock(string $name)
    {
        $this->connectionAdapter->unlink($this->getLockFileName($name));
    }

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