Varnish::purge() - Code Metrics - Inspection of "Varnish xkey continued" - FriendsOfSymfony/FOSHttpCache - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#409)

by David

created 2018-03-13 17:10 UTC

Varnish::purge() A

↳ Parent: Varnish

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	6
ccs	3
cts	3
cp	1
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	3
nc	1
nop	2
crap	1

<?php

/*
 * This file is part of the FOSHttpCache package.
 *
 * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace FOS\HttpCache\ProxyClient;

use FOS\HttpCache\Exception\InvalidArgumentException;
use FOS\HttpCache\ProxyClient\Invalidation\BanCapable;
use FOS\HttpCache\ProxyClient\Invalidation\PurgeCapable;
use FOS\HttpCache\ProxyClient\Invalidation\RefreshCapable;
use FOS\HttpCache\ProxyClient\Invalidation\TagCapable;
use Symfony\Component\OptionsResolver\Options;

/**
 * Varnish HTTP cache invalidator.
 *
 * Additional constructor options:
 * - tag_mode            Whether to use ban or the xkey extension for cache tagging.
 * - tags_header         Header for sending tag invalidation requests to
 *                       Varnish, if tag_mode is ban, defaults to X-Cache-Tags,
 *                       otherwise defaults to xkey-softpurge.
 * - header_length       Maximum header length when invalidating tags. If there
 *                       are more tags to invalidate than fit into the header,
 *                       the invalidation request is split into several requests.
 *                       Defaults to 7500
 * - default_ban_headers Map of header name => header value that have to be set
 *                       on each ban request, merged with the built-in headers
 *
 * @author David de Boer <[email protected]>
 */
class Varnish extends HttpProxyClient implements BanCapable, PurgeCapable, RefreshCapable, TagCapable
{
    const HTTP_METHOD_BAN = 'BAN';

    const HTTP_METHOD_PURGE = 'PURGE';

    const HTTP_METHOD_PURGEKEYS = 'PURGEKEYS';

    const HTTP_METHOD_REFRESH = 'GET';

    const HTTP_HEADER_HOST = 'X-Host';

    const HTTP_HEADER_URL = 'X-Url';

    const HTTP_HEADER_CONTENT_TYPE = 'X-Content-Type';

    const TAG_BAN = 'ban';

    const TAG_XKEY = 'purgekeys';

    /**
     * Default name of the header used to invalidate content with specific tags.
     *
     * This happens to be the same as TagHeaderFormatter::DEFAULT_HEADER_NAME
     * but does not technically need to be the same.
     *
     * @var string
     */
    const DEFAULT_HTTP_HEADER_CACHE_TAGS = 'X-Cache-Tags';

    const DEFAULT_HTTP_HEADER_CACHE_XKEY = 'xkey-softpurge';

    /**
     * {@inheritdoc}
     */
    public function invalidateTags(array $tags)
    {
        $banMode = self::TAG_BAN === $this->options['tag_mode'];
        $escapedTags = array_map('preg_quote', $this->escapeTags($tags));

        $chunkSize = $this->determineTagsPerHeader($escapedTags, $banMode ? '|' : ' ');

        foreach (array_chunk($escapedTags, $chunkSize) as $tagchunk) {
            if ($banMode) {
                $this->invalidateByBan($tagchunk);
            } else {
                $this->invalidateByPurgekeys($tagchunk);
            }
        }

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function ban(array $headers)
    {
        $headers = array_merge(
            $this->options['default_ban_headers'],
            $headers
        );

        $this->queueRequest(self::HTTP_METHOD_BAN, '/', $headers, false);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function banPath($path, $contentType = null, $hosts = null)
    {
        if (is_array($hosts)) {
            if (!count($hosts)) {
                throw new InvalidArgumentException('Either supply a list of hosts or null, but not an empty array.');
            }
            $hosts = '^('.implode('|', $hosts).')$';
        }

        $headers = [
            self::HTTP_HEADER_URL => $path,
        ];

        if ($contentType) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $headers[self::HTTP_HEADER_CONTENT_TYPE] = $contentType;
        }
        if ($hosts) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $headers[self::HTTP_HEADER_HOST] = $hosts;
        }

        return $this->ban($headers);
    }

    /**
     * {@inheritdoc}
     */
    public function purge($url, array $headers = [])
    {
        $this->queueRequest(self::HTTP_METHOD_PURGE, $url, $headers);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function refresh($url, array $headers = [])

    {
        $headers = array_merge($headers, ['Cache-Control' => 'no-cache']);
        $this->queueRequest(self::HTTP_METHOD_REFRESH, $url, $headers);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    protected function configureOptions()
    {
        $resolver = parent::configureOptions();
        $resolver->setDefaults([
            'tags_header' => self::DEFAULT_HTTP_HEADER_CACHE_TAGS,
            'tag_mode' => self::TAG_BAN,
            'header_length' => 7500,
            'default_ban_headers' => [],
        ]);
        $resolver->setDefault('tags_header', function (Options $options) {
            if (self::TAG_BAN === $options['tag_mode']) {
                return self::DEFAULT_HTTP_HEADER_CACHE_TAGS;
            }

            return self::DEFAULT_HTTP_HEADER_CACHE_XKEY;
        });
        $resolver->setAllowedValues('tag_mode', [self::TAG_BAN, self::TAG_XKEY]);
        $resolver->setNormalizer('default_ban_headers', function ($resolver, $specified) {
            return array_merge(
                [
                    self::HTTP_HEADER_HOST => self::REGEX_MATCH_ALL,
                    self::HTTP_HEADER_URL => self::REGEX_MATCH_ALL,
                    self::HTTP_HEADER_CONTENT_TYPE => self::REGEX_MATCH_ALL,
                ],
                $specified
            );
        });

        return $resolver;
    }

    private function invalidateByBan(array $tagchunk)
    {
        $tagExpression = sprintf('(^|,)(%s)(,|$)', implode('|', $tagchunk));
        $this->ban([$this->options['tags_header'] => $tagExpression]);
    }

    private function invalidateByPurgekeys(array $tagchunk)
    {
        $this->queueRequest(
            self::HTTP_METHOD_PURGEKEYS,
            '/',
            [$this->options['tags_header'] => implode(' ', $tagchunk)],
            false
        );
    }
}


1			<?php
2
3			/*
4			* This file is part of the FOSHttpCache package.
5			*
6			* (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace FOS\HttpCache\ProxyClient;
13
14			use FOS\HttpCache\Exception\InvalidArgumentException;
15			use FOS\HttpCache\ProxyClient\Invalidation\BanCapable;
16			use FOS\HttpCache\ProxyClient\Invalidation\PurgeCapable;
17			use FOS\HttpCache\ProxyClient\Invalidation\RefreshCapable;
18			use FOS\HttpCache\ProxyClient\Invalidation\TagCapable;
19			use Symfony\Component\OptionsResolver\Options;
20
21			/**
22			* Varnish HTTP cache invalidator.
23			*
24			* Additional constructor options:
25			* - tag_mode Whether to use ban or the xkey extension for cache tagging.
26			* - tags_header Header for sending tag invalidation requests to
27			* Varnish, if tag_mode is ban, defaults to X-Cache-Tags,
28			* otherwise defaults to xkey-softpurge.
29			* - header_length Maximum header length when invalidating tags. If there
30			* are more tags to invalidate than fit into the header,
31			* the invalidation request is split into several requests.
32			* Defaults to 7500
33			* - default_ban_headers Map of header name => header value that have to be set
34			* on each ban request, merged with the built-in headers
35			*
36			* @author David de Boer <[email protected]>
37			*/
38			class Varnish extends HttpProxyClient implements BanCapable, PurgeCapable, RefreshCapable, TagCapable
39			{
40			const HTTP_METHOD_BAN = 'BAN';
41
42			const HTTP_METHOD_PURGE = 'PURGE';
43
44			const HTTP_METHOD_PURGEKEYS = 'PURGEKEYS';
45
46			const HTTP_METHOD_REFRESH = 'GET';
47
48			const HTTP_HEADER_HOST = 'X-Host';
49
50			const HTTP_HEADER_URL = 'X-Url';
51
52			const HTTP_HEADER_CONTENT_TYPE = 'X-Content-Type';
53
54			const TAG_BAN = 'ban';
55
56			const TAG_XKEY = 'purgekeys';
57	4
58			/**
59	4		* Default name of the header used to invalidate content with specific tags.
60			*
61	4		* This happens to be the same as TagHeaderFormatter::DEFAULT_HEADER_NAME
62			* but does not technically need to be the same.
63			*
64			* @var string
65			*/
66	1		const DEFAULT_HTTP_HEADER_CACHE_TAGS = 'X-Cache-Tags';
67	1
68			const DEFAULT_HTTP_HEADER_CACHE_XKEY = 'xkey-softpurge';
69	3
70			/**
71			* {@inheritdoc}
72	4		*/
73	4		public function invalidateTags(array $tags)
74	4		{
75			$banMode = self::TAG_BAN === $this->options['tag_mode'];
76			$escapedTags = array_map('preg_quote', $this->escapeTags($tags));
77	4
78			$chunkSize = $this->determineTagsPerHeader($escapedTags, $banMode ? '\|' : ' ');
79
80			foreach (array_chunk($escapedTags, $chunkSize) as $tagchunk) {
81			if ($banMode) {
82			$this->invalidateByBan($tagchunk);
83	10		} else {
84			$this->invalidateByPurgekeys($tagchunk);
85	10		}
86	10		}
87	10
88			return $this;
89			}
90	10
91			/**
92	10		* {@inheritdoc}
93			*/
94			public function ban(array $headers)
95			{
96			$headers = array_merge(
97			$this->options['default_ban_headers'],
98	4		$headers
99			);
100	4
101	2		$this->queueRequest(self::HTTP_METHOD_BAN, '/', $headers, false);
102	1
103			return $this;
104	1		}
105
106			/**
107			* {@inheritdoc}
108	3		*/
109			public function banPath($path, $contentType = null, $hosts = null)
110			{
111	3		if (is_array($hosts)) {
112	2		if (!count($hosts)) {
113			throw new InvalidArgumentException('Either supply a list of hosts or null, but not an empty array.');
114	3		}
115	1		$hosts = '^('.implode('\|', $hosts).')$';
116			}
117
118	3		$headers = [
119			self::HTTP_HEADER_URL => $path,
120			];
121
122			if ($contentType) {
			0 ignored issues – show Bug Best Practice introduced 2015-11-23 22:08 UTC by Report Bug Copy Issue Report The expression `$contentType` of type `string\|null` is loosely compared to `true`; this is ambiguous if the string can be empty. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `string` values, the empty string `''` is a special case, in particular the following results might be unexpected: '' == false // true '' == null // true 'ab' == false // false 'ab' == null // false // It is often better to use strict comparison '' === false // false '' === null // false Loading history...
123			$headers[self::HTTP_HEADER_CONTENT_TYPE] = $contentType;
124	4		}
125			if ($hosts) {
			0 ignored issues – show Bug Best Practice introduced 2015-11-23 22:08 UTC by Report Bug Copy Issue Report The expression `$hosts` of type `string\|null` is loosely compared to `true`; this is ambiguous if the string can be empty. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `string` values, the empty string `''` is a special case, in particular the following results might be unexpected: '' == false // true '' == null // true 'ab' == false // false 'ab' == null // false // It is often better to use strict comparison '' === false // false '' === null // false Loading history...
126	4		$headers[self::HTTP_HEADER_HOST] = $hosts;
127			}
128	4
129			return $this->ban($headers);
130			}
131
132			/**
133			* {@inheritdoc}
134	3		*/
135			public function purge($url, array $headers = [])
136	3		{
137	3		$this->queueRequest(self::HTTP_METHOD_PURGE, $url, $headers);
138
139	3		return $this;
140			}
141
142			/**
143			* {@inheritdoc}
144			*/
145	19	View Code Duplication	public function refresh($url, array $headers = [])
			0 ignored issues – show Duplication introduced 2017-08-09 08:00 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
146			{
147	19		$headers = array_merge($headers, ['Cache-Control' => 'no-cache']);
148	19		$this->queueRequest(self::HTTP_METHOD_REFRESH, $url, $headers);
149	19
150	19		return $this;
151			}
152
153	19		/**
154	19		* {@inheritdoc}
155			*/
156	19		protected function configureOptions()
157	19		{
158	19		$resolver = parent::configureOptions();
159			$resolver->setDefaults([
160	19		'tags_header' => self::DEFAULT_HTTP_HEADER_CACHE_TAGS,
161			'tag_mode' => self::TAG_BAN,
162	19		'header_length' => 7500,
163			'default_ban_headers' => [],
164	19		]);
165			$resolver->setDefault('tags_header', function (Options $options) {
166			if (self::TAG_BAN === $options['tag_mode']) {
167			return self::DEFAULT_HTTP_HEADER_CACHE_TAGS;
168			}
169
170			return self::DEFAULT_HTTP_HEADER_CACHE_XKEY;
171			});
172			$resolver->setAllowedValues('tag_mode', [self::TAG_BAN, self::TAG_XKEY]);
173			$resolver->setNormalizer('default_ban_headers', function ($resolver, $specified) {
174			return array_merge(
175			[
176			self::HTTP_HEADER_HOST => self::REGEX_MATCH_ALL,
177			self::HTTP_HEADER_URL => self::REGEX_MATCH_ALL,
178			self::HTTP_HEADER_CONTENT_TYPE => self::REGEX_MATCH_ALL,
179			],
180			$specified
181			);
182			});
183
184			return $resolver;
185			}
186
187			private function invalidateByBan(array $tagchunk)
188			{
189			$tagExpression = sprintf('(^\|,)(%s)(,\|$)', implode('\|', $tagchunk));
190			$this->ban([$this->options['tags_header'] => $tagExpression]);
191			}
192
193			private function invalidateByPurgekeys(array $tagchunk)
194			{
195			$this->queueRequest(
196			self::HTTP_METHOD_PURGEKEYS,
197			'/',
198			[$this->options['tags_header'] => implode(' ', $tagchunk)],
199			false
200			);
201			}
202			}
203

FriendsOfSymfony / FOSHttpCache

Pull Request — master (#409)

Varnish::purge() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like