Tomaj\Hermes\Shutdown\PredisShutdown

Complexity

Total Complexity

7

Size/Duplication

Total Lines	62
Duplicated Lines	51.61 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	shouldShutdown()	21	21	4
A	shutdown()	11	11	2

<?php
declare(strict_types=1);

namespace Tomaj\Hermes\Shutdown;

use DateTime;
use Predis\Client;

/**
 * Class PredisShutdown provides predis implementation of Tomaj\Hermes\Shutdown\ShutdownInterface
 *
 * Set UNIX timestamp (as `string`) to key `$key` (default `hermes_shutdown`) to shutdown Hermes worker.
 */
class PredisShutdown implements ShutdownInterface
{
    /** @var string */
    private $key;

    /** @var Client */
    private $redis;

    public function __construct(Client $redis, string $key = 'hermes_shutdown')
    {
        $this->redis = $redis;
        $this->key = $key;
    }

    /**
     * {@inheritdoc}
     *
     * Returns true:
     *
     * - if shutdown timestamp is set,
     * - and timestamp is not in future,
     * - and hermes was started ($startTime) before timestamp
     */
    public function shouldShutdown(DateTime $startTime): bool

This method seems to be duplicated in your project.

    {
        // load UNIX timestamp from redis
        $shutdownTime = $this->redis->get($this->key);
        if ($shutdownTime === null) {
            return false;
        }
        $shutdownTime = (int) $shutdownTime;

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

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

        return true;
    }

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

This method seems to be duplicated in your project.

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

        /** @var \Predis\Response\Status $response */
        $response = $this->redis->set($this->key, $shutdownTime->format('U'));

        return $response->getPayload() === 'OK';
    }
}