Stu\Component\Event\EventProcessor

Complexity

Total Complexity

2

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	processEvent()	0	16	1
A	__construct()	0	6	1

<?php

namespace Stu\Component\Event;

use Stu\Component\Concurrency\EntityLockManagerInterface;
use Stu\Component\Event\Strategy\EventStrategyInterface;
use Stu\Module\Logging\LoggerTypeEnum;
use Stu\Module\Logging\LoggerUtilFactoryInterface;
use Stu\Module\Logging\RotatingLoggerInterface;
use Stu\Orm\Entity\EventInterface;
use Stu\Orm\Transaction\SwitchableEntityManagerInterface;

class EventProcessor implements EventProcessorInterface
{
    private RotatingLoggerInterface $logger;

    public function __construct(
        private SwitchableEntityManagerInterface $switchableEntityManager,
        private EntityLockManagerInterface $entityLockManager,
        LoggerUtilFactoryInterface $loggerUtilFactory
    ) {
        $this->logger = $loggerUtilFactory->getRotatingLogger(LoggerTypeEnum::EVENT_AND_ENTITY_LOCK);
    }

    public function processEvent(EventInterface $event, EventStrategyInterface $eventStrategy): void
    {
        try {
            $startTime = microtime(true);
            $this->switchableEntityManager->wrapInTransaction(function () use ($event, $eventStrategy) {

                $startTime = microtime(true);
                $eventStrategy->processEvent($event);
                $endTime = microtime(true);

                $this->logger->logf('    processing took %F ms', ($endTime - $startTime) * 1000);
            });
            $endTime = microtime(true);
            $this->logger->logf('    transaction took %F ms', ($endTime - $startTime) * 1000);
        } finally {
            $this->entityLockManager->clearEntityLocks();
        }
    }
}