Yiisoft\Yii\RateLimiter\Storage\ApcuStorage

Complexity

Total Complexity

7

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	3
A	saveIfNotExists()	0	4	1
A	saveCompareAndSwap()	0	5	1
A	get()	0	8	2

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\RateLimiter\Storage;

use Yiisoft\Yii\RateLimiter\Exception\CannotUseException;

final class ApcuStorage implements StorageInterface
{
    private const DEFAULT_FIX_PRECISION_RATE = 1000000;

    /**
     * @param int $fixPrecisionRate 
     * floating point is not supported by apcu_cas of ACPu, so use it to improves precision.
     */
    public function __construct(
        private int $fixPrecisionRate = self::DEFAULT_FIX_PRECISION_RATE
    ) {
        if (!extension_loaded('apcu') || ini_get('apc.enabled') === '0') {
            throw new CannotUseException('APCu extension is not loaded or not enabled.');
        }
    }

    public function saveIfNotExists(string $key, mixed $value, int $ttl): bool
    {
        $value = (int) ($value * $this->fixPrecisionRate);
        return (bool)apcu_add($key, $value, $ttl);
    }

    public function saveCompareAndSwap(string $key, mixed $oldValue, mixed $newValue, int $ttl): bool
    {
        $oldValue = (int) ($oldValue * $this->fixPrecisionRate);
        $newValue = (int) ($newValue * $this->fixPrecisionRate);
        return  (bool)apcu_cas($key, $oldValue, $newValue);
    }

    public function get(string $key): mixed
    {
        $value = apcu_fetch($key);
        
        if ($value != false) {
            $value = floatval($value / $this->fixPrecisionRate);
        }
        return $value;
    }
}