PageCache.php

Same filename in other branches
  1. 8.9.x core/modules/page_cache/src/StackMiddleware/PageCache.php
  2. 10 core/modules/page_cache/src/StackMiddleware/PageCache.php
  3. 11.x core/modules/page_cache/src/StackMiddleware/PageCache.php

Namespace

Drupal\page_cache\StackMiddleware

File

core/modules/page_cache/src/StackMiddleware/PageCache.php

View source
<?php

namespace Drupal\page_cache\StackMiddleware;

use Drupal\Core\Cache\Cache;
use Drupal\Core\Cache\CacheableResponseInterface;
use Drupal\Core\Cache\CacheBackendInterface;
use Drupal\Core\PageCache\RequestPolicyInterface;
use Drupal\Core\PageCache\ResponsePolicyInterface;
use Drupal\Core\Site\Settings;
use Symfony\Component\HttpFoundation\BinaryFileResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpFoundation\StreamedResponse;
use Symfony\Component\HttpKernel\HttpKernelInterface;

/**
 * Executes the page caching before the main kernel takes over the request.
 */
class PageCache implements HttpKernelInterface {
    
    /**
     * The wrapped HTTP kernel.
     *
     * @var \Symfony\Component\HttpKernel\HttpKernelInterface
     */
    protected $httpKernel;
    
    /**
     * The cache bin.
     *
     * @var \Drupal\Core\Cache\CacheBackendInterface
     */
    protected $cache;
    
    /**
     * A policy rule determining the cacheability of a request.
     *
     * @var \Drupal\Core\PageCache\RequestPolicyInterface
     */
    protected $requestPolicy;
    
    /**
     * A policy rule determining the cacheability of the response.
     *
     * @var \Drupal\Core\PageCache\ResponsePolicyInterface
     */
    protected $responsePolicy;
    
    /**
     * The cache ID for the (master) request.
     *
     * @var string
     */
    protected $cid;
    
    /**
     * Constructs a PageCache object.
     *
     * @param \Symfony\Component\HttpKernel\HttpKernelInterface $http_kernel
     *   The decorated kernel.
     * @param \Drupal\Core\Cache\CacheBackendInterface $cache
     *   The cache bin.
     * @param \Drupal\Core\PageCache\RequestPolicyInterface $request_policy
     *   A policy rule determining the cacheability of a request.
     * @param \Drupal\Core\PageCache\ResponsePolicyInterface $response_policy
     *   A policy rule determining the cacheability of the response.
     */
    public function __construct(HttpKernelInterface $http_kernel, CacheBackendInterface $cache, RequestPolicyInterface $request_policy, ResponsePolicyInterface $response_policy) {
        $this->httpKernel = $http_kernel;
        $this->cache = $cache;
        $this->requestPolicy = $request_policy;
        $this->responsePolicy = $response_policy;
    }
    
    /**
     * {@inheritdoc}
     */
    public function handle(Request $request, $type = self::MASTER_REQUEST, $catch = TRUE) : Response {
        // Only allow page caching on master request.
        if ($type === static::MASTER_REQUEST && $this->requestPolicy
            ->check($request) === RequestPolicyInterface::ALLOW) {
            $response = $this->lookup($request, $type, $catch);
        }
        else {
            $response = $this->pass($request, $type, $catch);
        }
        return $response;
    }
    
    /**
     * Sidesteps the page cache and directly forwards a request to the backend.
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     * @param int $type
     *   The type of the request (one of HttpKernelInterface::MASTER_REQUEST or
     *   HttpKernelInterface::SUB_REQUEST)
     * @param bool $catch
     *   Whether to catch exceptions or not
     *
     * @returns \Symfony\Component\HttpFoundation\Response $response
     *   A response object.
     */
    protected function pass(Request $request, $type = self::MASTER_REQUEST, $catch = TRUE) {
        return $this->httpKernel
            ->handle($request, $type, $catch);
    }
    
    /**
     * Retrieves a response from the cache or fetches it from the backend.
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     * @param int $type
     *   The type of the request (one of HttpKernelInterface::MASTER_REQUEST or
     *   HttpKernelInterface::SUB_REQUEST)
     * @param bool $catch
     *   Whether to catch exceptions or not
     *
     * @returns \Symfony\Component\HttpFoundation\Response $response
     *   A response object.
     */
    protected function lookup(Request $request, $type = self::MASTER_REQUEST, $catch = TRUE) {
        if ($response = $this->get($request)) {
            $response->headers
                ->set('X-Drupal-Cache', 'HIT');
        }
        else {
            $response = $this->fetch($request, $type, $catch);
        }
        // Only allow caching in the browser and prevent that the response is stored
        // by an external proxy server when the following conditions apply:
        // 1. There is a session cookie on the request.
        // 2. The Vary: Cookie header is on the response.
        // 3. The Cache-Control header does not contain the no-cache directive.
        if ($request->cookies
            ->has(session_name()) && in_array('Cookie', $response->getVary()) && !$response->headers
            ->hasCacheControlDirective('no-cache')) {
            $response->setPrivate();
        }
        // Perform HTTP revalidation.
        // @todo Use Response::isNotModified() as
        //   per https://www.drupal.org/node/2259489.
        $last_modified = $response->getLastModified();
        if ($last_modified) {
            // See if the client has provided the required HTTP headers.
            $if_modified_since = $request->server
                ->has('HTTP_IF_MODIFIED_SINCE') ? strtotime($request->server
                ->get('HTTP_IF_MODIFIED_SINCE')) : FALSE;
            $if_none_match = $request->server
                ->has('HTTP_IF_NONE_MATCH') ? stripslashes($request->server
                ->get('HTTP_IF_NONE_MATCH')) : FALSE;
            if ($if_modified_since && $if_none_match && $if_none_match == $response->getEtag() && $if_modified_since == $last_modified->getTimestamp()) {
                $response->setStatusCode(304);
                $response->setContent(NULL);
                // In the case of a 304 response, certain headers must be sent, and the
                // remaining may not (see RFC 2616, section 10.3.5).
                foreach (array_keys($response->headers
                    ->all()) as $name) {
                    if (!in_array($name, [
                        'content-location',
                        'expires',
                        'cache-control',
                        'vary',
                    ])) {
                        $response->headers
                            ->remove($name);
                    }
                }
            }
        }
        return $response;
    }
    
    /**
     * Fetches a response from the backend and stores it in the cache.
     *
     * @see drupal_page_header()
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     * @param int $type
     *   The type of the request (one of HttpKernelInterface::MASTER_REQUEST or
     *   HttpKernelInterface::SUB_REQUEST)
     * @param bool $catch
     *   Whether to catch exceptions or not
     *
     * @returns \Symfony\Component\HttpFoundation\Response $response
     *   A response object.
     */
    protected function fetch(Request $request, $type = self::MASTER_REQUEST, $catch = TRUE) {
        
        /** @var \Symfony\Component\HttpFoundation\Response $response */
        $response = $this->httpKernel
            ->handle($request, $type, $catch);
        // Only set the 'X-Drupal-Cache' header if caching is allowed for this
        // response.
        if ($this->storeResponse($request, $response)) {
            $response->headers
                ->set('X-Drupal-Cache', 'MISS');
        }
        return $response;
    }
    
    /**
     * Stores a response in the page cache.
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     * @param \Symfony\Component\HttpFoundation\Response $response
     *   A response object that should be stored in the page cache.
     *
     * @returns bool
     */
    protected function storeResponse(Request $request, Response $response) {
        // Drupal's primary cache invalidation architecture is cache tags: any
        // response that varies by a configuration value or data in a content
        // entity should have cache tags, to allow for instant cache invalidation
        // when that data is updated. However, HTTP does not standardize how to
        // encode cache tags in a response. Different CDNs implement their own
        // approaches, and configurable reverse proxies (e.g., Varnish) allow for
        // custom implementations. To keep Drupal's internal page cache simple, we
        // only cache CacheableResponseInterface responses, since those provide a
        // defined API for retrieving cache tags. For responses that do not
        // implement CacheableResponseInterface, there's no easy way to distinguish
        // responses that truly don't depend on any site data from responses that
        // contain invalidation information customized to a particular proxy or
        // CDN.
        // - Drupal modules are encouraged to use CacheableResponseInterface
        //   responses where possible and to leave the encoding of that information
        //   into response headers to the corresponding proxy/CDN integration
        //   modules.
        // - Custom applications that wish to provide internal page cache support
        //   for responses that do not implement CacheableResponseInterface may do
        //   so by replacing/extending this middleware service or adding another
        //   one.
        if (!$response instanceof CacheableResponseInterface) {
            return FALSE;
        }
        // Currently it is not possible to cache binary file or streamed responses:
        // https://github.com/symfony/symfony/issues/9128#issuecomment-25088678.
        // Therefore exclude them, even for subclasses that implement
        // CacheableResponseInterface.
        if ($response instanceof BinaryFileResponse || $response instanceof StreamedResponse) {
            return FALSE;
        }
        // Allow policy rules to further restrict which responses to cache.
        if ($this->responsePolicy
            ->check($response, $request) === ResponsePolicyInterface::DENY) {
            return FALSE;
        }
        $request_time = $request->server
            ->get('REQUEST_TIME');
        // The response passes all of the above checks, so cache it. Page cache
        // entries default to Cache::PERMANENT since they will be expired via cache
        // tags locally. Because of this, page cache ignores max age.
        // - Get the tags from CacheableResponseInterface per the earlier comments.
        // - Get the time expiration from the Expires header, rather than the
        //   interface, but see https://www.drupal.org/node/2352009 about possibly
        //   changing that.
        $expire = 0;
        // 403 and 404 responses can fill non-LRU cache backends and generally are
        // likely to have a low cache hit rate. So do not cache them permanently.
        if ($response->isClientError()) {
            // Cache for an hour by default. If the 'cache_ttl_4xx' setting is
            // set to 0 then do not cache the response.
            $cache_ttl_4xx = Settings::get('cache_ttl_4xx', 3600);
            if ($cache_ttl_4xx > 0) {
                $expire = $request_time + $cache_ttl_4xx;
            }
        }
        elseif ($expires = $response->getExpires()) {
            $date = $expires->getTimestamp();
            $expire = $date > $request_time ? $date : Cache::PERMANENT;
        }
        else {
            $expire = Cache::PERMANENT;
        }
        if ($expire === Cache::PERMANENT || $expire > $request_time) {
            $tags = $response->getCacheableMetadata()
                ->getCacheTags();
            $this->set($request, $response, $expire, $tags);
        }
        return TRUE;
    }
    
    /**
     * Returns a response object from the page cache.
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     * @param bool $allow_invalid
     *   (optional) If TRUE, a cache item may be returned even if it is expired or
     *   has been invalidated. Such items may sometimes be preferred, if the
     *   alternative is recalculating the value stored in the cache, especially
     *   if another concurrent request is already recalculating the same value.
     *   The "valid" property of the returned object indicates whether the item is
     *   valid or not. Defaults to FALSE.
     *
     * @return \Symfony\Component\HttpFoundation\Response|false
     *   The cached response or FALSE on failure.
     */
    protected function get(Request $request, $allow_invalid = FALSE) {
        $cid = $this->getCacheId($request);
        if ($cache = $this->cache
            ->get($cid, $allow_invalid)) {
            return $cache->data;
        }
        return FALSE;
    }
    
    /**
     * Stores a response object in the page cache.
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     * @param \Symfony\Component\HttpFoundation\Response $response
     *   The response to store in the cache.
     * @param int $expire
     *   One of the following values:
     *   - CacheBackendInterface::CACHE_PERMANENT: Indicates that the item should
     *     not be removed unless it is deleted explicitly.
     *   - A Unix timestamp: Indicates that the item will be considered invalid
     *     after this time, i.e. it will not be returned by get() unless
     *     $allow_invalid has been set to TRUE. When the item has expired, it may
     *     be permanently deleted by the garbage collector at any time.
     * @param array $tags
     *   An array of tags to be stored with the cache item. These should normally
     *   identify objects used to build the cache item, which should trigger
     *   cache invalidation when updated. For example if a cached item represents
     *   a node, both the node ID and the author's user ID might be passed in as
     *   tags. For example array('node' => array(123), 'user' => array(92)).
     */
    protected function set(Request $request, Response $response, $expire, array $tags) {
        $cid = $this->getCacheId($request);
        $this->cache
            ->set($cid, $response, $expire, $tags);
    }
    
    /**
     * Gets the page cache ID for this request.
     *
     * @param \Symfony\Component\HttpFoundation\Request $request
     *   A request object.
     *
     * @return string
     *   The cache ID for this request.
     */
    protected function getCacheId(Request $request) {
        // Once a cache ID is determined for the request, reuse it for the duration
        // of the request. This ensures that when the cache is written, it is only
        // keyed on request data that was available when it was read. For example,
        // the request format might be NULL during cache lookup and then set during
        // routing, in which case we want to key on NULL during writing, since that
        // will be the value during lookups for subsequent requests.
        if (!isset($this->cid)) {
            $cid_parts = [
                $request->getSchemeAndHttpHost() . $request->getRequestUri(),
                $request->getRequestFormat(NULL),
            ];
            $this->cid = implode(':', $cid_parts);
        }
        return $this->cid;
    }

}

Classes

Title Deprecated Summary
PageCache Executes the page caching before the main kernel takes over the request.

Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.