ProcessSetRemovalTimeJobHandler::execute() - Code Metrics - Inspection of "feat: port batch implementations" - bingo-soft/jabe - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed
Push — main ( fc8ba5...9083af )

by Bingo
created 2022-07-15 05:49 UTC
ProcessSetRemovalTimeJobHandler::execute() A

↳ Parent: ProcessSetRemovalTimeJobHandler
Complexity

Conditions	6
Paths	5
Size

Total Lines	20
Code Lines	15
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
eloc	15
c	1
b	0
f	0
dl	0
loc	20
rs	9.2222
cc	6
nc	5
nop	4
<?php

namespace Jabe\Engine\Impl\Batch\RemovalTime;

use Jabe\Engine\ProcessEngineConfiguration;
use Jabe\Engine\Batch\BatchInterface;
use Jabe\Engine\Impl\Batch\{
    AbstractBatchJobHandler,
    BatchJobConfiguration,
    BatchJobContext,
    BatchJobDeclaration
};
use Jabe\Engine\Impl\Interceptor\CommandContext;
use Jabe\Engine\Impl\JobExecutor\JobDeclaration;
use Jabe\Engine\Impl\Json\JsonObjectConverter;
use Jabe\Engine\Impl\Persistence\Entity\{
    ByteArrayEntity,
    ExecutionEntity,
    HistoricProcessInstanceEntity,
    MessageEntity
};
use Jabe\Engine\Repository\ProcessDefinitionInterface;

class ProcessSetRemovalTimeJobHandler extends AbstractBatchJobHandler
{
    public static $JOB_DECLARATION;

    public function execute(BatchJobConfiguration $configuration, ExecutionEntity $execution, CommandContext $commandContext, string $tenantId = null)
    {
        $byteArrayId = $configuration->getConfigurationByteArrayId();
        $configurationByteArray = $this->findByteArrayById($byteArrayId, $commandContext);

        $batchConfiguration = $this->readConfiguration($configurationByteArray);

        foreach ($batchConfiguration->getIds() as $instanceId) {
            $instance = $this->findProcessInstanceById($instanceId, $commandContext);

            if ($instance != null) {
                if ($batchConfiguration->isHierarchical() && $this->hasHierarchy($instance)) {
                if ($batchConfiguration->/** @scrutinizer ignore-call */ isHierarchical() && $this->hasHierarchy($instance)) {
                    $rootProcessInstanceId = $instance->getRootProcessInstanceId();
                    $rootInstance = $this->findProcessInstanceById($rootProcessInstanceId, $commandContext);
                    $removalTime = $this->getOrCalculateRemovalTime($batchConfiguration, $rootInstance, $commandContext);
                    $removalTime = $this->getOrCalculateRemovalTime($batchConfiguration, /** @scrutinizer ignore-type */ $rootInstance, $commandContext);
                    $this->addRemovalTimeToHierarchy($rootProcessInstanceId, $removalTime, $commandContext);
                    $this->addRemovalTimeToHierarchy($rootProcessInstanceId, /** @scrutinizer ignore-type */ $removalTime, $commandContext);
                } else {
                    $removalTime = $this->getOrCalculateRemovalTime($batchConfiguration, $instance, $commandContext);
                    if ($removalTime != $instance->getRemovalTime()) {
                        $this->addRemovalTime($instanceId, $removalTime, $commandContext);
                        $this->addRemovalTime($instanceId, /** @scrutinizer ignore-type */ $removalTime, $commandContext);
                    }
                }
            }
        }
    }

    protected function getOrCalculateRemovalTime(SetRemovalTimeBatchConfiguration $batchConfiguration, HistoricProcessInstanceEntity $instance, CommandContext $commandContext): ?string
    {
        if ($batchConfiguration->hasRemovalTime()) {
            return $batchConfiguration->getRemovalTime();
        } elseif ($this->hasBaseTime($instance, $commandContext)) {
            return $this->calculateRemovalTime($instance, $commandContext);
        } else {
            return null;
        }
    }

    protected function addRemovalTimeToHierarchy(string $rootProcessInstanceId, string $removalTime, CommandContext $commandContext): void
    {
        $commandContext->getHistoricProcessInstanceManager()
            ->addRemovalTimeToProcessInstancesByRootProcessInstanceId($rootProcessInstanceId, $removalTime);

        /*if (isDmnEnabled(commandContext)) {
            $commandContext->getHistoricDecisionInstanceManager()
            .addRemovalTimeToDecisionsByRootProcessInstanceId(rootProcessInstanceId, removalTime);
        }*/
    }

    protected function addRemovalTime(string $instanceId, string $removalTime, CommandContext $commandContext): void
    {
        $commandContext->getHistoricProcessInstanceManager()
            ->addRemovalTimeById($instanceId, $removalTime);

        /*if (isDmnEnabled(commandContext)) {
            $commandContext->getHistoricDecisionInstanceManager()
            .addRemovalTimeToDecisionsByProcessInstanceId(instanceId, removalTime);
        }*/
    }

    protected function hasBaseTime(HistoricProcessInstanceEntity $instance, CommandContext $commandContext): bool
    {
        return $this->isStrategyStart($commandContext) || ($this->isStrategyEnd($commandContext) && $this->isEnded($instance));
    }

    protected function isEnded(HistoricProcessInstanceEntity $instance): bool
    {
        return $instance->getEndTime() != null;
    }

    protected function isStrategyStart(CommandContext $commandContext): bool
    {
        return ProcessEngineConfiguration::HISTORY_REMOVAL_TIME_STRATEGY_START == $this->getHistoryRemovalTimeStrategy($commandContext);
    }

    protected function isStrategyEnd(CommandContext $commandContext): bool
    {
        return ProcessEngineConfiguration::HISTORY_REMOVAL_TIME_STRATEGY_END == $this->getHistoryRemovalTimeStrategy($commandContext);
    }

    protected function hasHierarchy(HistoricProcessInstanceEntity $instance): bool
    {
        return $instance->getRootProcessInstanceId() != null;
    }

    protected function getHistoryRemovalTimeStrategy(CommandContext $commandContext): string
    {
        return $commandContext->getProcessEngineConfiguration()
            ->getHistoryRemovalTimeStrategy();
            ->/** @scrutinizer ignore-call */ getHistoryRemovalTimeStrategy();
    }

    protected function findProcessDefinitionById(string $processDefinitionId, CommandContext $commandContext): ?ProcessDefinitionInterface
    {
        return $commandContext->getProcessEngineConfiguration()
            ->getDeploymentCache()
            ->/** @scrutinizer ignore-call */ getDeploymentCache()
            ->findDeployedProcessDefinitionById($processDefinitionId);
    }

    /*protected boolean isDmnEnabled(CommandContext commandContext) {
        return $commandContext->getProcessEngineConfiguration().isDmnEnabled();
    }*/

    protected function calculateRemovalTime(HistoricProcessInstanceEntity $processInstance, CommandContext $commandContext): string
    {
        $processDefinition = $this->findProcessDefinitionById($processInstance->getProcessDefinitionId(), $commandContext);

        return $commandContext->getProcessEngineConfiguration()
            ->getHistoryRemovalTimeProvider()
            ->/** @scrutinizer ignore-call */ getHistoryRemovalTimeProvider()
            ->calculateRemovalTime($processInstance, $processDefinition);
    }

    protected function findByteArrayById(string $byteArrayId, CommandContext $commandContext): ByteArrayEntity
    {
        return $commandContext->getDbEntityManager()
            ->selectById(ByteArrayEntity::class, $byteArrayId);
    }

    protected function findProcessInstanceById(string $instanceId, CommandContext $commandContext): ?HistoricProcessInstanceEntity
    {
        return $commandContext->getHistoricProcessInstanceManager()
            ->findHistoricProcessInstance($instanceId);
    }

    public function getJobDeclaration(): JobDeclaration
    {
        if (self::$JOB_DECLARATION === null) {
            self::$JOB_DECLARATION = new BatchJobDeclaration(BatchInterface::TYPE_PROCESS_SET_REMOVAL_TIME);
        }
        return self::$JOB_DECLARATION;
    }

    protected function createJobConfiguration(BatchConfiguration $configuration, array $processInstanceIds): BatchConfiguration
    {
        return (new SetRemovalTimeBatchConfiguration($processInstanceIds))

            ->setRemovalTime($configuration->getRemovalTime())
            ->setHasRemovalTime($configuration->hasRemovalTime())
            ->setHierarchical($configuration->isHierarchical());
    }

    protected function getJsonConverterInstance(): JsonObjectConverter
    {
        return SetRemovalTimeJsonConverter::instance();
        return SetRemovalTimeJsonConverter::/** @scrutinizer ignore-call */ instance();
    }

    public function getType(): string
    {
        return BatchInteface::TYPE_PROCESS_SET_REMOVAL_TIME;
    }
}

bingo-soft / jabe

Push — main ( fc8ba5...9083af )

ProcessSetRemovalTimeJobHandler::execute() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
