LibraryCatalog\Service\Repository\RedisTrait

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Test Coverage

Coverage

75%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	unlock()	0	3	1
A	lock()	0	6	2
A	transaction()	0	13	2

<?php

declare(strict_types=1);

namespace LibraryCatalog\Service\Repository;

use Predis\Client;

trait RedisTrait
{
    /**
     * @param Client $predis
     * @param string $key
     * @param int $ttl
     */
    public function lock(Client $predis, string $key, int $ttl): void
    {
        while ($predis->get($key)) {
            usleep(50000);
        }
        $predis->setex($key, $ttl, true);
    }

    /**
     * @param Client $predis
     * @param string $key
     */
    public function unlock(Client $predis, string $key): void
    {
        $predis->del($key);
    }

    /**
     * @param Client $predis
     * @param string $key
     * @param int $ttl
     * @param \Closure $closure
     * @throws \Throwable
     * @return mixed
     */
    public function transaction(Client $predis, string $key, int $ttl, \Closure $closure)
    {
        $this->lock($predis, $key, $ttl);
        try {
            $res = $closure();
        } catch (\Exception | \Throwable $e) {
            $this->unlock($predis, $key);
            throw $e;
        }
        // Unlock in correct flow.
        $this->unlock($predis, $key);

        return $res;
    }
}