LeoCarmo\CircuitBreaker\Adapters\SwooleTableAdapter

Complexity

Total Complexity

16

Size/Duplication

Total Lines	146
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	reachRateLimit()	0	16	3
A	isHalfOpen()	0	11	2
A	setOpenCircuit()	0	12	1
A	setHalfOpenCircuit()	0	14	1
A	__construct()	0	4	1
A	createTable()	0	7	1
A	checkExtensionLoaded()	0	4	2
A	setSuccess()	0	5	1
A	incrementFailure()	0	13	2
A	isOpen()	0	11	2

<?php declare(strict_types=1);

namespace LeoCarmo\CircuitBreaker\Adapters;

use Swoole\Table;

class SwooleTableAdapter implements AdapterInterface
{
    protected Table $table;

    public function __construct()
    {
        $this->checkExtensionLoaded();
        $this->table = $this->createTable();
    }

    protected function createTable()
    {
        $table = new Table(12);
        $table->column('count', Table::TYPE_INT, 4);
        $table->column('until_date', Table::TYPE_FLOAT);
        $table->create();
        return $table;
    }

    protected function checkExtensionLoaded()
    {
        if (! extension_loaded('swoole')) {
            throw new \RuntimeException('Extension swoole is required to use SwooleTableAdapter.');
        }
    }

    /**
     * @param string $service
     * @param int $timeWindow
     * @return bool
     */
    public function incrementFailure(string $service, int $timeWindow): bool
    {
        $key = "{$service}-failures";

        if ($this->table->exist($key)) {
            return is_integer($this->table->incr($key, 'count'));
        }

        $date = (new \DateTime("+{$timeWindow} seconds"));

        return $this->table->set($key, [
            'count' => 1,
            'until_date' => $date->getTimestamp(),
        ]);
    }

    public function reachRateLimit(string $service, int $failureRateThreshold): bool
    {
        $key = "{$service}-failures";

        if (! $this->table->exist($key)) {
            return false;
        }

        $failures = $this->table->get($key);

Are you sure the assignment to $failures is correct as $this->table->get($key) targeting Swoole\Table::get() seems to always return null.

        if (microtime(true) > $failures['until_date']) {
            $this->table->delete("{$service}-failures");
            return false;
        }

        return ($failures['count'] >= $failureRateThreshold);
    }

    /**
     * @param string $service
     */
    public function setSuccess(string $service): void
    {
        $this->table->delete("{$service}-failures");
        $this->table->delete("{$service}-open");
        $this->table->delete("{$service}-half_open");
    }

    /**
     * @param string $service
     * @return bool
     */
    public function isOpen(string $service): bool
    {
        $key = "{$service}-open";

        if (! $this->table->exists($key)) {
            return false;
        }

        $open = $this->table->get($key, 'until_date');

Are you sure the assignment to $open is correct as $this->table->get($key, 'until_date') targeting Swoole\Table::get() seems to always return null.

        return (microtime(true) < $open);
    }

    /**
     * @param string $service
     * @return bool|string
     */
    public function isHalfOpen(string $service): bool
    {
        $key = "{$service}-half_open";

        if (! $this->table->exists($key)) {
            return false;
        }

        $halfOpen = $this->table->get($key, 'until_date');

Are you sure the assignment to $halfOpen is correct as $this->table->get($key, 'until_date') targeting Swoole\Table::get() seems to always return null.

        return (microtime(true) < $halfOpen);
    }

    /**
     * @param string $service
     * @param int $timeWindow
     */
    public function setOpenCircuit(string $service, int $timeWindow): void
    {
        $date = (new \DateTime("+{$timeWindow} seconds"));

        $this->table->set(
            "{$service}-open",
            [
                'until_date' => $date->getTimestamp(),
            ]
        );

        $this->table->delete("{$service}-failures");
    }

    /**
     * @param string $service
     * @param int $timeWindow
     * @param int $intervalToHalfOpen
     */
    public function setHalfOpenCircuit(string $service, int $timeWindow, int $intervalToHalfOpen): void
    {
        $seconds = ($timeWindow + $intervalToHalfOpen);

        $date = (new \DateTime("+{$seconds} seconds"));

        $this->table->set(
            "{$service}-half_open",
            [
                'until_date' => $date->getTimestamp(),
            ]
        );

        $this->table->delete("{$service}-failures");
    }
}