lib/internal/Magento/Framework/Cache/Frontend/Adapter/OptimizedPredisClient.php - 2.4-develop - githubmirror/magento2

lib/internal/Magento/Framework/Cache/Frontend/Adapter/OptimizedPredisClient.php

131 строка3 KB

Dnyaneshwar S Jambhulkar

AC-15351::Identify and replace all Zend_Cache usages with symfony/cache across the codebase

05 янв 2026, 13:04

05 янв 2026, 13:042f6e93b

<?php
/**
 * Copyright 2026 Adobe
 * All Rights Reserved.
 */
declare(strict_types=1);

namespace Magento\Framework\Cache\Frontend\Adapter;

use Predis\Client as PredisClient;

/**
 * Optimized Predis wrapper - minimal intervention approach
 *
 * Only optimizes GET operations with response caching. All other operations
 * are passed through directly to maintain 100% compatibility with Predis.
 */
class OptimizedPredisClient extends PredisClient
{
    /**
     * @var array
     */
    private array $cache = [];

    /**
     * @var bool
     */
    private bool $cachingEnabled = true;

    private const CACHE_TTL = 1;
    private const CACHE_MAX = 200;

    /**
     * Constructor
     *
     * @param mixed $parameters
     * @param mixed $options
     */
    public function __construct($parameters = null, $options = null)
    {
        parent::__construct($parameters, $options);

        // Conservative: only enable caching for web requests, not CLI/tests
        if (php_sapi_name() === 'cli' || defined('TESTS_TEMP_DIR')) {
            $this->cachingEnabled = false;
        }
    }

    /**
     * Optimized GET with response caching
     *
     * @param string $key
     * @return mixed
     */
    public function get($key)
    {
        if (!$this->cachingEnabled) {
            return parent::get($key);
        }

        $cacheKey = 'get:' . $key;

        if (isset($this->cache[$cacheKey])) {
            [$result, $time] = $this->cache[$cacheKey];
            if ((time() - $time) < self::CACHE_TTL) {
                return $result;
            }
            unset($this->cache[$cacheKey]);
        }

        $result = parent::get($key);

        if (count($this->cache) >= self::CACHE_MAX) {
            array_shift($this->cache);
        }
        $this->cache[$cacheKey] = [$result, time()];

        return $result;
    }

    /**
     * Clear cache on SET
     *
     * @param string $key
     * @param mixed $value
     * @param string|null $expireResolution
     * @param int|null $expireTTL
     * @param string|null $flag
     * @return mixed
     */
    public function set($key, $value, $expireResolution = null, $expireTTL = null, $flag = null)
    {
        $this->cache = [];
        return parent::set($key, $value, $expireResolution, $expireTTL, $flag);
    }

    /**
     * Clear cache on DEL
     *
     * @param string|array $keys
     * @return mixed
     */
    public function del($keys)
    {
        $this->cache = [];
        return parent::del(is_array($keys) ? $keys : [$keys]);
    }

    /**
     * Clear cache on FLUSHDB
     *
     * @return mixed
     */
    public function flushdb()
    {
        $this->cache = [];
        return parent::flushdb();
    }

    /**
     * Clear cache on SELECT (database switch)
     *
     * @param int $database
     * @return mixed
     */
    public function select($database)
    {
        $this->cache = [];
        return parent::select($database);
    }
}