FastCache::doSave() - Code Metrics - Inspection of "Made major changes and fix to classes" - biurad/php-cache - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b2545f...e44389 )

by Divine Niiquaye

created 2020-07-16 13:41 UTC

FastCache::doSave() B

↳ Parent: FastCache

Complexity

Conditions	8
Paths	8

Size

Total Lines	33
Code Lines	19

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	8
eloc	19
c	0
b	0
f	0
nc	8
nop	5
dl	0
loc	33
rs	8.4444

<?php

declare(strict_types=1);

/*
 * This file is part of BiuradPHP opensource projects.
 *
 * PHP version 7.1 and above required
 *
 * @author    Divine Niiquaye Ibok <[email protected]>
 * @copyright 2019 Biurad Group (https://biurad.com/)
 * @license   https://opensource.org/licenses/BSD-3-Clause License
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Biurad\Cache;

use Biurad\Cache\Exceptions\CacheException;
use Biurad\Cache\Exceptions\InvalidArgumentException;
use Biurad\Cache\Interfaces\FastCacheInterface;
use Cache\Adapter\Common\CacheItem as PhpCacheItem;
use Cache\Adapter\Common\PhpCachePool;
use Closure;
use Generator;
use Psr\Cache\CacheItemInterface;
use Psr\Cache\CacheItemPoolInterface;
use Psr\SimpleCache\CacheInterface;
use stdClass;
use Throwable;

/**
 * Implements the cache for a application.
 */
class FastCache implements FastCacheInterface
{
    /** @internal */
    public const NAMESPACE_SEPARATOR = "\x00";

    public const NAMESPACE = 'CACHE_KEY[%s]';

    /** @var CacheInterface|CacheItemPoolInterface */
    private $storage;

    /** @var string */
    private $namespace;

    /** @var array<string,mixed> */
    private $computing = [];

    /**
     * @param CacheInterface|CacheItemPoolInterface $storage
     * @param string                                $namespace
     */
    final public function __construct($storage, string $namespace = self::NAMESPACE)
    {
        if (
            !($storage instanceof CacheInterface || $storage instanceof CacheItemPoolInterface)

        ) {
            throw new CacheException('$storage can only implements psr-6 or psr-16 cache interface');
        }

        $this->storage   = $storage;
        $this->namespace = $namespace . self::NAMESPACE_SEPARATOR;
    }

    /**
     * {@inheritdoc}
     */
    public function getStorage()
    {
        return $this->storage;
    }

    /**
     * Returns cache namespace.
     */
    public function getNamespace(): string
    {
        return \substr(\sprintf($this->namespace, ''), 0, -1);
    }

    /**
     * {@inheritdoc}
     */
    public function derive(string $namespace): FastCache
    {
        return new static($this->storage, $this->namespace . $namespace);
    }

    /**
     * {@inheritdoc}
     */
    public function load($key, callable $fallback = null, ?float $beta = null)
    {
        $data = $this->doFetch($this->generateKey($key));

        if ($data instanceof CacheItemInterface) {
            $data = $data->isHit() ? $data->get() : null;
        }

        if (null === $data && null !== $fallback) {
            return $this->save($key, $fallback, $beta);
        }

        return $data;
    }

    /**
     * {@inheritDoc}
     */
    public function bulkLoad(array $keys, callable $fallback = null, ?float $beta = null): array
    {
        if (0 === \count($keys)) {
            return [];
        }

        foreach ($keys as $key) {
            if (!\is_scalar($key)) {
                throw new InvalidArgumentException('Only scalar keys are allowed in bulkLoad()');
            }
        }
        $storageKeys = \array_map([$this, 'generateKey'], $keys);
        $cacheData   = $this->doFetch($storageKeys);
        $result      = [];

        if ($cacheData instanceof Generator) {
            $cacheData = \iterator_to_array($cacheData);
        }

        foreach ($keys as $i => $key) {
            $storageKey = $storageKeys[$i];

            if (isset($cacheData[$storageKey])) {
                $result[$key] = $cacheData[$storageKey];
            } elseif (null !== $fallback) {
                $result[$key] = $this->save(
                    $key,
                    function (CacheItemInterface $item, bool $save) use ($key, $fallback) {
                        return $fallback(...[$key, &$item, &$save]);
                    },
                    $beta
                );
            } else {
                $result[$key] = null;
            }
        }

        return \array_map(
            function ($value) {
                if ($value instanceof CacheItemInterface) {
                    return $value->get();
                }

                return $value;
            },
            $result
        );
    }

    /**
     * {@inheritdoc}
     *
     * @psalm-suppress InaccessibleProperty
     */
    public function save($key, ?callable $callback = null, ?float $beta = null)
    {
        $key = $this->generateKey($key);

        if (null === $callback) {
            $this->doDelete($key);

            return false;
        }

        if (0 > $beta = $beta ?? 1.0) {
            throw new InvalidArgumentException(
                \sprintf(
                    'Argument "$beta" provided to "%s::get()" must be a positive number, %f given.',
                    static::class,
                    $beta
                )
            );
        }

        static $setExpired;

        $setExpired = Closure::bind(
            static function (CacheItem $item) {
                if (null === $item->expiry) {

                    return null;
                }

                return (int) (0.1 + $item->expiry - \microtime(true));
            },
            null,
            CacheItem::class
        );

        if ($this->storage instanceof PhpCachePool) {
            $setExpired = static function (PhpCacheItem $item) {
                return $item->getExpirationTimestamp();
            };
        }

        $callback = function (CacheItemInterface $item, bool $save) use ($key, $callback) {
            // don't wrap nor save recursive calls
            if (isset($this->computing[$key])) {
                $value = $callback(...[&$item, &$save]);
                $save  = false;


                return $value;
            }

            $this->computing[$key] = $key;

            try {
                return $value = $callback(...[&$item, &$save]);

            } catch (Throwable $e) {
                $this->doDelete($key);

                throw $e;
            } finally {
                unset($this->computing[$key]);
            }
        };

        return $this->doSave($this->storage, $key, $callback, $setExpired, $beta);
    }

    /**
     * {@inheritdoc}
     */
    public function delete($key): void
    {
        $this->save($key, null);
    }

    /**
     * {@inheritdoc}
     */
    public function call(callable $callback, ?float $beta = null)
    {
        $key = \func_get_args();

        if (\is_array($callback) && \is_object($callback[0])) {
            $key[0][0] = \get_class($callback[0]);
        }

        return $this->load(
            $key,
            function (CacheItemInterface $item, bool $save) use ($callback, $key) {
                $dependencies = \array_merge(\array_slice($key, 1), [&$item, &$save]);

                return $callback(...$dependencies);
            },
            $beta
        );
    }

    /**
     * {@inheritdoc}
     */
    public function wrap(callable $callback, ?float $beta = null): callable
    {
        return function () use ($callback, $beta) {
            return $this->call($callback, $beta);
        };
    }

    /**
     * {@inheritdoc}
     */
    public function start($key): ?OutputHelper
    {
        $data = $this->load($key);

        if (null === $data) {
            return new OutputHelper($this, $key);
        }
        echo $data;

        return null;
    }

    /**
     * Generates internal cache key.
     *
     * @param mixed $key
     *
     * @return string
     */
    protected function generateKey($key): string
    {
        if (\is_array($key) && \current($key) instanceof Closure) {
            $key = \spl_object_id($key[0]);
        }

        $key = \md5(\is_scalar($key) ? (string) $key : \serialize($key));

        return \strpos($this->namespace, '%s') ? \sprintf($this->namespace, $key) : $this->namespace . $key;
    }

    /**
     * Save cache item.
     *
     * @param CacheInterface|CacheItemPoolInterface $storage
     * @param string                                $key
     * @param Closure                               $callback
     * @param Closure                               $setExpired
     * @param null|float                            $beta
     *
     * @return mixed The corresponding values found in the cache
     */
    protected function doSave($storage, string $key, Closure $callback, Closure $setExpired, ?float $beta)
    {
        if ($storage instanceof CacheItemPoolInterface) {
            $item = $storage->getItem($key);

            if (!$item->isHit() || \INF === $beta) {
                $save   = true;
                $result = $callback(...[$item, $save]);

                if (false !== $save) {

                    if (!$result instanceof CacheItemInterface) {
                        $item->set($result);
                        $storage->save($item);
                    } else {
                        $storage->save($result);
                    }
                }
            }

            return $item->get();
        }

        $save   = true;
        $item   = $storage instanceof PhpCachePool ? new PhpCacheItem($key) : new CacheItem();
        $result = $callback(...[$item, $save]);

        if ($result instanceof CacheItemInterface) {
            $result = $result->get();
        }

        $storage->set($key, $result, $setExpired($item));

        return $result;
    }

    /**
     * Fetch cache item.
     *
     * @param string|string[] $ids The cache identifier to fetch
     *
     * @return mixed The corresponding values found in the cache
     */
    protected function doFetch($ids)
    {
        if ($this->storage instanceof CacheItemPoolInterface) {
            return !\is_array($ids) ? $this->storage->getItem($ids) : $this->storage->getItems($ids);
        }

        return !\is_array($ids) ? $this->storage->get($ids) : $this->storage->getMultiple($ids, new stdClass());
    }

    /**
     * Remove an item from cache.
     *
     * @param string $id An identifier that should be removed from cache
     *
     * @return bool True if the items were successfully removed, false otherwise
     */
    protected function doDelete(string $id)
    {
        if ($this->storage instanceof CacheItemPoolInterface) {
            return $this->storage->deleteItem($id);
        }

        return $this->storage->delete($id);
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			/*
6			* This file is part of BiuradPHP opensource projects.
7			*
8			* PHP version 7.1 and above required
9			*
10			* @author Divine Niiquaye Ibok <[email protected]>
11			* @copyright 2019 Biurad Group (https://biurad.com/)
12			* @license https://opensource.org/licenses/BSD-3-Clause License
13			*
14			* For the full copyright and license information, please view the LICENSE
15			* file that was distributed with this source code.
16			*/
17
18			namespace Biurad\Cache;
19
20			use Biurad\Cache\Exceptions\CacheException;
21			use Biurad\Cache\Exceptions\InvalidArgumentException;
22			use Biurad\Cache\Interfaces\FastCacheInterface;
23			use Cache\Adapter\Common\CacheItem as PhpCacheItem;
24			use Cache\Adapter\Common\PhpCachePool;
25			use Closure;
26			use Generator;
27			use Psr\Cache\CacheItemInterface;
28			use Psr\Cache\CacheItemPoolInterface;
29			use Psr\SimpleCache\CacheInterface;
30			use stdClass;
31			use Throwable;
32
33			/**
34			* Implements the cache for a application.
35			*/
36			class FastCache implements FastCacheInterface
37			{
38			/** @internal */
39			public const NAMESPACE_SEPARATOR = "\x00";
40
41			public const NAMESPACE = 'CACHE_KEY[%s]';
42
43			/** @var CacheInterface\|CacheItemPoolInterface */
44			private $storage;
45
46			/** @var string */
47			private $namespace;
48
49			/** @var array<string,mixed> */
50			private $computing = [];
51
52			/**
53			* @param CacheInterface\|CacheItemPoolInterface $storage
54			* @param string $namespace
55			*/
56			final public function __construct($storage, string $namespace = self::NAMESPACE)
57			{
58			if (
59			!($storage instanceof CacheInterface \|\| $storage instanceof CacheItemPoolInterface)
			0 ignored issues – show introduced 2020-07-05 01:22 UTC by Report Bug Copy Issue Report `$storage` is always a sub-type of `Psr\Cache\CacheItemPoolInterface`. Loading history...
60			) {
61			throw new CacheException('$storage can only implements psr-6 or psr-16 cache interface');
62			}
63
64			$this->storage = $storage;
65			$this->namespace = $namespace . self::NAMESPACE_SEPARATOR;
66			}
67
68			/**
69			* {@inheritdoc}
70			*/
71			public function getStorage()
72			{
73			return $this->storage;
74			}
75
76			/**
77			* Returns cache namespace.
78			*/
79			public function getNamespace(): string
80			{
81			return \substr(\sprintf($this->namespace, ''), 0, -1);
82			}
83
84			/**
85			* {@inheritdoc}
86			*/
87			public function derive(string $namespace): FastCache
88			{
89			return new static($this->storage, $this->namespace . $namespace);
90			}
91
92			/**
93			* {@inheritdoc}
94			*/
95			public function load($key, callable $fallback = null, ?float $beta = null)
96			{
97			$data = $this->doFetch($this->generateKey($key));
98
99			if ($data instanceof CacheItemInterface) {
100			$data = $data->isHit() ? $data->get() : null;
101			}
102
103			if (null === $data && null !== $fallback) {
104			return $this->save($key, $fallback, $beta);
105			}
106
107			return $data;
108			}
109
110			/**
111			* {@inheritDoc}
112			*/
113			public function bulkLoad(array $keys, callable $fallback = null, ?float $beta = null): array
114			{
115			if (0 === \count($keys)) {
116			return [];
117			}
118
119			foreach ($keys as $key) {
120			if (!\is_scalar($key)) {
121			throw new InvalidArgumentException('Only scalar keys are allowed in bulkLoad()');
122			}
123			}
124			$storageKeys = \array_map([$this, 'generateKey'], $keys);
125			$cacheData = $this->doFetch($storageKeys);
126			$result = [];
127
128			if ($cacheData instanceof Generator) {
129			$cacheData = \iterator_to_array($cacheData);
130			}
131
132			foreach ($keys as $i => $key) {
133			$storageKey = $storageKeys[$i];
134
135			if (isset($cacheData[$storageKey])) {
136			$result[$key] = $cacheData[$storageKey];
137			} elseif (null !== $fallback) {
138			$result[$key] = $this->save(
139			$key,
140			function (CacheItemInterface $item, bool $save) use ($key, $fallback) {
141			return $fallback(...[$key, &$item, &$save]);
142			},
143			$beta
144			);
145			} else {
146			$result[$key] = null;
147			}
148			}
149
150			return \array_map(
151			function ($value) {
152			if ($value instanceof CacheItemInterface) {
153			return $value->get();
154			}
155
156			return $value;
157			},
158			$result
159			);
160			}
161
162			/**
163			* {@inheritdoc}
164			*
165			* @psalm-suppress InaccessibleProperty
166			*/
167			public function save($key, ?callable $callback = null, ?float $beta = null)
168			{
169			$key = $this->generateKey($key);
170
171			if (null === $callback) {
172			$this->doDelete($key);
173
174			return false;
175			}
176
177			if (0 > $beta = $beta ?? 1.0) {
178			throw new InvalidArgumentException(
179			\sprintf(
180			'Argument "$beta" provided to "%s::get()" must be a positive number, %f given.',
181			static::class,
182			$beta
183			)
184			);
185			}
186
187			static $setExpired;
188
189			$setExpired = Closure::bind(
190			static function (CacheItem $item) {
191			if (null === $item->expiry) {
			0 ignored issues – show Bug introduced 2020-07-16 13:43 UTC by Report Bug Copy Issue Report The property `expiry` is declared protected in `Biurad\Cache\CacheItem` and cannot be accessed from this context. Loading history...
192			return null;
193			}
194
195			return (int) (0.1 + $item->expiry - \microtime(true));
196			},
197			null,
198			CacheItem::class
199			);
200
201			if ($this->storage instanceof PhpCachePool) {
202			$setExpired = static function (PhpCacheItem $item) {
203			return $item->getExpirationTimestamp();
204			};
205			}
206
207			$callback = function (CacheItemInterface $item, bool $save) use ($key, $callback) {
208			// don't wrap nor save recursive calls
209			if (isset($this->computing[$key])) {
210			$value = $callback(...[&$item, &$save]);
211			$save = false;
			0 ignored issues – show Unused Code introduced 2020-07-13 00:12 UTC by Report Bug Copy Issue Report The assignment to `$save` is dead and can be removed. Loading history...
212
213			return $value;
214			}
215
216			$this->computing[$key] = $key;
217
218			try {
219			return $value = $callback(...[&$item, &$save]);
			0 ignored issues – show Unused Code introduced 2020-07-05 01:22 UTC by Report Bug Copy Issue Report The assignment to `$value` is dead and can be removed. Loading history...
220			} catch (Throwable $e) {
221			$this->doDelete($key);
222
223			throw $e;
224			} finally {
225			unset($this->computing[$key]);
226			}
227			};
228
229			return $this->doSave($this->storage, $key, $callback, $setExpired, $beta);
230			}
231
232			/**
233			* {@inheritdoc}
234			*/
235			public function delete($key): void
236			{
237			$this->save($key, null);
238			}
239
240			/**
241			* {@inheritdoc}
242			*/
243			public function call(callable $callback, ?float $beta = null)
244			{
245			$key = \func_get_args();
246
247			if (\is_array($callback) && \is_object($callback[0])) {
248			$key[0][0] = \get_class($callback[0]);
249			}
250
251			return $this->load(
252			$key,
253			function (CacheItemInterface $item, bool $save) use ($callback, $key) {
254			$dependencies = \array_merge(\array_slice($key, 1), [&$item, &$save]);
255
256			return $callback(...$dependencies);
257			},
258			$beta
259			);
260			}
261
262			/**
263			* {@inheritdoc}
264			*/
265			public function wrap(callable $callback, ?float $beta = null): callable
266			{
267			return function () use ($callback, $beta) {
268			return $this->call($callback, $beta);
269			};
270			}
271
272			/**
273			* {@inheritdoc}
274			*/
275			public function start($key): ?OutputHelper
276			{
277			$data = $this->load($key);
278
279			if (null === $data) {
280			return new OutputHelper($this, $key);
281			}
282			echo $data;
283
284			return null;
285			}
286
287			/**
288			* Generates internal cache key.
289			*
290			* @param mixed $key
291			*
292			* @return string
293			*/
294			protected function generateKey($key): string
295			{
296			if (\is_array($key) && \current($key) instanceof Closure) {
297			$key = \spl_object_id($key[0]);
298			}
299
300			$key = \md5(\is_scalar($key) ? (string) $key : \serialize($key));
301
302			return \strpos($this->namespace, '%s') ? \sprintf($this->namespace, $key) : $this->namespace . $key;
303			}
304
305			/**
306			* Save cache item.
307			*
308			* @param CacheInterface\|CacheItemPoolInterface $storage
309			* @param string $key
310			* @param Closure $callback
311			* @param Closure $setExpired
312			* @param null\|float $beta
313			*
314			* @return mixed The corresponding values found in the cache
315			*/
316			protected function doSave($storage, string $key, Closure $callback, Closure $setExpired, ?float $beta)
317			{
318			if ($storage instanceof CacheItemPoolInterface) {
319			$item = $storage->getItem($key);
320
321			if (!$item->isHit() \|\| \INF === $beta) {
322			$save = true;
323			$result = $callback(...[$item, $save]);
324
325			if (false !== $save) {
			0 ignored issues – show introduced 2020-07-13 03:42 UTC by Report Bug Copy Issue Report The condition `false !== $save` is always `true`. Loading history...
326			if (!$result instanceof CacheItemInterface) {
327			$item->set($result);
328			$storage->save($item);
329			} else {
330			$storage->save($result);
331			}
332			}
333			}
334
335			return $item->get();
336			}
337
338			$save = true;
339			$item = $storage instanceof PhpCachePool ? new PhpCacheItem($key) : new CacheItem();
340			$result = $callback(...[$item, $save]);
341
342			if ($result instanceof CacheItemInterface) {
343			$result = $result->get();
344			}
345
346			$storage->set($key, $result, $setExpired($item));
347
348			return $result;
349			}
350
351			/**
352			* Fetch cache item.
353			*
354			* @param string\|string[] $ids The cache identifier to fetch
355			*
356			* @return mixed The corresponding values found in the cache
357			*/
358			protected function doFetch($ids)
359			{
360			if ($this->storage instanceof CacheItemPoolInterface) {
361			return !\is_array($ids) ? $this->storage->getItem($ids) : $this->storage->getItems($ids);
362			}
363
364			return !\is_array($ids) ? $this->storage->get($ids) : $this->storage->getMultiple($ids, new stdClass());
365			}
366
367			/**
368			* Remove an item from cache.
369			*
370			* @param string $id An identifier that should be removed from cache
371			*
372			* @return bool True if the items were successfully removed, false otherwise
373			*/
374			protected function doDelete(string $id)
375			{
376			if ($this->storage instanceof CacheItemPoolInterface) {
377			return $this->storage->deleteItem($id);
378			}
379
380			return $this->storage->delete($id);
381			}
382			}
383

biurad / php-cache

Push — master ( b2545f...e44389 )

FastCache::doSave() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like