TonicHealthCheck\Check\Redis\WriteReadDelete\RedisWriteReadDeleteCheck

Complexity

Total Complexity

8

Size/Duplication

Total Lines	74
Duplicated Lines	8.11 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	performCheck()	6	31	5
A	getClient()	0	4	1
A	setClient()	0	4	1

<?php

namespace TonicHealthCheck\Check\Redis\WriteReadDelete;

use Predis\Client as PredisClient;
use Predis\PredisException;
use TonicHealthCheck\Check\Redis\AbstractRedisCheck;
use TonicHealthCheck\Check\Redis\WriteReadDelete\Exception\RedisDeleteCheckException;
use TonicHealthCheck\Check\Redis\WriteReadDelete\Exception\RedisWRDCheckException;
use TonicHealthCheck\Check\Redis\WriteReadDelete\Exception\RedisWriteReadCheckException;

/**
 * Class RedisWriteReadDeleteCheck.
 */
class RedisWriteReadDeleteCheck extends AbstractRedisCheck
{
    const CHECK = 'redis-write-read-delete-check';

    /**
     * @var PredisClient
     */
    protected $client;

    /**
     * @param string       $checkNode
     * @param PredisClient $client
     */
    public function __construct($checkNode, PredisClient $client)
    {
        parent::__construct($checkNode);
        $this->setClient($client);
    }

    /**
     * Test redis write&read&delete.
     *
     * @throws RedisDeleteCheckException
     * @throws RedisWRDCheckException
     * @throws RedisWriteReadCheckException
     */
    public function performCheck()
    {
        try {
            $value1 = 'testData_123456';
            $value2 = 'Other_98765';
            $valueKey = 'test_health_check_val';

            $valueOld = $this->getClient()->get($valueKey);
            $this->getClient()->set($valueKey, $value1);

            if ($this->getClient()->get($valueKey) != $value1) {

This code seems to be duplicated across your project.

                throw RedisWriteReadCheckException::doesNotSave($valueOld, $value1, $this->getClient()->get($valueKey));
            }

            $valueOld = $this->getClient()->get($valueKey);
            $this->getClient()->set($valueKey, $value2);

            if ($this->getClient()->get($valueKey) != $value2) {

This code seems to be duplicated across your project.

                throw RedisWriteReadCheckException::doesNotSave($valueOld, $value2, $this->getClient()->get($valueKey));
            }

            $valueOld = $this->getClient()->get($valueKey);
            $this->getClient()->del($valueKey);

            if ($this->getClient()->exists($valueKey)) {
                throw RedisDeleteCheckException::doesNotDelete($valueOld, $this->getClient()->get($valueKey));
            }
        } catch (PredisException $e) {
            throw RedisWRDCheckException::internalProblem($e);
        }
    }

    /**
     * @return PredisClient
     */
    public function getClient()
    {
        return $this->client;
    }

    /**
     * @param PredisClient $client
     */
    protected function setClient(PredisClient $client)
    {
        $this->client = $client;
    }
}