Dispatch before / after events

Author: Prokyonn

src/Command/ExecuteCommand.php

@@ -16,6 +16,9 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\ConsoleOutputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\EventDispatcher\EventDispatcherInterface;
+use Task\Event\Events;
+use Task\Event\TaskEvent;
 use Task\Executor\FailedException;
 use Task\Handler\TaskHandlerFactoryInterface;
 use Task\Storage\TaskExecutionRepositoryInterface;
@@ -35,6 +38,11 @@ class ExecuteCommand extends Command
      */
     private $executionRepository;
 
+    /**
+     * @var EventDispatcherInterface
+     */
+    private $eventDispatcher;
+
     /**
      * @param string $name
      * @param TaskHandlerFactoryInterface $handlerFactory
@@ -43,12 +51,14 @@ class ExecuteCommand extends Command
     public function __construct(
         $name,
         TaskHandlerFactoryInterface $handlerFactory,
-        TaskExecutionRepositoryInterface $executionRepository
+        TaskExecutionRepositoryInterface $executionRepository,
+        EventDispatcherInterface $dispatcher
     ) {
         parent::__construct($name);
 
         $this->handlerFactory = $handlerFactory;
         $this->executionRepository = $executionRepository;
+        $this->eventDispatcher = $dispatcher;
     }
 
     /**
@@ -70,7 +80,9 @@ protected function execute(InputInterface $input, OutputInterface $output)
         $handler = $this->handlerFactory->create($execution->getHandlerClass());
 
         try {
+            $this->eventDispatcher->dispatch(new TaskEvent($execution->getTask()),Events::TASK_BEFORE);
             $result = $handler->handle($execution->getWorkload());
+            $this->eventDispatcher->dispatch(new TaskEvent($execution->getTask()),Events::TASK_BEFORE);
         } catch (\Exception $exception) {
             if ($exception instanceof FailedException) {
                 $errorOutput->writeln(FailedException::class);

src/Resources/config/command.xml

@@ -23,6 +23,7 @@
             <argument type="string">task:execute</argument>
             <argument type="service" id="task.handler.factory"/>
             <argument type="service" id="task.storage.task_execution"/>
+            <argument type="service" id="event_dispatcher"/>
 
             <tag name="console.command"/>
         </service>