voku\cache\AdapterMemcached

Complexity

Total Complexity

16

Size/Duplication

Total Lines	121
Duplicated Lines	7.44 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

79.49%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	setMemcached()	0	7	1
A	exists()	0	4	1
A	get()	0	4	1
A	installed()	0	4	1
A	remove()	0	4	1
A	removeAll()	0	4	1
A	set()	9	9	2
A	setExpired()	0	8	2
A	setSettings()	0	15	4

<?php

declare(strict_types=1);

namespace voku\cache;

use Memcached;
use voku\cache\Exception\InvalidArgumentException;

/**
 * AdapterMemcached: Memcached-adapter
 */
class AdapterMemcached implements iAdapter
{
    /**
     * @var bool
     */
    public $installed = false;

    /**
     * @var Memcached
     */
    private $memcached;

    /**
     * __construct
     *
     * @param Memcached|null $memcached
     */
    public function __construct($memcached = null)
    {
        if ($memcached instanceof Memcached) {
            $this->setMemcached($memcached);
        }
    }

    /**
     * @param Memcached $memcached
     */
    public function setMemcached(Memcached $memcached)
    {
        $this->memcached = $memcached;
        $this->installed = true;

        $this->setSettings();
    }

    /**
     * {@inheritdoc}
     */
    public function exists(string $key): bool
    {
        return $this->get($key) !== false;
    }

    /**
     * {@inheritdoc}
     */
    public function get(string $key)
    {
        return $this->memcached->get($key);
    }

    /**
     * {@inheritdoc}
     */
    public function installed(): bool
    {
        return $this->installed;
    }

    /**
     * {@inheritdoc}
     */
    public function remove(string $key): bool
    {
        return $this->memcached->delete($key);
    }

    /**
     * {@inheritdoc}
     */
    public function removeAll(): bool
    {
        return $this->memcached->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function set(string $key, $value): bool

This method seems to be duplicated in your project.

    {
        // Make sure we are under the proper limit
        if (\strlen($this->memcached->getOption(Memcached::OPT_PREFIX_KEY) . $key) > 250) {
            throw new InvalidArgumentException('The passed cache key is over 250 bytes:' . \print_r($key, true));
        }

        return $this->memcached->set($key, $value);
    }

    /**
     * {@inheritdoc}
     */
    public function setExpired(string $key, $value, int $ttl = 0): bool
    {
        if ($ttl > 2592000) {
            $ttl = 2592000;
        }

        return $this->memcached->set($key, $value, $ttl);
    }

    /**
     * Set the MemCached settings.
     *
     * @noinspection PhpUndefinedClassConstantInspection -> MSGPACK is not added into phpstorm stubs
     */
    private function setSettings()
    {
        // Use faster compression if available
        if (Memcached::HAVE_IGBINARY) {
            $this->memcached->setOption(Memcached::OPT_SERIALIZER, Memcached::SERIALIZER_IGBINARY);
        } elseif (defined('Memcached::HAVE_MSGPACK') && Memcached::HAVE_MSGPACK) {
            $this->memcached->setOption(Memcached::OPT_SERIALIZER, Memcached::SERIALIZER_MSGPACK);
        }
        $this->memcached->setOption(Memcached::OPT_DISTRIBUTION, Memcached::DISTRIBUTION_CONSISTENT);
        $this->memcached->setOption(Memcached::OPT_LIBKETAMA_COMPATIBLE, true);
        $this->memcached->setOption(Memcached::OPT_NO_BLOCK, true);
        $this->memcached->setOption(Memcached::OPT_TCP_NODELAY, true);
        $this->memcached->setOption(Memcached::OPT_COMPRESSION, false);
        $this->memcached->setOption(Memcached::OPT_CONNECT_TIMEOUT, 2);
    }
}