RedisAdapterTest

Complexity

Total Complexity

3

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	testIncrementFailure()	0	29	1
A	testIncrementFailureWithKeyWithoutTtl()	0	30	1
A	testIncrementFailureWithKeyWithoutTtlIntegratedRedis()	0	22	1

<?php declare(strict_types=1);

use LeoCarmo\CircuitBreaker\Adapters\RedisAdapter;
use PHPUnit\Framework\TestCase;

class RedisAdapterTest extends TestCase
{
    public function testIncrementFailure()
    {
        $redis = $this->createMock(\Redis::class);

        $adapter = new RedisAdapter($redis, 'test-failure');

        $redis->expects($this->once())
            ->method('ttl');

        $redis->expects($this->never())
            ->method('del');

        $redis->expects($this->once())
            ->method('get')
            ->willReturn(false);

        $redis->expects($this->once())
            ->method('multi');

        $redis->expects($this->once())
            ->method('incr');

        $redis->expects($this->once())
            ->method('expire');

        $redis->expects($this->once())
            ->method('exec');

        $adapter->incrementFailure('test-service', 30);
    }

    public function testIncrementFailureWithKeyWithoutTtl()
    {
        $redis = $this->createMock(\Redis::class);

        $adapter = new RedisAdapter($redis, 'test-failure');

        $redis->expects($this->once())
            ->method('ttl')
            ->willReturn(-1);

        $redis->expects($this->once())
            ->method('del');

        $redis->expects($this->once())
            ->method('get')
            ->willReturn(false);

        $redis->expects($this->once())
            ->method('multi');

        $redis->expects($this->once())
            ->method('incr');

        $redis->expects($this->once())
            ->method('expire');

        $redis->expects($this->once())
            ->method('exec');

        $adapter->incrementFailure('test-service', 30);
    }

    public function testIncrementFailureWithKeyWithoutTtlIntegratedRedis()
    {
        $redis = new \Redis();
        $redis->connect(getenv('REDIS_HOST'));

        $dummy_key = 'circuit-breaker:test-failure:test-service:failures';

        // set dummy key without expire
        $redis->set($dummy_key, 1);
        $ttl = $redis->ttl($dummy_key);

        $this->assertEquals(-1, $ttl, 'Dummy key without ttl');

        $adapter = new RedisAdapter($redis, 'test-failure');

        // here, we expect that the dummy key will be removed and a new with ttl will be set
        $adapter->incrementFailure('test-service', 30);

        $ttl = $redis->ttl($dummy_key);

        $this->assertNotEquals(-1, $ttl, 'Dummy key with ttl');
        $this->assertGreaterThan(1, $ttl, 'Dummy key more than 1s ttl');
    }
}