Daikon\Dbal\Projector\ProjectorService::handle()

Complexity

Conditions	4
Paths	4

Size

Total Lines	17
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function handle(EnvelopeInterface $envelope): bool
    {
        $commit = $envelope->getMessage();
        Assertion::implementsInterface($commit, CommitInterface::class);

        foreach ($commit->getEventLog() as $domainEvent) {
            $aggregatePrefix = AggregatePrefix::fromFqcn($domainEvent->getAggregateRootClass());
            $projectors = $this->projectorMap->filterByAggregatePrefix($aggregatePrefix);
            foreach ($projectors->getIterator() as $projector) {
                if (!$projector->handle($envelope)) {
                    throw new DbalException('Projector %s failed to handle message.');
                }
            }
        }

        return true;
    }
}