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

…-standards

Update console commands to symfony5 standards

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;
  }
 }