Merge pull request #276 from f500/update-console-commands-to-symfony5-standards

Update console commands to symfony5 standards

Author: ramondelafuente

config/services.yaml

@@ -134,5 +134,7 @@ services:
 
     Tooling\SymfonyConsole\:
         resource: '../src/Tooling/SymfonyConsole/'
+        arguments:
+            $eventStore: '@prooph_event_store.herd_store'
         tags:
             - 'console.command'

src/Tooling/SymfonyConsole/CreateEventStreamCommand.php

@@ -8,36 +8,50 @@
 use Prooph\EventStore\EventStore;
 use Prooph\EventStore\Stream;
 use Prooph\EventStore\StreamName;
-use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
-final class CreateEventStreamCommand extends ContainerAwareCommand
+final class CreateEventStreamCommand extends Command
 {
+    /**
+     * @var EventStore
+     */
+    private $eventStore;
+
+    /**
+     * @var string
+     */
+    protected static $defaultName = 'event-store:event-stream:create';
+
     protected function configure(): void
     {
-        $this->setName('event-store:event-stream:create')
-            ->setDescription('Create event_stream.')
+        $this->setDescription('Create event_stream.')
             ->setHelp('This command creates the event_stream');
     }
 
+    public function __construct(EventStore $eventStore)
+    {
+        parent::__construct();
+
+        $this->eventStore = $eventStore;
+    }
+
     /**
-     * @param InputInterface $input
+     * @param InputInterface  $input
      * @param OutputInterface $output
+     * @return int
      * @phpcsSuppress SlevomatCodingStandard.Functions.UnusedParameter.UnusedParameter
      */
     protected function execute(InputInterface $input, OutputInterface $output): int
     {
-        /** @var EventStore $eventStore */
-        $eventStore = $this->getContainer()->get('prooph_event_store.herd_store');
-
         $streamName = new StreamName('event_stream');
 
-        if ($eventStore->hasStream($streamName)) {
+        if ($this->eventStore->hasStream($streamName)) {
             return 0;
         }
 
-        $eventStore->create(new Stream($streamName, new ArrayIterator([])));
+        $this->eventStore->create(new Stream($streamName, new ArrayIterator([])));
         $output->writeln('<info>Event stream was created successfully.</info>');
 
         return 0;

src/Tooling/SymfonyConsole/DeleteEventStreamCommand.php

@@ -7,16 +7,27 @@
 use Prooph\EventStore\EventStore;
 use Prooph\EventStore\Exception\StreamNotFound;
 use Prooph\EventStore\StreamName;
-use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 use Symfony\Component\Console\Question\ConfirmationQuestion;
 
-final class DeleteEventStreamCommand extends ContainerAwareCommand
+final class DeleteEventStreamCommand extends Command
 {
-    protected function configure(): void
+    /**
+     * @var EventStore
+     */
+    private $eventStore;
+
+    /**
+     * @var string
+     */
+    protected static $defaultName = 'event-store:event-stream:delete';
+
+    public function __construct(EventStore $eventStore)
     {
-        $this->setName('event-store:event-stream:delete');
+        parent::__construct();
+        $this->eventStore = $eventStore;
     }
 
     protected function execute(InputInterface $input, OutputInterface $output): int
@@ -32,14 +43,13 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         }
 
         try {
-            /** @var EventStore $eventStore */
-            $eventStore = $this->getContainer()->get('prooph_event_store.herd_store');
-            $eventStore->delete(new StreamName('event_stream'));
+            $this->eventStore->delete(new StreamName('event_stream'));
         } catch (StreamNotFound $exception) {
             // Fine by us.
         }
 
         $output->writeln('<info>Event stream was deleted successfully.</info>');
+
         return 0;
     }
 }