zawiszaty / symfony-prooph-example

app/tests/TestCase.php

<?php

declare(strict_types=1);

namespace Tests;

use App\Kernel;
use Prooph\EventSourcing\Aggregate\AggregateType;

The type Prooph\EventSourcing\Aggregate\AggregateType was not found. Maybe you did not declare it correctly or list all dependencies?

use Prooph\EventSourcing\AggregateRoot;

The type Prooph\EventSourcing\AggregateRoot was not found. Maybe you did not declare it correctly or list all dependencies?

use Prooph\EventSourcing\EventStoreIntegration\AggregateTranslator;

The type Prooph\EventSourcing\EventStoreIntegration\AggregateTranslator was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\DependencyInjection\Container;

The type Symfony\Component\DependencyInjection\Container was not found. Maybe you did not declare it correctly or list all dependencies?

class TestCase extends \PHPUnit\Framework\TestCase

The type PHPUnit\Framework\TestCase was not found. Maybe you did not declare it correctly or list all dependencies?

{
    /**
     * @var Container|null
     */
    protected $container;

    /**
     * @var Kernel
     */
    private $kernel;

    protected function setUp(): void
    {
        parent::setUp(); // TODO: Change the autogenerated stub
        $this->kernel = new Kernel('test', true);
        $this->kernel->boot();
        $this->container = $this->kernel->getContainer();
    }

    /**
     * @var AggregateTranslator
     */
    private $aggregateTranslator;

    protected function popRecordedEvent(AggregateRoot $aggregateRoot): array
    {
        return $this->getAggregateTranslator()->extractPendingStreamEvents($aggregateRoot);
    }

    /**
     * @return object
     */
    protected function reconstituteAggregateFromHistory(string $aggregateRootClass, array $events): object
    {
        return $this->getAggregateTranslator()->reconstituteAggregateFromHistory(
            AggregateType::fromAggregateRootClass($aggregateRootClass),
            new \ArrayIterator($events)
        );
    }

    private function getAggregateTranslator(): AggregateTranslator
    {
        if (null === $this->aggregateTranslator) {
            $this->aggregateTranslator = new AggregateTranslator();
        }

        return $this->aggregateTranslator;
    }
}