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

Complexity

Conditions	4
Paths	4

Size

Total Lines	22
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

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

        $metadata = $envelope->getMetadata();
        foreach ($commit->getEventLog() as $domainEvent) {
            $fqcn = $domainEvent->getAggregateRootClass();
            $aggregateAlias = $fqcn::getAlias();
            $projectors = $this->projectorMap->filterByAggregateAlias($aggregateAlias);
            foreach ($projectors->getIterator() as $projector) {
                if (!$projector->handle($envelope)) {
                    throw new ReadModelException('Projector %s failed to handle message.');
                }
            }

            $metadata = $metadata->with('_aggregate_alias', $aggregateAlias->toNative());
            $this->messageBus->publish($domainEvent, 'events', $metadata);
        }

        return true;
    }
}