RedisPubSubHandler::exists() - Code Metrics - ynloultratech/graphql-bundle - Measure and Improve Code Quality continuously with Scrutinizer

RedisPubSubHandler::exists() A
last analyzed 2020-12-22 19:23 UTC

↳ Parent: RedisPubSubHandler

Complexity

Conditions	3
Paths	3

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
eloc	6
c	2
b	0
f	0
dl	0
loc	11
ccs	0
cts	10
cp	0
rs	10
cc	3
nc	3
nop	1
crap	12

<?php
/*******************************************************************************
 *  This file is part of the GraphQL Bundle package.
 *
 *  (c) YnloUltratech <[email protected]>
 *
 *  For the full copyright and license information, please view the LICENSE
 *  file that was distributed with this source code.
 ******************************************************************************/

namespace Ynlo\GraphQLBundle\Subscription\PubSub;

class RedisPubSubHandler implements PubSubHandlerInterface
{
    /**
     * @var string
     */
    protected $redisHost;

    /**
     * @var string
     */
    protected $redisPort;

    /**
     * @var \Redis
     */
    protected $client;

    /**
     * @var \Redis
     */
    protected $consumer;

    /**
     * @var string
     */
    protected $prefix;

    /**
     * RedisPubSubHandler constructor.
     *
     * @param array $config
     */
    public function __construct(array $config)
    {
        $this->redisHost = $config['host'] ?? 'localhost';
        $this->redisPort = $config['port'] ?? 6379;
        $this->prefix = $config['prefix'] ?? 'GraphQLSubscription:';

        $this->client = new \Redis();
        $this->client->connect($this->redisHost, $this->redisPort);
        $this->client->setOption(\Redis::OPT_PREFIX, $this->prefix);
    }

    /**
     * @inheritDoc
     */
    public function sub(string $channel, string $id, array $meta, \DateTime $expireAt = null): void
    {
        $key = sprintf('%s:%s', $channel, $id);
        $alreadyExists = $this->exists($id);
        $this->client->set($key, serialize($meta));

        if (!$expireAt) {
            $expireAt = new \DateTime('+24Hours');
        }
        if (!$alreadyExists && $expireAt) {
            $this->client->expireAt($key, $expireAt->format('U'));
            $this->client->expireAt($key, /** @scrutinizer ignore-type */ $expireAt->format('U'));
        }

        $iterator = null;

    }

    /**
     * @inheritDoc
     */
    public function pub(string $channel, array $filters = [], array $data = []): void
    {
        $this->client->publish($channel, serialize([$filters, $data]));
    }

    /**
     * @inheritDoc
     */
    public function touch(string $id): void
    {
        $iterator = null;
        while ($iterator !== 0) {
            while ($keys = $this->client->scan($iterator, "*:$id*")) {
                foreach ($keys as $key) {
                    $this->client->expireAt($this->unprefix($key), (new \DateTime('+24Hours'))->format('U'));
                    $this->client->expireAt($this->unprefix($key), /** @scrutinizer ignore-type */ (new \DateTime('+24Hours'))->format('U'));
                }
            }
        }
    }

    /**
     * @inheritDoc
     */
    public function del(string $id): void
    {
        $iterator = null;

        foreach ($this->client->keys("*:$id") as $key) {
            $this->client->del($this->unprefix($key));
        }
    }

    /**
     * @inheritDoc
     */
    public function clear(): void
    {
        $iterator = null;

        foreach ($this->client->keys('*') as $key) {
            $this->client->del($this->unprefix($key));
        }
    }

    /**
     * @inheritDoc
     */
    public function exists(string $id): bool
    {
        $iterator = null;
        while ($iterator !== 0) {
            $keys = $this->client->scan($iterator, "*:$id*");
            if (!empty($keys)) {
                return true;
            }
        }

        return false;
    }

    /**
     * @inheritDoc
     */
    public function consume(array $channels, callable $dispatch): void
    {
        $this->consumer = new \Redis();
        // the timeout is specified to avoid redis connection error after some time running the consumer
        // the `default_socket_timeout` to -1 like described here https://github.com/phpredis/phpredis/issues/70
        // can't be used because create a conflict with others sock open functions like used in Ynlo\GraphQLBundle\Subscription\SubscriptionManager::sendRequest
        $this->consumer->connect($this->redisHost, $this->redisPort, 0, null, 0, 100000);
        $this->consumer->connect($this->redisHost, /** @scrutinizer ignore-type */ $this->redisPort, 0, null, 0, 100000);
        $this->consumer->setOption(\Redis::OPT_READ_TIMEOUT, 1000000);
        $this->consumer->setOption(\Redis::OPT_PREFIX, $this->prefix);
        $this->consumer->subscribe(
            $channels,
            function (\Redis $redis, $chan, $event) use ($dispatch) {
            /** @scrutinizer ignore-type */ function (\Redis $redis, $chan, $event) use ($dispatch) {
                $iterator = null;
                while ($iterator !== 0) {
                    while ($keys = $this->client->scan($iterator, "*$chan:*", 100)) {
                        [$filters, $data] = unserialize($event, [true]);
                        foreach ($keys as $key) {
                            $key = $this->unprefix($key);
                            $chan = $this->unprefix($chan);
                            $meta = $this->client->get($key);
                            preg_match("/$chan:(.+)/", $key, $matches);
                            if ($matches) {
                                $metaArray = unserialize($meta, [true]);
                                $message = new SubscriptionMessage(
                                    $chan,
                                    $matches[1],
                                    $data,
                                    $filters,
                                    is_array($metaArray) ? $metaArray : []
                                );

                                $dispatch($message);
                            }
                        }
                    }
                }
            }
        );
    }

    /**
     * Helper to remove prefix
     *
     * @param string $key
     *
     * @return string
     */
    private function unprefix($key): string
    {
        return str_replace($this->prefix, null, $key);
    }
}


ynloultratech / graphql-bundle

RedisPubSubHandler::exists() A last analyzed 2020-12-22 19:23 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

RedisPubSubHandler::exists() A
last analyzed 2020-12-22 19:23 UTC