MultiplexerClient::invoke() - Code Metrics - Inspection of "Clear cache with ClearCapable" - FriendsOfSymfony/FOSHttpCache - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#440)

by David

created 2018-11-06 13:13 UTC

MultiplexerClient::invoke() A

↳ Parent: MultiplexerClient

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

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

<?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\ExceptionCollection;
use FOS\HttpCache\Exception\InvalidArgumentException;
use FOS\HttpCache\Exception\UnsupportedProxyOperationException;
use FOS\HttpCache\ProxyClient\Invalidation\BanCapable;
use FOS\HttpCache\ProxyClient\Invalidation\ClearCapable;
use FOS\HttpCache\ProxyClient\Invalidation\PurgeCapable;
use FOS\HttpCache\ProxyClient\Invalidation\RefreshCapable;
use FOS\HttpCache\ProxyClient\Invalidation\TagCapable;

/**
 * This class forwards invalidation to all attached clients.
 *
 * @author Emanuele Panzeri <[email protected]>
 */
class MultiplexerClient implements BanCapable, PurgeCapable, RefreshCapable, TagCapable, ClearCapable
{
    /**
     * @var ProxyClient[]
     */
    private $proxyClients;

    /**
     * MultiplexerClient constructor.
     *
     * @param ProxyClient[] $proxyClients The list of Proxy clients
     */
    public function __construct(array $proxyClients)
    {
        foreach ($proxyClients as $proxyClient) {
            if (!$proxyClient instanceof ProxyClient) {
                throw new InvalidArgumentException(
                    'Expected ProxyClientInterface, got: '.
                    (is_object($proxyClient) ? get_class($proxyClient) : gettype($proxyClient))
                );
            }
        }

        $this->proxyClients = $proxyClients;
    }

    /**
     * Forwards to all clients.
     *
     * @param array $headers HTTP headers that path must match to be banned
     *
     * @return $this
     */
    public function ban(array $headers)
    {
        $this->invoke(BanCapable::class, 'ban', [$headers]);

        return $this;
    }

    /**
     * Forwards to all clients.
     *
     * @param string       $path        Regular expression pattern for URI to invalidate
     * @param string       $contentType Regular expression pattern for the content type to limit banning, for instance
     *                                  'text'
     * @param array|string $hosts       Regular expression of a host name or list of exact host names to limit banning
     *
     * @return $this
     */
    public function banPath($path, $contentType = null, $hosts = null)
    {
        $this->invoke(BanCapable::class, 'banPath', [$path, $contentType, $hosts]);

        return $this;
    }

    /**
     * Forwards to all clients.
     *
     * @throws ExceptionCollection If any errors occurred during flush
     *
     * @return int The number of cache invalidations performed per caching server
     */
    public function flush()
    {
        $count = 0;
        foreach ($this->proxyClients as $proxyClient) {
            $count += $proxyClient->flush();
        }

        return $count;
    }

    /**
     * Forwards tag invalidation request to all clients.
     *
     * {@inheritdoc}
     *
     * @param array $tags
     *
     * @return $this
     */
    public function invalidateTags(array $tags)
    {
        $this->invoke(TagCapable::class, 'invalidateTags', [$tags]);

        return $this;
    }

    /**
     * Forwards to all clients.
     *
     * @param string $url     Path or URL to purge
     * @param array  $headers Extra HTTP headers to send to the caching proxy (optional)
     *
     * @return $this
     */
    public function purge($url, array $headers = [])
    {
        $this->invoke(PurgeCapable::class, 'purge', [$url, $headers]);

        return $this;
    }

    /**
     * Forwards to all clients.
     *
     * @param string $url     Path or URL to refresh
     * @param array  $headers Extra HTTP headers to send to the caching proxy (optional)
     *
     * @return $this
     */
    public function refresh($url, array $headers = [])
    {
        $this->invoke(RefreshCapable::class, 'refresh', [$url, $headers]);

        return $this;
    }

    /**
     * Forwards to all clients.
     *
     * @return $this
     */
    public function clear()
    {
        $this->invoke(ClearCapable::class, 'clear', []);

        return $this;
    }

    /**
     * Invoke the given $method on all available ProxyClients implementing the
     * given $interface.
     *
     * @param string $interface The FQN of the interface
     * @param string $method    The method to invoke
     * @param array  $arguments The arguments to be passed to the method
     */
    private function invoke($interface, $method, array $arguments)
    {
        foreach ($this->getProxyClients($interface) as $proxyClient) {
            call_user_func_array([$proxyClient, $method], $arguments);
        }
    }

    /**
     * Invoke the given $method on the first available ProxyClient implementing
     * the given $interface.
     *
     * @param string $interface The FQN of the interface
     * @param string $method    The method to invoke
     * @param array  $arguments The arguments to be passed to the method
     *
     * @return mixed Return value of ProxyClient method call
     *
     * @throws UnsupportedProxyOperationException
     */
    private function invokeFirst($interface, $method, array $arguments)
    {
        foreach ($this->getProxyClients($interface) as $proxyClient) {
            return call_user_func_array([$proxyClient, $method], $arguments);
        }

        throw UnsupportedProxyOperationException::cacheDoesNotImplement($interface);
    }

    /**
     * Get proxy clients that implement a feature interface.
     *
     * @param string $interface
     *
     * @return ProxyClient[]
     */
    private function getProxyClients($interface)
    {
        return array_filter(
            $this->proxyClients,
            function ($proxyClient) use ($interface) {
                return is_subclass_of($proxyClient, $interface);
            }
        );
    }
}


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\ExceptionCollection;
15		use FOS\HttpCache\Exception\InvalidArgumentException;
16		use FOS\HttpCache\Exception\UnsupportedProxyOperationException;
17		use FOS\HttpCache\ProxyClient\Invalidation\BanCapable;
18		use FOS\HttpCache\ProxyClient\Invalidation\ClearCapable;
19		use FOS\HttpCache\ProxyClient\Invalidation\PurgeCapable;
20		use FOS\HttpCache\ProxyClient\Invalidation\RefreshCapable;
21		use FOS\HttpCache\ProxyClient\Invalidation\TagCapable;
22
23		/**
24		* This class forwards invalidation to all attached clients.
25		*
26		* @author Emanuele Panzeri <[email protected]>
27		*/
28		class MultiplexerClient implements BanCapable, PurgeCapable, RefreshCapable, TagCapable, ClearCapable
29		{
30		/**
31		* @var ProxyClient[]
32		*/
33		private $proxyClients;
34
35		/**
36		* MultiplexerClient constructor.
37		*
38		* @param ProxyClient[] $proxyClients The list of Proxy clients
39	8	*/
40		public function __construct(array $proxyClients)
41	8	{
42	8	foreach ($proxyClients as $proxyClient) {
43	2	if (!$proxyClient instanceof ProxyClient) {
44		throw new InvalidArgumentException(
45	8	'Expected ProxyClientInterface, got: '.
46		(is_object($proxyClient) ? get_class($proxyClient) : gettype($proxyClient))
47		);
48		}
49		}
50	6
51	6	$this->proxyClients = $proxyClients;
52		}
53
54		/**
55		* Forwards to all clients.
56		*
57		* @param array $headers HTTP headers that path must match to be banned
58		*
59		* @return $this
60	1	*/
61		public function ban(array $headers)
62	1	{
63		$this->invoke(BanCapable::class, 'ban', [$headers]);
64	1
65		return $this;
66		}
67
68		/**
69		* Forwards to all clients.
70		*
71		* @param string $path Regular expression pattern for URI to invalidate
72		* @param string $contentType Regular expression pattern for the content type to limit banning, for instance
73		* 'text'
74		* @param array\|string $hosts Regular expression of a host name or list of exact host names to limit banning
75		*
76		* @return $this
77	1	*/
78		public function banPath($path, $contentType = null, $hosts = null)
79	1	{
80		$this->invoke(BanCapable::class, 'banPath', [$path, $contentType, $hosts]);
81	1
82		return $this;
83		}
84
85		/**
86		* Forwards to all clients.
87		*
88		* @throws ExceptionCollection If any errors occurred during flush
89		*
90		* @return int The number of cache invalidations performed per caching server
91	1	*/
92		public function flush()
93	1	{
94	1	$count = 0;
95	1	foreach ($this->proxyClients as $proxyClient) {
96		$count += $proxyClient->flush();
97		}
98	1
99		return $count;
100		}
101
102		/**
103		* Forwards tag invalidation request to all clients.
104		*
105		* {@inheritdoc}
106		*
107		* @param array $tags
108		*
109		* @return $this
110	1	*/
111		public function invalidateTags(array $tags)
112	1	{
113		$this->invoke(TagCapable::class, 'invalidateTags', [$tags]);
114	1
115		return $this;
116		}
117
118		/**
119		* Forwards to all clients.
120		*
121		* @param string $url Path or URL to purge
122		* @param array $headers Extra HTTP headers to send to the caching proxy (optional)
123		*
124		* @return $this
125	1	*/
126		public function purge($url, array $headers = [])
127	1	{
128		$this->invoke(PurgeCapable::class, 'purge', [$url, $headers]);
129	1
130		return $this;
131		}
132
133		/**
134		* Forwards to all clients.
135		*
136		* @param string $url Path or URL to refresh
137		* @param array $headers Extra HTTP headers to send to the caching proxy (optional)
138		*
139		* @return $this
140	1	*/
141		public function refresh($url, array $headers = [])
142	1	{
143		$this->invoke(RefreshCapable::class, 'refresh', [$url, $headers]);
144	1
145		return $this;
146		}
147
148		/**
149		* Forwards to all clients.
150		*
151		* @return $this
152		*/
153		public function clear()
154		{
155	5	$this->invoke(ClearCapable::class, 'clear', []);
156
157	5	return $this;
158	5	}
159
160	5	/**
161		* Invoke the given $method on all available ProxyClients implementing the
162		* given $interface.
163		*
164		* @param string $interface The FQN of the interface
165		* @param string $method The method to invoke
166		* @param array $arguments The arguments to be passed to the method
167		*/
168		private function invoke($interface, $method, array $arguments)
169		{
170		foreach ($this->getProxyClients($interface) as $proxyClient) {
171		call_user_func_array([$proxyClient, $method], $arguments);
172		}
173		}
174
175		/**
176		* Invoke the given $method on the first available ProxyClient implementing
177		* the given $interface.
178		*
179		* @param string $interface The FQN of the interface
180		* @param string $method The method to invoke
181		* @param array $arguments The arguments to be passed to the method
182		*
183		* @return mixed Return value of ProxyClient method call
184		*
185		* @throws UnsupportedProxyOperationException
186		*/
187		private function invokeFirst($interface, $method, array $arguments)
188		{
189		foreach ($this->getProxyClients($interface) as $proxyClient) {
190	5	return call_user_func_array([$proxyClient, $method], $arguments);
191		}
192	5
193	5	throw UnsupportedProxyOperationException::cacheDoesNotImplement($interface);
194	5	}
195	5
196	5	/**
197		* Get proxy clients that implement a feature interface.
198		*
199		* @param string $interface
200		*
201		* @return ProxyClient[]
202		*/
203		private function getProxyClients($interface)
204		{
205		return array_filter(
206		$this->proxyClients,
207		function ($proxyClient) use ($interface) {
208		return is_subclass_of($proxyClient, $interface);
209		}
210		);
211		}
212		}
213

FriendsOfSymfony / FOSHttpCache

Pull Request — master (#440)

MultiplexerClient::invoke() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like