Stu\Module\Tick\Spacecraft\SpacecraftTickManager

Complexity

Total Complexity

7

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Test Coverage

Coverage

10%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	work()	0	22	4
A	setLock()	0	9	1
A	clearLock()	0	3	1

<?php

declare(strict_types=1);

namespace Stu\Module\Tick\Spacecraft;

use Doctrine\ORM\EntityManagerInterface;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

use Stu\Component\Game\SemaphoreConstants;

The type Stu\Component\Game\SemaphoreConstants was not found. Maybe you did not declare it correctly or list all dependencies?

use Stu\Module\Control\SemaphoreUtilInterface;
use Stu\Module\Logging\LoggerUtilFactoryInterface;
use Stu\Module\Logging\LoggerUtilInterface;
use Stu\Module\Tick\Lock\LockManagerInterface;
use Stu\Module\Tick\Lock\LockTypeEnum;
use Stu\Module\Tick\Spacecraft\ManagerComponent\ManagerComponentInterface;

final class SpacecraftTickManager implements SpacecraftTickManagerInterface
{
    private LoggerUtilInterface $loggerUtil;

    /** @param array<ManagerComponentInterface> $components */
    public function __construct(
        private SemaphoreUtilInterface $semaphoreUtil,
        private LockManagerInterface $lockManager,
        private EntityManagerInterface $entityManager,
        private array $components,
        LoggerUtilFactoryInterface $loggerUtilFactory
    ) {
        $this->loggerUtil = $loggerUtilFactory->getLoggerUtil(true);
    }

    #[Override]
    public function work(bool $doCommit = false): void
    {
        $this->setLock(1);

        try {
            foreach ($this->components as $component) {
                $startTime = microtime(true);
                $component->work();

                if ($this->loggerUtil->doLog()) {
                    $endTime = microtime(true);
                    $this->loggerUtil->log(sprintf("\t\t%s, seconds: %F", get_class($component), $endTime - $startTime));
                }
            }

            if ($doCommit) {
                $this->entityManager->flush();
                $this->entityManager->commit();
            }
        } finally {
            $this->clearLock(1);
        }
    }

    private function setLock(int $batchGroupId): void
    {
        //main ship sema on
        $mainSema = $this->semaphoreUtil->acquireSemaphore(SemaphoreConstants::MAIN_SHIP_SEMAPHORE_KEY);

        $this->lockManager->setLock($batchGroupId, LockTypeEnum::SHIP_GROUP);

        //main ship sema off
        $this->semaphoreUtil->releaseSemaphore($mainSema);
    }

    private function clearLock(int $batchGroupId): void
    {
        $this->lockManager->clearLock($batchGroupId, LockTypeEnum::SHIP_GROUP);
    }
}