Tomaj\Hermes\Restart\RedisRestart

Complexity

Total Complexity

9

Size/Duplication

Total Lines	63
Duplicated Lines	12.7 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	3
A	shouldRestart()	0	21	4
A	restart()	8	8	2

<?php
declare(strict_types=1);

namespace Tomaj\Hermes\Restart;

use DateTime;
use InvalidArgumentException;

/**
 * Class RedisRestart provides redis implementation of Tomaj\Hermes\Restart\RestartInterface
 *
 * Set UNIX timestamp (as `string`) to key `$key` (default `hermes_restart`) to restart Hermes.
 */
class RedisRestart implements RestartInterface
{
    /** @var string */
    private $key;

    /** @var \Predis\Client|\Redis */
    private $redis;

    public function __construct($redis, string $key = 'hermes_restart')
    {
        if (!(($redis instanceof \Predis\Client) || ($redis instanceof \Redis))) {

The class Predis\Client does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw new InvalidArgumentException('Predis\Client or Redis instance required');
        }

        $this->key = $key;
        $this->redis = $redis;
    }

    /**
     * {@inheritdoc}
     *
     * Returns true:
     *
     * - if restart timestamp is set,
     * - and timestamp is not in future,
     * - and hermes was started ($startTime) before timestamp
     */
    public function shouldRestart(DateTime $startTime): bool
    {
        // load UNIX timestamp from redis
        $restartTime = $this->redis->get($this->key);
        if ($restartTime === null) {
            return false;
        }
        $restartTime = (int) $restartTime;

        // do not restart if restart time is in future
        if ($restartTime > time()) {
            return false;
        }

        // do not restart if hermes started after restart time
        if ($restartTime < $startTime->getTimestamp()) {
            return false;
        }

        return true;
    }

    /**
     * {@inheritdoc}
     *
     * Sets to Redis value `$restartTime` (or current DateTime) to `$key` defined in constructor.
     */
    public function restart(DateTime $restartTime = null): bool

This method seems to be duplicated in your project.

    {
        if ($restartTime === null) {
            $restartTime = new DateTime();
        }

        return $this->redis->set($this->key, $restartTime->format('U'));
    }
}