1#@!#!123s

: / proc / thread-self / root / opt / psa / admin / plib / modules / advisor / vendor / tedivm / stash / src / Stash /
Filename : Item.php
back
<?php

/*
 * This file is part of the Stash package.
 *
 * (c) Robert Hafner <tedivm@tedivm.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace PleskAdvisor\Stash;

use PleskAdvisor\Stash\Exception\Exception;
use PleskAdvisor\Stash\Exception\InvalidArgumentException;
use PleskAdvisor\Stash\Exception\ItemKeyMissingException;
use PleskAdvisor\Stash\Interfaces\DriverInterface;
use PleskAdvisor\Stash\Interfaces\ItemInterface;
use PleskAdvisor\Stash\Interfaces\PoolInterface;
/**
 * Stash caches data that has a high generation cost, such as template preprocessing or code that requires a database
 * connection. This class can store any native php datatype, as long as it can be serialized (so when creating classes
 * that you wish to store instances of, remember the __sleep and __wake magic functions).
 *
 * @package Stash
 * @author  Robert Hafner <tedivm@tedivm.com>
 */
class Item implements ItemInterface
{
    /**
     * This is the default time, in seconds, that objects are cached for.
     *
     * @var int seconds
     */
    public static $cacheTime = 432000;
    // five days
    /**
     * Disables the cache system wide. It is used internally when the storage engine fails or if the cache is being
     * cleared. This differs from the cacheEnabled property in that it affects all instances of the cache, not just one.
     *
     * @var bool
     */
    public static $runtimeDisable = \false;
    /**
     * Used internally to mark the class as disabled. Unlike the static runtimeDisable flag this is effective only for
     * the current instance.
     *
     * @var bool
     */
    protected $cacheEnabled = \true;
    /**
     * Contains a list of default arguments for when users do not supply them.
     *
     * @var array
     */
    protected $defaults = array(
        'precompute_time' => 40,
        // time, in seconds, before expiration
        'sleep_time' => 500,
        // time, in microseconds, to sleep
        'sleep_attempts' => 1,
        // number of times to sleep, wake up, and recheck cache
        'stampede_ttl' => 30,
    );
    /**
     * The data to store in the cache
     *
     * @var mixed
     */
    protected $data;
    /**
     * When the cache for this item expires
     *
     * @var int
     */
    protected $expiration;
    /**
     * Invalidation method
     *
     * @var int
     */
    protected $invalidationMethod = Invalidation::PRECOMPUTE;
    /**
     * Invalidation argument 1
     *
     * @var mixed
     */
    protected $invalidationArg1 = null;
    /**
     * Invalidation argument 2
     *
     * @var mixed
     */
    protected $invalidationArg2 = null;
    /**
     * The identifier for the item being cached. It is set through the setupKey function.
     *
     * @var array One dimensional array representing the location of a cached object.
     */
    protected $key;
    /**
     * A serialized version of the key, used primarily used as the index in various arrays.
     *
     * @var string
     */
    protected $keyString;
    /**
     * Marks whether or not stampede protection is enabled for this instance of Stash.
     *
     * @var bool
     */
    protected $stampedeRunning = \false;
    /**
     * The Pool that spawned this instance of the Item..
     *
     * @var \Stash\Interfaces\PoolInterface
     */
    protected $pool;
    /**
     * The cacheDriver being used by the system. While this class handles all of the higher functions, it's the cache
     * driver here that handles all of the storage/retrieval functionality. This value is set by the constructor.
     *
     * @var \Stash\Interfaces\DriverInterface
     */
    protected $driver;
    /**
     * If set various then errors and exceptions will get passed to the PSR Compliant logging library. This
     * can be set using the setLogger() function in this class.
     *
     * @var \Psr\Log\LoggerInterface
     */
    protected $logger;
    /**
     * Defines the namespace the item lives in.
     *
     * @var string|null
     */
    protected $namespace = null;
    /**
     * This is a flag to see if a valid response is returned. It is set by the getData function and is used by the
     * isMiss function.
     *
     * @var bool
     */
    private $isHit = null;
    /**
     * {@inheritdoc}
     *
     * @param \Stash\Interfaces\PoolInterface $pool
     */
    public function setPool(PoolInterface $pool) : void
    {
        $this->pool = $pool;
        $this->driver = $pool->getDriver();
    }
    /**
     * {@inheritdoc}
     *
     * @param array $key        the key to set for this cache item
     * @param string $namespace the namespace for this cache item
     */
    public function setKey(array $key, ?string $namespace = null) : void
    {
        $this->namespace = $namespace;
        $keyStringTmp = $key;
        if (isset($this->namespace)) {
            \array_shift($keyStringTmp);
        }
        $this->keyString = \implode('/', $keyStringTmp);
        // We implant the namespace "cache" to the front of every stash object's key. This allows us to segment
        // off the user data, and use other 'namespaces' for internal purposes.
        \array_unshift($key, 'cache');
        $this->key = \array_map('strtolower', $key);
    }
    /**
     * {@inheritdoc}
     */
    public function disable() : bool
    {
        $this->cacheEnabled = \false;
        return \true;
    }
    /**
     * {@inheritdoc}
     */
    public function getKey() : string
    {
        return isset($this->keyString) ? $this->keyString : \false;
    }
    /**
     * {@inheritdoc}
     */
    public function clear() : bool
    {
        try {
            return $this->executeClear();
        } catch (Exception $e) {
            $this->logException('Clearing cache caused exception.', $e);
            $this->disable();
            return \false;
        }
    }
    /**
     * {@inheritdoc}
     */
    private function executeClear()
    {
        unset($this->data);
        unset($this->expiration);
        if ($this->isDisabled()) {
            return \false;
        }
        return $this->driver->clear(isset($this->key) ? $this->key : null);
    }
    /**
     * {@inheritdoc}
     *
     * @return mixed|null
     */
    public function get() : mixed
    {
        try {
            if (!isset($this->data)) {
                $this->data = $this->executeGet($this->invalidationMethod, $this->invalidationArg1, $this->invalidationArg2);
            }
            if (\false === $this->isHit) {
                return null;
            }
            return $this->data;
        } catch (Exception $e) {
            $this->logException('Retrieving from cache caused exception.', $e);
            $this->disable();
            return null;
        }
    }
    /**
     * {@inheritdoc}
     *
     * @param int $invalidation
     * @param mixed  $arg
     * @param mixed  $arg2
     */
    public function setInvalidationMethod($invalidation = Invalidation::PRECOMPUTE, $arg = null, $arg2 = null) : void
    {
        $this->invalidationMethod = $invalidation;
        $this->invalidationArg1 = $arg;
        $this->invalidationArg2 = $arg2;
    }
    /**
     * {@inheritdoc}
     *
     * @param int $invalidation
     * @param mixed  $arg
     * @param mixed  $arg2
     * @return mixed|Null
     */
    private function executeGet($invalidation = Invalidation::PRECOMPUTE, $arg = null, $arg2 = null)
    {
        $this->isHit = \false;
        if ($this->isDisabled()) {
            return null;
        }
        if (!isset($this->key)) {
            return null;
        }
        if (!\is_array($invalidation)) {
            $vArray = array();
            if (isset($invalidation)) {
                $vArray[] = $invalidation;
            }
            if (isset($arg)) {
                $vArray[] = $arg;
            }
            if (isset($arg2)) {
                $vArray[] = $arg2;
            }
            $invalidation = $vArray;
        }
        $record = $this->getRecord();
        $this->validateRecord($invalidation, $record);
        return isset($record['data']['return']) ? $record['data']['return'] : null;
    }
    /**
     * {@inheritdoc}
     *
     * @return bool
     */
    public function isHit() : bool
    {
        return !$this->isMiss();
    }
    /**
     * {@inheritdoc}
     *
     * @return bool
     */
    public function isMiss() : bool
    {
        if (!isset($this->isHit)) {
            $this->get();
        }
        if ($this->isDisabled()) {
            return \true;
        }
        return !$this->isHit;
    }
    /**
     * {@inheritdoc}
     *
     * @param int $ttl time to live
     * @return bool
     */
    public function lock(?int $ttl = null) : bool
    {
        if ($this->isDisabled()) {
            return \true;
        }
        if (!isset($this->key)) {
            return \false;
        }
        $this->stampedeRunning = \true;
        $expiration = isset($ttl) && \is_numeric($ttl) ? (int) $ttl : $this->defaults['stampede_ttl'];
        $spkey = $this->key;
        $spkey[0] = 'sp';
        return $this->driver->storeData($spkey, \true, \time() + $expiration);
    }
    /**
     * {@inheritdoc}
     *
     * @param mixed $value
     * @return \Stash\Item
     */
    public function set(mixed $value) : static
    {
        if (!isset($this->key)) {
            throw new ItemKeyMissingException('Item key is missing, cannot save.');
        }
        if ($this->isDisabled()) {
            return $this;
        }
        $this->data = $value;
        return $this;
    }
    /**
     * {@inheritdoc}
     *
     * @param int|\DateInterval|\DateTimeInterface|null $ttl time to live
     * @return \Stash\Item
     */
    public function setTTL(int|\DateInterval|\DateTimeInterface|null $ttl = null) : static
    {
        if (\is_numeric($ttl) || $ttl instanceof \DateInterval) {
            return $this->expiresAfter($ttl);
        }
        if ($ttl instanceof \DateTimeInterface) {
            return $this->expiresAt($ttl);
        }
        $this->expiration = null;
        return $this;
    }
    /**
     * {@inheritdoc}
     *
     * @throws \Stash\Exception\InvalidArgumentException
     * @return \Stash\Item
     */
    public function expiresAt(int|\DateInterval|\DateTimeInterface|null $expiration = null) : static
    {
        if (!\is_null($expiration) && !$expiration instanceof \DateTimeInterface) {
            # For compatbility with PHP 5.4 we also allow inheriting from the DateTime object.
            if (!$expiration instanceof \DateTime) {
                throw new InvalidArgumentException('expiresAt requires \\DateTimeInterface or null');
            }
        }
        $this->expiration = $expiration;
        return $this;
    }
    /**
     * {@inheritdoc}
     *
     * @param int $time date timestamp
     * @return \Stash\Item
     */
    public function expiresAfter(int|\DateInterval|null $time) : static
    {
        $date = new \DateTime();
        if (\is_numeric($time)) {
            $dateInterval = \DateInterval::createFromDateString(\abs($time) . ' seconds');
            if ($time > 0) {
                $date->add($dateInterval);
            } else {
                $date->sub($dateInterval);
            }
            $this->expiration = $date;
        } elseif ($time instanceof \DateInterval) {
            $date->add($time);
            $this->expiration = $date;
        }
        return $this;
    }
    /**
     * {@inheritdoc}
     *
     * @return bool
     */
    public function save() : bool
    {
        try {
            return $this->executeSet($this->data, $this->expiration);
        } catch (Exception $e) {
            $this->logException('Setting value in cache caused exception.', $e);
            $this->disable();
            return \false;
        }
    }
    /**
     * {@inheritdoc}
     *
     * @param mixed $data
     * @param int|\DateTimeInterface|null $time
     * @return bool
     */
    protected function executeSet(mixed $data, int|\DateTimeInterface|null $time) : bool
    {
        if ($this->isDisabled() || !isset($this->key)) {
            return \false;
        }
        $store = array();
        $store['return'] = $data;
        $store['createdOn'] = \time();
        if (isset($time) && ($time instanceof \DateTime || $time instanceof \DateTimeInterface)) {
            $expiration = $time->getTimestamp();
            $cacheTime = $expiration - $store['createdOn'];
        } else {
            $cacheTime = self::$cacheTime;
        }
        $expiration = $store['createdOn'] + $cacheTime;
        if ($cacheTime > 0) {
            $expirationDiff = \random_int(0, \floor($cacheTime * 0.15));
            $expiration -= $expirationDiff;
        }
        if ($this->stampedeRunning === \true) {
            $spkey = $this->key;
            $spkey[0] = 'sp';
            // change "cache" data namespace to stampede namespace
            $this->driver->clear($spkey);
            $this->stampedeRunning = \false;
        }
        return $this->driver->storeData($this->key, $store, $expiration);
    }
    /**
     * {@inheritdoc}
     *
     * @param int|\DateInterval|null $ttl time to live
     * @return \Stash\Item|false
     */
    public function extend(int|\DateInterval|null $ttl = null) : \PleskAdvisor\Stash\Item|bool
    {
        if ($this->isDisabled()) {
            return \false;
        }
        $expiration = $this->getExpiration();
        if (\is_numeric($ttl)) {
            $dateInterval = \DateInterval::createFromDateString(\abs($ttl) . ' seconds');
            if ($ttl > 0) {
                $expiration->add($dateInterval);
            } else {
                $expiration->sub($dateInterval);
            }
        } elseif ($ttl instanceof \DateInterval) {
            $expiration->add($ttl);
        } else {
            $expiration = null;
        }
        if ($this->executeSet($this->get(), $expiration)) {
            return $this;
        }
        return \false;
    }
    /**
     * {@inheritdoc}
     *
     * @return bool
     */
    public function isDisabled() : bool
    {
        return self::$runtimeDisable || !$this->cacheEnabled || \defined('STASH_DISABLE_CACHE') && \constant('STASH_DISABLE_CACHE');
    }
    /**
     * {@inheritdoc}
     *
     * @param \Psr\Log\LoggerInterface
     */
    public function setLogger($logger) : bool
    {
        $this->logger = $logger;
        return \true;
    }
    /**
     * Logs an exception with the Logger class, if it exists.
     *
     * @param  string     $message
     * @param  \Exception $exception
     * @return bool
     */
    protected function logException(string $message, \Exception $exception) : bool
    {
        if (!isset($this->logger)) {
            return \false;
        }
        $this->logger->critical($message, array('exception' => $exception, 'key' => $this->keyString));
        return \true;
    }
    /**
     * Returns true if another Item is currently recalculating the cache.
     *
     * @param  array $key
     * @return bool
     */
    protected function getStampedeFlag(array $key) : bool
    {
        $key[0] = 'sp';
        // change "cache" data namespace to stampede namespace
        $spReturn = $this->driver->getData($key);
        $sp = isset($spReturn['data']) ? $spReturn['data'] : \false;
        if (isset($spReturn['expiration'])) {
            if ($spReturn['expiration'] < \time()) {
                $sp = \false;
            }
        }
        return $sp;
    }
    /**
     * Returns the record for the current key. If there is no record than an empty array is returned.
     *
     * @return array
     */
    protected function getRecord() : array
    {
        $record = $this->driver->getData($this->key);
        if (!\is_array($record)) {
            return array();
        }
        return $record;
    }
    /**
     * Decides whether the current data is fresh according to the supplied validation technique. As some techniques
     * actively change the record this function takes that in as a reference.
     *
     * This function has the ability to change the isHit property as well as the record passed.
     *
     * @internal
     * @param array $validation
     * @param array &$record
     */
    protected function validateRecord(array $validation, array &$record) : void
    {
        $invalidation = Invalidation::PRECOMPUTE;
        if (\is_array($validation)) {
            $argArray = $validation;
            $invalidation = isset($argArray[0]) ? $argArray[0] : Invalidation::PRECOMPUTE;
            if (isset($argArray[1])) {
                $arg = $argArray[1];
            }
            if (isset($argArray[2])) {
                $arg2 = $argArray[2];
            }
        }
        $curTime = \microtime(\true);
        if (isset($record['expiration']) && ($ttl = $record['expiration'] - $curTime) > 0) {
            $this->isHit = \true;
            if ($invalidation == Invalidation::PRECOMPUTE) {
                $time = isset($arg) && \is_numeric($arg) ? $arg : $this->defaults['precompute_time'];
                // If stampede control is on it means another cache is already processing, so we return
                // true for the hit.
                if ($ttl < $time) {
                    $this->isHit = (bool) $this->getStampedeFlag($this->key);
                }
            }
            return;
        }
        if (!isset($invalidation) || $invalidation == Invalidation::NONE) {
            $this->isHit = \false;
            return;
        }
        if (!$this->getStampedeFlag($this->key)) {
            $this->isHit = \false;
            return;
        }
        switch ($invalidation) {
            case Invalidation::VALUE:
                if (!isset($arg)) {
                    $this->isHit = \false;
                    return;
                }
                $record['data']['return'] = $arg;
                $this->isHit = \true;
                break;
            case Invalidation::SLEEP:
                $time = isset($arg) && \is_numeric($arg) ? $arg : $this->defaults['sleep_time'];
                $attempts = isset($arg2) && \is_numeric($arg2) ? $arg2 : $this->defaults['sleep_attempts'];
                $ptime = $time * 1000;
                if ($attempts <= 0) {
                    $this->isHit = \false;
                    $record['data']['return'] = null;
                    break;
                }
                \usleep($ptime);
                $record['data']['return'] = $this->executeGet(Invalidation::SLEEP, $time, $attempts - 1);
                break;
            case Invalidation::OLD:
                $this->isHit = isset($record['data']) && $record['data']['return'] !== null;
                break;
            default:
                $this->isHit = \false;
                break;
        }
    }
    /**
     * {@inheritdoc}
     *
     * @return \DateTime|false
     */
    public function getCreation() : \DateTime|bool
    {
        $record = $this->getRecord();
        if (!isset($record['data']['createdOn'])) {
            return \false;
        }
        $dateTime = new \DateTime();
        $dateTime->setTimestamp($record['data']['createdOn']);
        return $dateTime;
    }
    /**
     * {@inheritdoc}
     *
     * @return \DateTime date timestamp
     */
    public function getExpiration() : \DateTime
    {
        if (!isset($this->expiration)) {
            $record = $this->getRecord();
            $dateTime = new \DateTime();
            if (!isset($record['expiration'])) {
                return $dateTime;
            }
            $this->expiration = $dateTime->setTimestamp($record['expiration']);
        }
        return $this->expiration;
    }
    /**
     * This clears out any locks that are present if this Item is prematurely destructed.
     */
    public function __destruct()
    {
        if (isset($this->stampedeRunning) && $this->stampedeRunning === \true) {
            $spkey = $this->key;
            $spkey[0] = 'sp';
            $this->driver->clear($spkey);
        }
    }
}