BenTools\MercurePHP\Metrics\Redis\RedisMetricsHandler

Complexity

Total Complexity

6

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	incrementUsers()	0	4	1
A	decrementUsers()	0	4	1
A	resetUsers()	0	4	1
A	__construct()	0	3	1
A	getNbUsers()	0	12	2

<?php

namespace BenTools\MercurePHP\Metrics\Redis;

use BenTools\MercurePHP\Metrics\MetricsHandlerInterface;
use Clue\React\Redis\Client as AsynchronousClient;
use React\Promise\PromiseInterface;

use function React\Promise\all;

final class RedisMetricsHandler implements MetricsHandlerInterface
{
    /**
     * @var AsynchronousClient
     */
    private AsynchronousClient $client;

    public function __construct(AsynchronousClient $client)
    {
        $this->client = $client;
    }

    public function resetUsers(string $localAddress): PromiseInterface
    {
        /** @phpstan-ignore-next-line */
        return $this->client->set('users:' . $localAddress, 0);
    }

    public function incrementUsers(string $localAddress): PromiseInterface
    {
        /** @phpstan-ignore-next-line */
        return $this->client->incr('users:' . $localAddress);
    }

    public function decrementUsers(string $localAddress): PromiseInterface
    {
        /** @phpstan-ignore-next-line */
        return $this->client->decr('users:' . $localAddress);
    }

    public function getNbUsers(): PromiseInterface
    {
        /** @phpstan-ignore-next-line */
        return $this->client->keys('users:*')
            ->then(
                function (array $keys) {
                    $promises = [];
                    foreach ($keys as $key) {
                        $promises[] = $this->client->get($key); /** @phpstan-ignore-line */
                    }

                    return all($promises)->then(fn (array $results): int => \array_sum($results));
                }
            );
    }
}