RedisSequenceResolver::sequence() - Code Metrics - godruoyi/php-snowflake - Measure and Improve Code Quality continuously with Scrutinizer

RedisSequenceResolver::sequence() A
last analyzed 2021-05-25 06:04 UTC

↳ Parent: RedisSequenceResolver

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

Metric	Value
dl	0
loc	10
ccs	0
cts	8
cp	0
rs	9.9332
c	0
b	0
f	0
cc	2
nc	2
nop	1
crap	6

<?php

/*
 * This file is part of the godruoyi/php-snowflake.
 *
 * (c) Godruoyi <[email protected]>
 *
 * This source file is subject to the MIT license that is bundled.
 */

namespace Godruoyi\Snowflake;

use Redis;
use RedisException;

class RedisSequenceResolver implements SequenceResolver
{
    /**
     * The redis client instance.
     *
     * @var \Redis
     */
    protected $redis;

    /**
     * The cache prefix.
     *
     * @var string
     */
    protected $prefix;

    /**
     * Init resolve instance, must connectioned.
     */
    public function __construct(Redis $redis)
    {
        if ($redis->ping()) {
            $this->redis = $redis;

            return;
        }

        throw new RedisException('Redis server went away');
    }

    /**
     *  {@inheritdoc}
     */
    public function sequence(int $currentTime)
    {
        $lua = "return redis.call('exists',KEYS[1])<1 and redis.call('psetex',KEYS[1],ARGV[2],ARGV[1])";

        if ($this->redis->eval($lua, [($key = $this->prefix.$currentTime), 1, 1000], 1)) {
            return 0;
        }

        return $this->redis->incrby($key, 1);
    }

    /**
     * Set cacge prefix.
     */
    public function setCachePrefix(string $prefix)
    {
        $this->prefix = $prefix;

        return $this;
    }
}


1			<?php
2
3			/*
4			* This file is part of the godruoyi/php-snowflake.
5			*
6			* (c) Godruoyi <[email protected]>
7			*
8			* This source file is subject to the MIT license that is bundled.
9			*/
10
11			namespace Godruoyi\Snowflake;
12
13			use Redis;
14			use RedisException;
15
16			class RedisSequenceResolver implements SequenceResolver
17			{
18			/**
19			* The redis client instance.
20			*
21			* @var \Redis
22			*/
23			protected $redis;
24
25			/**
26			* The cache prefix.
27			*
28			* @var string
29			*/
30			protected $prefix;
31
32			/**
33			* Init resolve instance, must connectioned.
34			*/
35			public function __construct(Redis $redis)
36			{
37			if ($redis->ping()) {
38			$this->redis = $redis;
39
40			return;
41			}
42
43			throw new RedisException('Redis server went away');
44			}
45
46			/**
47			* {@inheritdoc}
48			*/
49			public function sequence(int $currentTime)
50			{
51			$lua = "return redis.call('exists',KEYS[1])<1 and redis.call('psetex',KEYS[1],ARGV[2],ARGV[1])";
52
53			if ($this->redis->eval($lua, [($key = $this->prefix.$currentTime), 1, 1000], 1)) {
54			return 0;
55			}
56
57			return $this->redis->incrby($key, 1);
58			}
59
60			/**
61			* Set cacge prefix.
62			*/
63			public function setCachePrefix(string $prefix)
64			{
65			$this->prefix = $prefix;
66
67			return $this;
68			}
69			}
70

godruoyi / php-snowflake

RedisSequenceResolver::sequence() A last analyzed 2021-05-25 06:04 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

RedisSequenceResolver::sequence() A
last analyzed 2021-05-25 06:04 UTC