adding client for the symfony built-in reverse proxy HttpCache

Author: dbu

CHANGELOG.md

@@ -1,6 +1,11 @@
 Changelog
 =========
 
+1.3.3
+-----
+
+* **2015-05-08** Added a client for the Symfony built-in HttpCache
+
 1.3.0
 -----
 

doc/proxy-clients.rst

@@ -1,7 +1,7 @@
 Caching Proxy Clients
 =====================
 
-This library ships with clients for the Varnish and NGINX caching proxy. You
+This library ships with clients for the Varnish, NGINX and Symfony built-in caching proxies. You
 can use the clients either wrapped by the :doc:`cache invalidator <cache-invalidator>`
 (recommended), or directly for low-level access to invalidation functionality.
 
@@ -35,16 +35,16 @@ include that port in the base URL::
 
 .. note::
 
-    To use the client, you need to :doc:`configure Varnish <varnish-configuration>` accordingly.
+    To make invalidation work, you need to :doc:`configure Varnish <varnish-configuration>` accordingly.
 
 NGINX Client
 ~~~~~~~~~~~~
 
 At minimum, supply an array containing IPs or hostnames of the NGINX servers
 that you want to send invalidation requests to. Make sure to include the port
-NGINX runs on if it is not port 80::
+NGINX runs on if it is not the default::
 
-    use FOS\HttpCache\Invalidation\Nginx;
+    use FOS\HttpCache\ProxyClient\Nginx;
 
     $servers = array('10.0.0.1', '10.0.0.2:8088'); // Port 80 assumed for 10.0.0.1
     $nginx = new Nginx($servers);
@@ -64,6 +64,29 @@ supply that location to the class as the third parameter::
 
     To use the client, you need to :doc:`configure NGINX <nginx-configuration>` accordingly.
 
+Symfony Client
+~~~~~~~~~~~~~~
+
+At minimum, supply an array containing IPs or hostnames of your web servers
+running Symfony. Provide the direct access to the web server without any other
+proxies that might block invalidation requests. Make sure to include the port
+the web server runs on if it is not the default::
+
+    use FOS\HttpCache\ProxyClient\Symfony;
+
+    $servers = array('10.0.0.1', '10.0.0.2:8088'); // Port 80 assumed for 10.0.0.1
+    $client = new Symfony($servers);
+
+This is sufficient for invalidating absolute URLs. If you also wish to
+invalidate relative paths, supply the hostname (or base URL) where your website
+is available as the second parameter::
+
+    $client = new Symfony($servers, 'my-cool-app.com');
+
+.. note::
+
+    To make invalidation work, you need to :doc:`use the EventDispatchingHttpCache <symfony-cache-configuration>`.
+
 Using the Clients
 -----------------
 
@@ -200,4 +223,7 @@ send a basic authentication header, you can inject a custom Guzzle client::
     $servers = array('10.0.0.1');
     $varnish = new Varnish($servers, '/baseUrl', $client);
 
+The Symfony client accepts a guzzle client as the 3rd parameter as well, NGINX
+accepts it as 4th parameter.
+
 .. _Guzzle client: http://guzzle3.readthedocs.org/

doc/symfony-cache-configuration.rst

@@ -42,8 +42,6 @@ not the recommended way. You would need to adjust every place you instantiate
 the cache. Instead, overwrite the constructor of AppCache and register the
 subscribers there. A simple cache will look like this::
 
-    require_once __DIR__.'/AppKernel.php';
-
     use FOS\HttpCache\SymfonyCache\EventDispatchingHttpCache;
     use FOS\HttpCache\SymfonyCache\UserContextSubscriber;
 
@@ -57,6 +55,8 @@ subscribers there. A simple cache will look like this::
             parent::__construct($kernel, $cacheDir);
 
             $this->addSubscriber(new UserContextSubscriber());
+            $this->addSubscriber(new PurgeSubscriber());
+            $this->addSubscriber(new RefreshSubscriber());
         }
     }
 
@@ -168,7 +168,7 @@ options through the constructor:
 
     With Apache, you can do this for example in a ``.htaccess`` file::
 
-        RewriteEngine On 
+        RewriteEngine On
         RewriteRule .* - [E=HTTP_AUTHORIZATION:%{HTTP:Authorization}]
 
 Cleaning the Cookie Header

src/ProxyClient/Symfony.php

@@ -0,0 +1,90 @@
+<?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\Exception\MissingHostException;
+use FOS\HttpCache\ProxyClient\Invalidation\BanInterface;
+use FOS\HttpCache\ProxyClient\Invalidation\PurgeInterface;
+use FOS\HttpCache\ProxyClient\Invalidation\RefreshInterface;
+use FOS\HttpCache\SymfonyCache\PurgeSubscriber;
+use Guzzle\Http\ClientInterface;
+use Symfony\Component\OptionsResolver\OptionsResolver;
+
+/**
+ * Symfony HttpCache invalidator.
+ *
+ * @author David de Boer <[email protected]>
+ * @author David Buchmann <[email protected]>
+ */
+class Symfony extends AbstractProxyClient implements PurgeInterface, RefreshInterface
+{
+    const HTTP_METHOD_REFRESH = 'GET';
+
+    /**
+     * The options configured in the constructor argument or default values.
+     *
+     * @var array
+     */
+    private $options;
+
+    /**
+     * {@inheritDoc}
+     *
+     * When creating the client, you can configure options:
+     *
+     * - purge_method:         HTTP method that identifies purge requests.
+     *
+     * @param array $options The purge_method that should be used.
+     */
+    public function __construct(array $servers, $baseUrl = null, ClientInterface $client = null, array $options = array())
+    {
+        parent::__construct($servers, $baseUrl, $client);
+
+        $resolver = new OptionsResolver();
+        $resolver->setDefined(array('purge_method'));
+        $resolver->setDefaults(array(
+            'purge_method' => PurgeSubscriber::DEFAULT_PURGE_METHOD,
+        ));
+
+        $this->options = $resolver->resolve($options);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function purge($url, array $headers = array())
+    {
+        $this->queueRequest($this->options['purge_method'], $url, $headers);
+
+        return $this;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function refresh($url, array $headers = array())
+    {
+        $headers = array_merge($headers, array('Cache-Control' => 'no-cache'));
+        $this->queueRequest(self::HTTP_METHOD_REFRESH, $url, $headers);
+
+        return $this;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function getAllowedSchemes()
+    {
+        return array('http', 'https');
+    }
+}

src/SymfonyCache/PurgeSubscriber.php

@@ -27,6 +27,8 @@
  */
 class PurgeSubscriber extends AccessControlledSubscriber
 {
+    const DEFAULT_PURGE_METHOD = 'PURGE';
+
     /**
      * The options configured in the constructor argument or default values.
      *
@@ -59,7 +61,7 @@ public function __construct(array $options = array())
         $resolver->setDefaults(array(
             'purge_client_matcher' => null,
             'purge_client_ips' => null,
-            'purge_method' => 'PURGE',
+            'purge_method' => static::DEFAULT_PURGE_METHOD,
         ));
 
         $this->options = $resolver->resolve($options);