for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Daikon\Dbal\Projector;
use Assert\Assertion;
use Daikon\Cqrs\EventStore\CommitInterface;
use Daikon\Dbal\Repository\RepositoryInterface;
use Daikon\MessageBus\EnvelopeInterface;
final class StandardProjector implements ProjectorInterface
{
private $repository;
public function __construct(RepositoryInterface $repository)
$this->repository = $repository;
}
public function handle(EnvelopeInterface $envelope): bool
$commit = $envelope->getMessage();
Assertion::isInstanceOf($commit, CommitInterface::class);
if ($commit->getStreamRevision()->toNative() === 1) {
$projection = $this->repository->makeProjection();
} else {
$aggregateId = $commit->getStreamId()->toNative();
$projection = $this->repository->findById($aggregateId);
foreach ($commit->getEventLog() as $domainEvent) {
$projection = $projection->applyEvent($domainEvent);
return $this->repository->persist($projection);
daikon-cqrs /
dbal
