Archivr\LockAdapter\AbstractLockAdapter

Complexity

Total Complexity

13

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	isLocked()	0	4	2
A	hasLock()	0	4	1
A	acquireLock()	0	18	3
A	releaseLock()	0	14	3
A	__destruct()	0	4	1
A	releaseAcquiredLocks()	0	9	2
A	getLockLabel()	0	7	1
	doesLockExist()	0	1	?
	doAcquireLock()	0	1	?
	doReleaseLock()	0	1	?

<?php

namespace Archivr\LockAdapter;

abstract class AbstractLockAdapter implements LockAdapterInterface
{
    /**
     * @var int[]
     */
    protected $lockDepthMap = [];

    public function isLocked(string $name): bool
    {
        return $this->hasLock($name) || $this->doesLockExist($name);
    }

    public function hasLock(string $name): bool
    {
        return isset($this->lockDepthMap[$name]);
    }

    public function acquireLock(string $name): bool
    {
        if (!isset($this->lockDepthMap[$name]))
        {
            $success = $this->doAcquireLock($name);

            if (!$success)
            {
                return false;
            }

            $this->lockDepthMap[$name] = 0;
        }

        $this->lockDepthMap[$name]++;

        return true;
    }

    public function releaseLock(string $name): bool
    {
        if (isset($this->lockDepthMap[$name]))
        {
            if (--$this->lockDepthMap[$name] === 0)
            {
                $this->doReleaseLock($name);

                unset($this->lockDepthMap[$name]);
            }
        }

        return true;
    }

    public function __destruct()
    {
        $this->releaseAcquiredLocks();
    }

    protected function releaseAcquiredLocks()
    {
        foreach (array_keys($this->lockDepthMap) as $lockName)
        {
            $this->doReleaseLock($lockName);
        }

        $this->lockDepthMap = [];
    }

    protected function getLockLabel(): string
    {
        return json_encode([
            'acquired' => time(),
            'user' => get_current_user()
        ]);
    }

    abstract protected function doesLockExist(string $name): bool;
    abstract protected function doAcquireLock(string $name): bool;
    abstract protected function doReleaseLock(string $name);
}