From dfe05127e4df1bc12a22ad18cb94d8c84ef3c4de Mon Sep 17 00:00:00 2001
From: David Badura <david.badura@patchlevel.de>
Date: Thu, 10 Aug 2023 19:43:54 +0200
Subject: [PATCH] remove old projection commands

---
 src/Console/Command/ProjectionCommand.php     |  71 -------
 .../Command/ProjectionCreateCommand.php       |  50 -----
 src/Console/Command/ProjectionDropCommand.php |  50 -----
 .../Command/ProjectionRebuildCommand.php      | 118 -----------
 .../Command/ProjectionCreateCommandTest.php   |  68 -------
 .../Command/ProjectionDropCommandTest.php     |  68 -------
 .../Command/ProjectionRebuildCommandTest.php  | 187 ------------------
 7 files changed, 612 deletions(-)
 delete mode 100644 src/Console/Command/ProjectionCommand.php
 delete mode 100644 src/Console/Command/ProjectionCreateCommand.php
 delete mode 100644 src/Console/Command/ProjectionDropCommand.php
 delete mode 100644 src/Console/Command/ProjectionRebuildCommand.php
 delete mode 100644 tests/Unit/Console/Command/ProjectionCreateCommandTest.php
 delete mode 100644 tests/Unit/Console/Command/ProjectionDropCommandTest.php
 delete mode 100644 tests/Unit/Console/Command/ProjectionRebuildCommandTest.php

diff --git a/src/Console/Command/ProjectionCommand.php b/src/Console/Command/ProjectionCommand.php
deleted file mode 100644
index c8abc40f..00000000
--- a/src/Console/Command/ProjectionCommand.php
+++ /dev/null
@@ -1,71 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Console\Command;
-
-use Patchlevel\EventSourcing\Console\InvalidArgumentGiven;
-use Patchlevel\EventSourcing\Projection\Projector\Projector;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorRepository;
-use Symfony\Component\Console\Command\Command;
-
-use function array_filter;
-use function array_values;
-use function in_array;
-use function is_array;
-use function is_string;
-use function is_subclass_of;
-
-abstract class ProjectionCommand extends Command
-{
-    public function __construct(
-        private readonly ProjectorRepository $projectorRepository,
-    ) {
-        parent::__construct();
-    }
-
-    /** @return list<Projector> */
-    protected function projectors(mixed $projectionOption): array
-    {
-        $normalizedProjectionOption = $this->normalizeProjectionOption($projectionOption);
-
-        if (!$normalizedProjectionOption) {
-            return $this->projectorRepository->projectors();
-        }
-
-        return array_values(
-            array_filter(
-                [...$this->projectorRepository->projectors()],
-                static fn (Projector $projection): bool => in_array($projection::class, $normalizedProjectionOption)
-            ),
-        );
-    }
-
-    /** @return non-empty-array<class-string<Projector>>|null */
-    private function normalizeProjectionOption(mixed $option): array|null
-    {
-        if (is_string($option)) {
-            $option = [$option];
-        }
-
-        if (!is_array($option)) {
-            throw new InvalidArgumentGiven($option, 'class-string<' . Projector::class . '>[]');
-        }
-
-        $result = [];
-
-        foreach ($option as $entry) {
-            if (!is_string($entry) || !is_subclass_of($entry, Projector::class)) {
-                throw new InvalidArgumentGiven($entry, 'class-string<' . Projector::class . '>');
-            }
-
-            $result[] = $entry;
-        }
-
-        if ($result === []) {
-            return null;
-        }
-
-        return $result;
-    }
-}
diff --git a/src/Console/Command/ProjectionCreateCommand.php b/src/Console/Command/ProjectionCreateCommand.php
deleted file mode 100644
index d301f4d6..00000000
--- a/src/Console/Command/ProjectionCreateCommand.php
+++ /dev/null
@@ -1,50 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Console\Command;
-
-use Patchlevel\EventSourcing\Console\OutputStyle;
-use Patchlevel\EventSourcing\Projection\Projector\MetadataProjectorResolver;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorHelper;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorRepository;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorResolver;
-use Symfony\Component\Console\Attribute\AsCommand;
-use Symfony\Component\Console\Input\InputInterface;
-use Symfony\Component\Console\Input\InputOption;
-use Symfony\Component\Console\Output\OutputInterface;
-
-#[AsCommand(
-    'event-sourcing:projection:create',
-    'create projection schema',
-)]
-final class ProjectionCreateCommand extends ProjectionCommand
-{
-    public function __construct(
-        ProjectorRepository $projectorRepository,
-        private readonly ProjectorResolver $projectorResolver = new MetadataProjectorResolver(),
-    ) {
-        parent::__construct($projectorRepository);
-    }
-
-    protected function configure(): void
-    {
-        $this
-            ->addOption('projection', 'p', InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY, 'run only for specific projections [FQCN]');
-    }
-
-    protected function execute(InputInterface $input, OutputInterface $output): int
-    {
-        $console = new OutputStyle($input, $output);
-
-        (new ProjectorHelper($this->projectorResolver))->createProjection(
-            ...$this->projectors(
-                $input->getOption('projection'),
-            ),
-        );
-
-        $console->success('projection created');
-
-        return 0;
-    }
-}
diff --git a/src/Console/Command/ProjectionDropCommand.php b/src/Console/Command/ProjectionDropCommand.php
deleted file mode 100644
index eaefb95a..00000000
--- a/src/Console/Command/ProjectionDropCommand.php
+++ /dev/null
@@ -1,50 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Console\Command;
-
-use Patchlevel\EventSourcing\Console\OutputStyle;
-use Patchlevel\EventSourcing\Projection\Projector\MetadataProjectorResolver;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorHelper;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorRepository;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorResolver;
-use Symfony\Component\Console\Attribute\AsCommand;
-use Symfony\Component\Console\Input\InputInterface;
-use Symfony\Component\Console\Input\InputOption;
-use Symfony\Component\Console\Output\OutputInterface;
-
-#[AsCommand(
-    'event-sourcing:projection:drop',
-    'drop projection schema',
-)]
-final class ProjectionDropCommand extends ProjectionCommand
-{
-    public function __construct(
-        ProjectorRepository $projectorRepository,
-        private readonly ProjectorResolver $projectorResolver = new MetadataProjectorResolver(),
-    ) {
-        parent::__construct($projectorRepository);
-    }
-
-    protected function configure(): void
-    {
-        $this
-            ->addOption('projection', 'p', InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY, 'run only for specific projections [FQCN]');
-    }
-
-    protected function execute(InputInterface $input, OutputInterface $output): int
-    {
-        $console = new OutputStyle($input, $output);
-
-        (new ProjectorHelper($this->projectorResolver))->dropProjection(
-            ...$this->projectors(
-                $input->getOption('projection'),
-            ),
-        );
-
-        $console->success('projection deleted');
-
-        return 0;
-    }
-}
diff --git a/src/Console/Command/ProjectionRebuildCommand.php b/src/Console/Command/ProjectionRebuildCommand.php
deleted file mode 100644
index af002e1d..00000000
--- a/src/Console/Command/ProjectionRebuildCommand.php
+++ /dev/null
@@ -1,118 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Console\Command;
-
-use DateTimeImmutable;
-use Patchlevel\EventSourcing\Console\InputHelper;
-use Patchlevel\EventSourcing\Console\OutputStyle;
-use Patchlevel\EventSourcing\Pipeline\Middleware\UntilEventMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Pipeline;
-use Patchlevel\EventSourcing\Pipeline\Source\StoreSource;
-use Patchlevel\EventSourcing\Pipeline\Target\ProjectorRepositoryTarget;
-use Patchlevel\EventSourcing\Projection\Projector\InMemoryProjectorRepository;
-use Patchlevel\EventSourcing\Projection\Projector\MetadataProjectorResolver;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorHelper;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorRepository;
-use Patchlevel\EventSourcing\Projection\Projector\ProjectorResolver;
-use Patchlevel\EventSourcing\Store\Store;
-use Symfony\Component\Console\Attribute\AsCommand;
-use Symfony\Component\Console\Input\InputInterface;
-use Symfony\Component\Console\Input\InputOption;
-use Symfony\Component\Console\Output\OutputInterface;
-use Throwable;
-
-use function is_string;
-use function sprintf;
-
-#[AsCommand(
-    'event-sourcing:projection:rebuild',
-    'rebuild projection',
-)]
-final class ProjectionRebuildCommand extends ProjectionCommand
-{
-    public function __construct(
-        private Store $store,
-        ProjectorRepository $projectorRepository,
-        private ProjectorResolver $projectorResolver = new MetadataProjectorResolver(),
-    ) {
-        parent::__construct($projectorRepository);
-    }
-
-    protected function configure(): void
-    {
-        $this
-            ->addOption('recreate', 'r', InputOption::VALUE_NONE, 'drop and create projections')
-            ->addOption(
-                'until',
-                'u',
-                InputOption::VALUE_REQUIRED,
-                'create the projection up to a point in time [2017-02-02 12:00]',
-            )
-            ->addOption(
-                'projection',
-                'p',
-                InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY,
-                'run only for specific projections [FQCN]',
-            );
-    }
-
-    protected function execute(InputInterface $input, OutputInterface $output): int
-    {
-        $console = new OutputStyle($input, $output);
-
-        $projectors = $this->projectors($input->getOption('projection'));
-
-        if (InputHelper::bool($input->getOption('recreate'))) {
-            (new ProjectorHelper($this->projectorResolver))->dropProjection(
-                ...$projectors,
-            );
-
-            $console->success('projection schema deleted');
-
-            (new ProjectorHelper($this->projectorResolver))->createProjection(
-                ...$projectors,
-            );
-
-            $console->success('projection schema created');
-        }
-
-        $until = InputHelper::nullableString($input->getOption('until'));
-
-        $middlewares = [];
-
-        if (is_string($until)) {
-            try {
-                $date = new DateTimeImmutable($until);
-            } catch (Throwable) {
-                $console->error(sprintf('date "%s" not supported. the format should be "2017-02-02 12:00"', $until));
-
-                return 1;
-            }
-
-            $middlewares[] = new UntilEventMiddleware($date);
-        }
-
-        $pipeline = new Pipeline(
-            new StoreSource($this->store),
-            new ProjectorRepositoryTarget(
-                new InMemoryProjectorRepository($projectors),
-                $this->projectorResolver,
-            ),
-            $middlewares,
-        );
-
-        $console->warning('rebuild projections');
-        $console->progressStart($pipeline->count());
-
-        $pipeline->run(static function () use ($console): void {
-            $console->progressAdvance();
-        });
-
-        $console->progressFinish();
-        $console->success('finish');
-
-        return 0;
-    }
-}
diff --git a/tests/Unit/Console/Command/ProjectionCreateCommandTest.php b/tests/Unit/Console/Command/ProjectionCreateCommandTest.php
deleted file mode 100644
index ae1b6e06..00000000
--- a/tests/Unit/Console/Command/ProjectionCreateCommandTest.php
+++ /dev/null
@@ -1,68 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Tests\Unit\Console\Command;
-
-use Patchlevel\EventSourcing\Console\Command\ProjectionCreateCommand;
-use Patchlevel\EventSourcing\Projection\Projector\InMemoryProjectorRepository;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Dummy2Projection;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\DummyProjection;
-use PHPUnit\Framework\TestCase;
-use Prophecy\PhpUnit\ProphecyTrait;
-use Symfony\Component\Console\Input\ArrayInput;
-use Symfony\Component\Console\Output\BufferedOutput;
-
-/**
- * @covers \Patchlevel\EventSourcing\Console\Command\ProjectionCreateCommand
- * @covers \Patchlevel\EventSourcing\Console\Command\ProjectionCommand
- */
-final class ProjectionCreateCommandTest extends TestCase
-{
-    use ProphecyTrait;
-
-    public function testSuccessful(): void
-    {
-        $projectionA = new DummyProjection();
-        $projectionB = new Dummy2Projection();
-        $repository = new InMemoryProjectorRepository([$projectionA, $projectionB]);
-
-        $command = new ProjectionCreateCommand($repository);
-
-        $input = new ArrayInput([]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-
-        self::assertTrue($projectionA->createCalled);
-        self::assertTrue($projectionB->createCalled);
-
-        $content = $output->fetch();
-
-        self::assertStringContainsString('[OK] projection created', $content);
-    }
-
-    public function testSpecificProjection(): void
-    {
-        $projectionA = new DummyProjection();
-        $projectionB = new Dummy2Projection();
-        $repository = new InMemoryProjectorRepository([$projectionA, $projectionB]);
-
-        $command = new ProjectionCreateCommand($repository);
-
-        $input = new ArrayInput(['--projection' => DummyProjection::class]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-        self::assertTrue($projectionA->createCalled);
-        self::assertFalse($projectionB->createCalled);
-
-        $content = $output->fetch();
-
-        self::assertStringContainsString('[OK] projection created', $content);
-    }
-}
diff --git a/tests/Unit/Console/Command/ProjectionDropCommandTest.php b/tests/Unit/Console/Command/ProjectionDropCommandTest.php
deleted file mode 100644
index e5bd10c5..00000000
--- a/tests/Unit/Console/Command/ProjectionDropCommandTest.php
+++ /dev/null
@@ -1,68 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Tests\Unit\Console\Command;
-
-use Patchlevel\EventSourcing\Console\Command\ProjectionDropCommand;
-use Patchlevel\EventSourcing\Projection\Projector\InMemoryProjectorRepository;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Dummy2Projection;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\DummyProjection;
-use PHPUnit\Framework\TestCase;
-use Prophecy\PhpUnit\ProphecyTrait;
-use Symfony\Component\Console\Input\ArrayInput;
-use Symfony\Component\Console\Output\BufferedOutput;
-
-/**
- * @covers \Patchlevel\EventSourcing\Console\Command\ProjectionDropCommand
- * @covers \Patchlevel\EventSourcing\Console\Command\ProjectionCommand
- */
-final class ProjectionDropCommandTest extends TestCase
-{
-    use ProphecyTrait;
-
-    public function testSuccessful(): void
-    {
-        $projectionA = new DummyProjection();
-        $projectionB = new Dummy2Projection();
-        $repository = new InMemoryProjectorRepository([$projectionA, $projectionB]);
-
-        $command = new ProjectionDropCommand($repository);
-
-        $input = new ArrayInput([]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-
-        self::assertTrue($projectionA->dropCalled);
-        self::assertTrue($projectionB->dropCalled);
-
-        $content = $output->fetch();
-
-        self::assertStringContainsString('[OK] projection deleted', $content);
-    }
-
-    public function testSpecificProjection(): void
-    {
-        $projectionA = new DummyProjection();
-        $projectionB = new Dummy2Projection();
-        $repository = new InMemoryProjectorRepository([$projectionA, $projectionB]);
-
-        $command = new ProjectionDropCommand($repository);
-
-        $input = new ArrayInput(['--projection' => DummyProjection::class]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-        self::assertTrue($projectionA->dropCalled);
-        self::assertFalse($projectionB->dropCalled);
-
-        $content = $output->fetch();
-
-        self::assertStringContainsString('[OK] projection deleted', $content);
-    }
-}
diff --git a/tests/Unit/Console/Command/ProjectionRebuildCommandTest.php b/tests/Unit/Console/Command/ProjectionRebuildCommandTest.php
deleted file mode 100644
index aed9d29e..00000000
--- a/tests/Unit/Console/Command/ProjectionRebuildCommandTest.php
+++ /dev/null
@@ -1,187 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Patchlevel\EventSourcing\Tests\Unit\Console\Command;
-
-use Patchlevel\EventSourcing\Console\Command\ProjectionRebuildCommand;
-use Patchlevel\EventSourcing\EventBus\Message;
-use Patchlevel\EventSourcing\Projection\Projector\InMemoryProjectorRepository;
-use Patchlevel\EventSourcing\Store\ArrayStream;
-use Patchlevel\EventSourcing\Store\Criteria;
-use Patchlevel\EventSourcing\Store\CriteriaBuilder;
-use Patchlevel\EventSourcing\Store\Store;
-use Patchlevel\EventSourcing\Store\Stream;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Dummy2Projection;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\DummyProjection;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\Email;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileCreated;
-use Patchlevel\EventSourcing\Tests\Unit\Fixture\ProfileId;
-use PHPUnit\Framework\TestCase;
-use Prophecy\PhpUnit\ProphecyTrait;
-use Symfony\Component\Console\Input\ArrayInput;
-use Symfony\Component\Console\Output\BufferedOutput;
-
-/**
- * @covers \Patchlevel\EventSourcing\Console\Command\ProjectionRebuildCommand
- * @covers \Patchlevel\EventSourcing\Console\Command\ProjectionCommand
- */
-final class ProjectionRebuildCommandTest extends TestCase
-{
-    use ProphecyTrait;
-
-    private Stream $stream;
-    private Criteria $criteria;
-
-    public function setUp(): void
-    {
-        $this->stream = new ArrayStream([
-            new Message(
-                new ProfileCreated(ProfileId::fromString('1'), Email::fromString('info@patchlevel.de')),
-            ),
-            new Message(
-                new ProfileCreated(ProfileId::fromString('1'), Email::fromString('info@patchlevel.de')),
-            ),
-            new Message(
-                new ProfileCreated(ProfileId::fromString('1'), Email::fromString('info@patchlevel.de')),
-            ),
-            new Message(
-                new ProfileCreated(ProfileId::fromString('1'), Email::fromString('info@patchlevel.de')),
-            ),
-            new Message(
-                new ProfileCreated(ProfileId::fromString('1'), Email::fromString('info@patchlevel.de')),
-            ),
-        ]);
-
-        $this->criteria = (new CriteriaBuilder())->fromIndex(0)->build();
-    }
-
-    public function testSuccessful(): void
-    {
-        $projectionA = new DummyProjection();
-        $repository = new InMemoryProjectorRepository([$projectionA]);
-
-        $store = $this->prophesize(Store::class);
-        $store->count($this->criteria)->willReturn(5);
-        $store->load($this->criteria)->willReturn($this->stream);
-
-        $command = new ProjectionRebuildCommand(
-            $store->reveal(),
-            $repository,
-        );
-
-        $input = new ArrayInput([]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-
-        $content = $output->fetch();
-
-        self::assertInstanceOf(Message::class, $projectionA->handledMessage);
-        self::assertInstanceOf(ProfileCreated::class, $projectionA->handledMessage->event());
-
-        self::assertStringContainsString('[WARNING] rebuild projections', $content);
-        self::assertStringContainsString('[OK] finish', $content);
-    }
-
-    public function testSpecificProjection(): void
-    {
-        $store = $this->prophesize(Store::class);
-        $store->count($this->criteria)->willReturn(5);
-        $store->load($this->criteria)->willReturn($this->stream);
-
-        $projectionA = new DummyProjection();
-        $projectionB = new Dummy2Projection();
-        $repository = new InMemoryProjectorRepository([$projectionA, $projectionB]);
-
-        $command = new ProjectionRebuildCommand(
-            $store->reveal(),
-            $repository,
-        );
-
-        $input = new ArrayInput(['--projection' => $projectionA::class]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-        self::assertNotNull($projectionA->handledMessage);
-        self::assertNull($projectionB->handledMessage);
-
-        $content = $output->fetch();
-
-        self::assertStringContainsString('[WARNING] rebuild projections', $content);
-        self::assertStringContainsString('[OK] finish', $content);
-    }
-
-    public function testRecreate(): void
-    {
-        $projectionA = new DummyProjection();
-
-        $store = $this->prophesize(Store::class);
-        $store->count($this->criteria)->willReturn(5);
-        $store->load($this->criteria)->willReturn($this->stream);
-
-        $repository = new InMemoryProjectorRepository([$projectionA]);
-
-        $command = new ProjectionRebuildCommand(
-            $store->reveal(),
-            $repository,
-        );
-
-        $input = new ArrayInput(['--recreate' => true]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-
-        $content = $output->fetch();
-
-        self::assertTrue($projectionA->createCalled);
-        self::assertTrue($projectionA->dropCalled);
-
-        self::assertStringContainsString('[OK] projection schema deleted', $content);
-        self::assertStringContainsString('[OK] projection schema created', $content);
-        self::assertStringContainsString('[WARNING] rebuild projections', $content);
-        self::assertStringContainsString('[OK] finish', $content);
-    }
-
-    public function testRecreateWithSpecificProjection(): void
-    {
-        $store = $this->prophesize(Store::class);
-        $store->count($this->criteria)->willReturn(5);
-        $store->load($this->criteria)->willReturn($this->stream);
-
-        $projectionA = new DummyProjection();
-        $projectionB = new Dummy2Projection();
-        $repository = new InMemoryProjectorRepository([$projectionA, $projectionB]);
-
-        $command = new ProjectionRebuildCommand(
-            $store->reveal(),
-            $repository,
-        );
-
-        $input = new ArrayInput(['--recreate' => true, '--projection' => DummyProjection::class]);
-        $output = new BufferedOutput();
-
-        $exitCode = $command->run($input, $output);
-
-        self::assertSame(0, $exitCode);
-        self::assertNotNull($projectionA->handledMessage);
-        self::assertTrue($projectionA->createCalled);
-        self::assertTrue($projectionA->dropCalled);
-        self::assertNull($projectionB->handledMessage);
-        self::assertFalse($projectionB->createCalled);
-        self::assertFalse($projectionB->dropCalled);
-
-        $content = $output->fetch();
-
-        self::assertStringContainsString('[OK] projection schema deleted', $content);
-        self::assertStringContainsString('[OK] projection schema created', $content);
-        self::assertStringContainsString('[WARNING] rebuild projections', $content);
-        self::assertStringContainsString('[OK] finish', $content);
-    }
-}