kalanis\kw_semaphore\Semaphore\Storage

Complexity

Total Complexity

7

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	has()	0	6	2
A	__construct()	0	4	1
A	want()	0	6	2
A	remove()	0	6	2

<?php

namespace kalanis\kw_semaphore\Semaphore;


use kalanis\kw_paths\Stuff;
use kalanis\kw_semaphore\Interfaces\ISemaphore;
use kalanis\kw_semaphore\SemaphoreException;
use kalanis\kw_storage\Interfaces\IStorage;
use kalanis\kw_storage\StorageException;


/**
 * Class Storage
 * @package kalanis\kw_semaphore\Semaphore
 * Data source for semaphore is storage
 */
class Storage implements ISemaphore
{
    protected string $rootPath = '';
    protected IStorage $storage;

    public function __construct(IStorage $storage, string $rootPath)
    {
        $this->rootPath = Stuff::removeEndingSlash($rootPath) . static::EXT_SEMAPHORE;
        $this->storage = $storage;
    }

    public function want(): bool
    {
        try {
            return $this->storage->write($this->rootPath, static::TEXT_SEMAPHORE);
        } catch (StorageException $ex) {
            throw new SemaphoreException($ex->getMessage(), $ex->getCode(), $ex);
        }
    }

    public function has(): bool
    {
        try {
            return $this->storage->exists($this->rootPath);
        } catch (StorageException $ex) {
            throw new SemaphoreException($ex->getMessage(), $ex->getCode(), $ex);
        }
    }

    public function remove(): bool
    {
        try {
            return $this->storage->remove($this->rootPath);
        } catch (StorageException $ex) {
            throw new SemaphoreException($ex->getMessage(), $ex->getCode(), $ex);
        }
    }
}