fixed refactored

Author: wachterjohannes

src/Command/DebugTasksCommand.php

@@ -7,7 +7,7 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
-use Task\Storage\TaskExecutionRepositoryInterface;
+use Task\Execution\TaskExecutionRepositoryInterface;
 
 /**
  * Run pending tasks.

src/Command/ScheduleTaskCommand.php

@@ -38,7 +38,7 @@ protected function configure()
             ->addArgument('handler', InputArgument::REQUIRED)
             ->addArgument('workload', InputArgument::OPTIONAL)
             ->addOption('cron-expression', 'c', InputOption::VALUE_REQUIRED)
-            ->addOption('end-date', 'e', InputOption::VALUE_REQUIRED);
+            ->addOption('end-date', null, InputOption::VALUE_REQUIRED);
     }
 
     /**
@@ -66,6 +66,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
             $taskBuilder->cron($cronExpression, new \DateTime(), $endDate);
         }
 
-        $taskBuilder->schedule();
+        $this->scheduler->addTask($taskBuilder->getTask());
     }
 }

src/DependencyInjection/TaskCompilerPass.php

@@ -4,7 +4,7 @@
 
 use Doctrine\Common\Persistence\ObjectManager;
 use Task\Execution\TaskExecutionInterface;
-use Task\Storage\TaskExecutionRepositoryInterface;
+use Task\Execution\TaskExecutionRepositoryInterface;
 use Task\TaskBundle\Entity\TaskExecutionRepository as ORMTaskExecutionRepository;
 use Task\TaskInterface;
 
@@ -68,4 +68,9 @@ public function findAll($limit = null)
     {
         return $this->taskExecutionRepository->findBy([], ['scheduleTime' => 'ASC'], $limit);
     }
+
+    public function get($uuid)
+    {
+        // TODO: Implement get() method.
+    }
 }

src/DoctrineStorage/TaskExecutionRepository.php

@@ -22,7 +22,7 @@ public function findByStartTime(TaskInterface $task, \DateTime $scheduleTime)
                 ->getQuery()
                 ->getSingleResult();
         } catch (NoResultException $e) {
-            return null;
+            return;
         }
     }
 

src/Entity/TaskExecutionRepository.php

@@ -19,7 +19,7 @@
         </service>
 
         <service id="task.command.schedule_task" class="Task\TaskBundle\Command\ScheduleTaskCommand">
-            <argument type="string">task:schedule:task</argument>
+            <argument type="string">task:schedule</argument>
             <argument type="service" id="task.scheduler"/>
 
             <tag name="console.command"/>

src/Resources/config/command.xml

@@ -3,6 +3,7 @@
            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.storage" class="Task\Storage\ArrayStorage\ArrayTaskRepository"/>
+        <service id="task.storage.task" class="Task\Storage\ArrayStorage\ArrayTaskRepository"/>
+        <service id="task.storage.task_execution" class="Task\Storage\ArrayStorage\ArrayTaskExecutionRepository"/>
     </services>
 </container>

src/Resources/config/storage/array.xml

@@ -5,7 +5,6 @@
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\HttpKernel\Bundle\Bundle;
 use Task\TaskBundle\DependencyInjection\HandlerCompilerPass;
-use Task\TaskBundle\DependencyInjection\TaskCompilerPass;
 
 /**
  * Integrates php-task into symfony.
@@ -19,6 +18,5 @@ public function build(ContainerBuilder $container)
         parent::build($container);
 
         $container->addCompilerPass(new HandlerCompilerPass());
-        $container->addCompilerPass(new TaskCompilerPass());
     }
 }