Added a router listener

Author: Nyholm

src/CacheBundle.php

@@ -31,7 +31,6 @@ public function build(ContainerBuilder $container)
 
         $container->addCompilerPass(new Compiler\SessionSupportCompilerPass());
         $container->addCompilerPass(new Compiler\DoctrineSupportCompilerPass());
-        $container->addCompilerPass(new Compiler\RouterCompilerPass());
 
         if ($container->getParameter('kernel.debug')) {
             $container->addCompilerPass(new Compiler\DataCollectorCompilerPass());

src/DependencyInjection/CacheExtension.php

@@ -11,8 +11,8 @@
 
 namespace Cache\CacheBundle\DependencyInjection;
 
-use Cache\CacheBundle\Cache\LoggingCachePool;
 use Cache\CacheBundle\DataCollector\CacheDataCollector;
+use Cache\CacheBundle\Routing\RouterListener;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\DependencyInjection\Reference;
 use Symfony\Component\HttpKernel\DependencyInjection\Extension;
@@ -45,6 +45,14 @@ public function load(array $configs, ContainerBuilder $container)
             }
         }
 
+        if ($config['router']['enabled']) {
+            $container->register('cache.router_listener', RouterListener::class)
+                ->addArgument(new Reference($config['router']['service_id']))
+                ->addArgument($config['router']['ttl'])
+                ->addTag('kernel.event_listener', ['event'=>'kernel.request', 'method'=>'onBeforeRouting', 'priority'=>33])
+                ->addTag('kernel.event_listener', ['event'=>'kernel.request', 'method'=>'onAfterRouting', 'priority'=>31]);
+        }
+
     }
 
     public function getAlias()

src/DependencyInjection/Compiler/RouterCompilerPass.php

@@ -142,10 +142,7 @@ private function addRouterSection()
                     ->defaultFalse()
                 ->end()
                 ->integerNode('ttl')
-                    ->defaultValue(86400)
-                ->end()
-                ->booleanNode('auto-register')
-                    ->defaultTrue()
+                    ->defaultValue(604800)
                 ->end()
                 ->scalarNode('service_id')
                     ->isRequired()

src/DependencyInjection/Configuration.php

@@ -0,0 +1,112 @@
+<?php
+
+namespace Cache\CacheBundle\Routing;
+
+use Cache\Taggable\TaggablePoolInterface;
+use Psr\Cache\CacheItemPoolInterface;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpKernel\Event\GetResponseEvent;
+use Symfony\Component\HttpKernel\KernelEvents;
+
+/**
+ * @author Tobias Nyholm <[email protected]>
+ */
+class RouterListener
+{
+    /**
+     * @var CacheItemPoolInterface
+     */
+    private $cache;
+
+    /**
+     * @var int
+     */
+    private $ttl;
+
+    /**
+     * @param CacheItemPoolInterface $cache
+     * @param int                    $ttl
+     */
+    public function __construct(CacheItemPoolInterface $cache, $ttl)
+    {
+        $this->cache = $cache;
+        $this->ttl   = $ttl;
+    }
+
+    /**
+     * Before routing, try to fetch route result from cache.
+     *
+     * @param GetResponseEvent $event
+     */
+    public function onBeforeRouting(GetResponseEvent $event)
+    {
+        $request = $event->getRequest();
+
+        if ($request->attributes->has('_controller')) {
+            // routing is already done
+            return;
+        }
+
+        $item = $this->getCacheItem($request);
+        if (!$item->isHit()) {
+            return;
+        }
+
+        $request->attributes->add($item->get());
+    }
+
+    /**
+     * After the routing, make sure to store the result in cache.
+     *
+     * @param GetResponseEvent $event
+     */
+    public function onAfterRouting(GetResponseEvent $event)
+    {
+        $request = $event->getRequest();
+
+        if (!$request->attributes->has('_controller')) {
+            // routing has not taken place
+            return;
+        }
+
+        $item = $this->getCacheItem($request);
+        if ($item->isHit()) {
+            return;
+        }
+
+        $item->set($request->attributes->all());
+        $this->cache->save($item);
+    }
+
+    /**
+     * Get a good key that varies on method, host, path info etc etc.
+     *
+     * @param Request $request
+     *
+     * @return string
+     */
+    private function createCacheKey(Request $request)
+    {
+        $key = 'route_'.$request->getMethod().'_'.$request->getHost().'_'.$request->getPathInfo();
+
+        return $key;
+    }
+
+    /**
+     * @param Request $request
+     *
+     * @return \Psr\Cache\CacheItemInterface
+     */
+    private function getCacheItem(Request $request)
+    {
+        $key = $this->createCacheKey($request);
+        if ($this->cache instanceof TaggablePoolInterface) {
+            $item = $this->cache->getItem($key, ['routing']);
+        } else {
+            $item = $this->cache->getItem($key);
+        }
+
+        return $item;
+    }
+}