Completed
Push — master ( 8c1c6a...f8807b )
by Nikola
17s queued 10s
created

RedisRateLimiter::increment()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
dl 0
loc 4
ccs 0
cts 3
cp 0
rs 10
c 0
b 0
f 0
cc 1
nc 1
nop 1
crap 2
1
<?php
2
/**
3
 * This file is part of the Rate Limit package.
4
 *
5
 * Copyright (c) Nikola Posa
6
 *
7
 * For full copyright and license information, please refer to the LICENSE file,
8
 * located at the package root folder.
9
 */
10
11
declare(strict_types=1);
12
13
namespace RateLimit;
14
15
use Redis;
16
17
/**
18
 * @author Nikola Posa <[email protected]>
19
 */
20
final class RedisRateLimiter extends AbstractRateLimiter
21
{
22
    /**
23
     * @var Redis
24
     */
25
    private $redis;
26
27 9
    public function __construct(Redis $redis, int $limit, int $window)
28
    {
29 9
        $this->redis = $redis;
30
31 9
        parent::__construct($limit, $window);
32 9
    }
33
34 4
    protected function get(string $key, int $default) : int
35
    {
36 4
        $value = $this->redis->get($key);
37
38 4
        if (false === $value) {
39 4
            return $default;
40
        }
41
42 3
        return (int) $value;
43
    }
44
45 4
    protected function init(string $key)
46
    {
47 4
        $this->redis->setex($key, $this->window, 1);
48 4
    }
49
50
    protected function increment(string $key)
51
    {
52
        $this->redis->incr($key);
53
    }
54
55 2
    protected function ttl(string $key) : int
56
    {
57 2
        $ttl = $this->redis->pttl($key);
58 2
        if ($ttl === -1) {
59
            $this->redis->expire($key, $this->window);
60
            $ttl = $this->window*1000;
61
        }
62
63 2
        return max((int) ceil($ttl / 1000), 0);
64
    }
65
}
66