added command and extended storage

Author: wachterjohannes

src/Command/DebugTasksCommand.php

@@ -0,0 +1,80 @@
+<?php
+
+namespace Task\TaskBundle\Command;
+
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\Table;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Task\Storage\StorageInterface;
+
+/**
+ * Run pending tasks.
+ *
+ * @author @wachterjohannes <[email protected]>
+ */
+class DebugTasksCommand extends Command
+{
+    /**
+     * @var StorageInterface
+     */
+    private $storage;
+
+    public function __construct($name, StorageInterface $storage)
+    {
+        parent::__construct($name);
+
+        $this->storage = $storage;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function configure()
+    {
+        $this->setDescription('Debug tasks')
+            ->addOption('limit', 'l')
+            ->addOption('key');
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $key = $input->getOption('key');
+        $limit = $input->getOption('limit');
+
+        if (null !== $key) {
+            $tasks = $this->storage->findByKey($key, $limit);
+        } else {
+            $tasks = $this->storage->findAll($limit);
+        }
+
+        $table = new Table($output);
+        $table->setHeaders(array('uuid', 'key', 'task-name', 'execution-date', 'completed', 'start', 'duration'));
+
+        foreach ($tasks as $task) {
+            $start = null;
+            $duration = null;
+            if (null !== $task->getLastExecution()) {
+                $start = $task->getLastExecution()->getFinishedAtAsDateTime()->format(\DateTime::RFC3339);
+                $duration = $task->getLastExecution()->getExecutionDuration();
+            }
+
+            $table->addRow(
+                [
+                    $task->getUuid(),
+                    $task->getKey(),
+                    $task->getTaskName(),
+                    $task->getExecutionDate()->format(\DateTime::RFC3339),
+                    $task->isCompleted(),
+                    $start,
+                    $duration,
+                ]
+            );
+        }
+
+        $table->render();
+    }
+}

src/Storage/DoctrineStorage.php

@@ -70,13 +70,26 @@ function (TaskEntity $entity) {
     /**
      * {@inheritdoc}
      */
-    public function findAll()
+    public function findAll($limit = null)
     {
         return array_map(
             function (TaskEntity $entity) {
                 return $entity->getTask();
             },
-            $this->taskRepository->findAll()
+            $this->taskRepository->findBy([], null, $limit)
+        );
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function findByKey($key, $limit = null)
+    {
+        return array_map(
+            function (TaskEntity $entity) {
+                return $entity->getTask();
+            },
+            $this->taskRepository->findBy(['key' => $key], null, $limit)
         );
     }