RedisAdapterTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testSetAdapter()	0	10	1
A	testHalfOpenFailAndOpenCircuit()	0	25	1
A	testOpenCircuit()	0	17	1
A	testCloseCircuitSuccess()	0	5	1

<?php

use LeoCarmo\CircuitBreaker\CircuitBreaker;
use LeoCarmo\CircuitBreaker\Adapters\RedisAdapter;

class RedisAdapterTest extends \PHPUnit\Framework\TestCase
{

    public function testSetAdapter()
    {
        $redis = new \Redis();
        $redis->connect('0.0.0.0', 6379);

        $redis = new RedisAdapter($redis, 'my-product');

        CircuitBreaker::setAdapter($redis);

        $this->assertInstanceOf(RedisAdapter::class, CircuitBreaker::getAdapter());
    }

    public function testOpenCircuit()
    {
        $service = 'my-service';

        CircuitBreaker::setServiceSettings($service, [
            'timeWindow' => 20,
            'failureRateThreshold' => 5,
            'intervalToHalfOpen' => 10,
        ]);

        CircuitBreaker::failure($service);
        CircuitBreaker::failure($service);
        CircuitBreaker::failure($service);
        CircuitBreaker::failure($service);
        CircuitBreaker::failure($service);

        $this->assertFalse(CircuitBreaker::isAvailable($service));
    }

    public function testCloseCircuitSuccess()
    {
        CircuitBreaker::success('my-service');

        $this->assertTrue(CircuitBreaker::isAvailable('my-service'));
    }

    public function testHalfOpenFailAndOpenCircuit()
    {
        $service = 'my-service-2';

        CircuitBreaker::setServiceSettings($service, [
            'timeWindow' => 1,
            'failureRateThreshold' => 3,
            'intervalToHalfOpen' => 15,
        ]);

        CircuitBreaker::failure($service);
        CircuitBreaker::failure($service);
        CircuitBreaker::failure($service);

        // Check if is available for open circuit
        $this->assertFalse(CircuitBreaker::isAvailable($service));

        // Sleep for half open
        sleep(2);

        // Register new failure
        CircuitBreaker::failure($service);

        // Check if is open
        $this->assertFalse(CircuitBreaker::isAvailable($service));
    }
}