TH\RedisLock\RedisSimpleLock

Complexity

Total Complexity

8

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

<?php
class RedisSimpleLock implements Lock
{
    private $identifier;
    private $client;
    private $ttl;
    private $logger;
    private $id;

    /**
     * Create new RedisSimpleLock
     *
     * @param string               $identifier the redis lock key
     * @param Client               $client     the Predis client
     * @param integer              $ttl        lock time-to-live in milliseconds
     * @param LoggerInterface|null $logger
     */
    public function __construct($identifier, Client $client, $ttl = 10000, LoggerInterface $logger = null)
    {
        $this->identifier = $identifier;
        $this->client     = $client;
        $this->ttl        = $ttl;
        $this->logger     = $logger ?: new NullLogger;
        $this->id         = mt_rand();
        register_shutdown_function($this->releaseClosure());
    }

    public function acquire()
    {
        $log_data = ["identifier" => $this->identifier];
        $response = $this->client->set($this->identifier, $this->id, "PX", $this->ttl, "NX");
        if (!$response instanceof Status || $response->getPayload() !== "OK") {
            $this->logger->debug("could not acquire lock on {identifier}", $log_data);

            throw new Exception("Could not acquire lock on " . $this->identifier);
        }
        $this->logger->debug("lock acquired on {identifier}", $log_data);
    }

    public function release()
    {
        $closure = $this->releaseClosure();
        $closure();
    }

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

    private function releaseClosure()
    {
        $client = $this->client;
        $id = $this->id;
        $identifier = $this->$identifier;
        $logger = $this->logger;