Storeman\LockAdapter\StorageBasedLockAdapter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	64
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
B	doAcquireLock()	0	31	5
A	doReleaseLock()	0	4	1
A	getLockFileName()	0	4	1

<?php

namespace Storeman\LockAdapter;

use Storeman\StorageAdapter\StorageAdapterInterface;

class StorageBasedLockAdapter extends AbstractLockAdapter
{
    /**
     * @var StorageAdapterInterface
     */
    protected $storageAdapter;

    public function __construct(StorageAdapterInterface $storageAdapter)
    {
        $this->storageAdapter = $storageAdapter;
    }

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

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

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

        $started = time();

        while(true)
        {
            if (!$this->storageAdapter->exists($lockFileName))
            {
                $this->storageAdapter->write($lockFileName, $payload);

                return true;
            }

            // timeout not reached: sleep another round and try againg
            if ($timeout === null || ($started + $timeout) < time())
            {
                sleep(3);
            }

            // timeout reached: return false
            else
            {
                return false;
            }
        }

        return false;
    }

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

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