added terminate listener to run scheduled tasks

Author: wachterjohannes

src/DependencyInjection/Configuration.php

@@ -20,6 +20,12 @@ public function getConfigTreeBuilder()
         $treeBuilder->root('task')
             ->children()
                 ->enumNode('storage')->values(['array', 'doctrine'])->defaultValue('array')->end()
+                ->arrayNode('run')
+                    ->addDefaultsIfNotSet()
+                    ->children()
+                        ->enumNode('mode')->values(['off', 'listener'])->defaultValue('off')->end()
+                    ->end()
+                ->end()
             ->end();
 
         return $treeBuilder;

src/DependencyInjection/TaskExtension.php

@@ -26,5 +26,9 @@ public function load(array $configs, ContainerBuilder $container)
         $loader->load(sprintf('storage/%s.xml', $config['storage']));
         $loader->load('scheduler.xml');
         $loader->load('command.xml');
+
+        if ($config['run']['mode'] === 'listener') {
+            $loader->load('listener.xml');
+        }
     }
 }

src/EventListener/RunListener.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace Task\TaskBundle\EventListener;
+
+use Symfony\Component\EventDispatcher\Event;
+use Task\SchedulerInterface;
+
+/**
+ * Listens to event and run scheduled tasks.
+ *
+ * @author @wachterjohannes <[email protected]>
+ */
+class RunListener
+{
+    /**
+     * @var SchedulerInterface
+     */
+    private $scheduler;
+
+    public function __construct(SchedulerInterface $scheduler)
+    {
+        $this->scheduler = $scheduler;
+    }
+
+    /**
+     * Run scheduled tasks.
+     *
+     * @param Event $event
+     */
+    public function run(Event $event)
+    {
+        $this->scheduler->run();
+    }
+}

src/Resources/config/listener.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" ?>
+<container xmlns="http://symfony.com/schema/dic/services"
+           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+           xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
+    <services>
+        <service id="task.event_listener.run" class="Task\TaskBundle\EventListener\RunListener">
+            <argument type="service" id="task.scheduler" />
+
+            <tag name="kernel.event_listener" event="kernel.terminate" method="run" />
+        </service>
+    </services>
+</container>

tests/Functional/SchedulerTest.php

@@ -3,6 +3,8 @@
 namespace Functional;
 
 use Symfony\Bundle\FrameworkBundle\Test\KernelTestCase;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
 use Task\SchedulerInterface;
 use Task\Storage\StorageInterface;
 use Task\Task;

tests/Unit/EventListener/RunListenerTest.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Unit\EventListener;
+
+use Symfony\Component\EventDispatcher\Event;
+use Task\SchedulerInterface;
+use Task\TaskBundle\EventListener\RunListener;
+
+class RunListenerTest extends \PHPUnit_Framework_TestCase
+{
+    public function testRun()
+    {
+        $event = $this->prophesize(Event::class);
+        $scheduler = $this->prophesize(SchedulerInterface::class);
+
+        $listener = new RunListener($scheduler->reveal());
+
+        $listener->run($event->reveal());
+
+        $scheduler->run()->shouldBeCalledTimes(1);
+    }
+}