Jabe\Engine\Impl\Batch\RemovalTime\UpdateProcessInstancesSuspendStateJobHandler

Complexity

Total Complexity

6

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getType()	0	3	1
A	createJobConfiguration()	0	3	1
A	getJobDeclaration()	0	6	2
A	execute()	0	15	1
A	getJsonConverterInstance()	0	3	1

<?php

namespace Jabe\Engine\Impl\Batch\RemovalTime;

use Jabe\Engine\Batch\BatchInterface;
use Jabe\Engine\Impl\UpdateProcessInstancesSuspensionStateBuilderImpl;
use Jabe\Engine\Impl\Batch\{
    AbstractBatchJobHandler,
    BatchJobConfiguration,
    BatchJobContext,
    BatchJobDeclaration
};
use Jabe\Engine\Impl\Cmd\UpdateProcessInstancesSuspendStateCmd;
use Jabe\Engine\Impl\Interceptor\{
    CommandContext,
    CommandExecutorInterface
};
use Jabe\Engine\Impl\JobExecutor\JobDeclaration;
use Jabe\Engine\Impl\Json\JsonObjectConverter;
use Jabe\Engine\Impl\Persistence\Entity\{
    ByteArrayEntity,
    ExecutionEntity,
    MessageEntity
};

class UpdateProcessInstancesSuspendStateJobHandler extends AbstractBatchJobHandler
{
    public static $JOB_DECLARATION;

    public function getType(): string
    {
        return BatchInterface::TYPE_PROCESS_INSTANCE_UPDATE_SUSPENSION_STATE;
    }

    protected function getJsonConverterInstance(): JsonObjectConverter
    {
        return UpdateProcessInstancesSuspendStateBatchConfigurationJsonConverter::instance();
    }

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

    protected function createJobConfiguration(BatchConfiguration $configuration, array $processIdsForJob): BatchConfiguration
    {
        return new UpdateProcessInstancesSuspendStateBatchConfiguration($processIdsForJob, $configuration->getSuspended());
    }

    public function execute(BatchJobConfiguration $configuration, ExecutionEntity $execution, CommandContext $commandContext, string $tenantId = null)
    {
        $configurationEntity = $commandContext
            ->getDbEntityManager()
            ->selectById(ByteArrayEntity::class, $configuration->getConfigurationByteArrayId());

        $batchConfiguration = $this->readConfiguration($configurationEntity->getBytes());

It seems like $configurationEntity->getBytes() can also be of type null; however, parameter $serializedConfiguration of Jabe\Engine\Impl\Batch\AbstractBatchJobHandler::readConfiguration() does only seem to accept string, maybe add an additional type check?

        $commandExecutor = $commandContext->getProcessEngineConfiguration()
            ->getCommandExecutorTxRequired();

The method getCommandExecutorTxRequired() does not exist on Jabe\Engine\Impl\Cfg\ProcessEngineConfigurationImpl.

        $commandContext->executeWithOperationLogPrevented(
            new UpdateProcessInstancesSuspendStateCmd(
                $commandExecutor,
                new UpdateProcessInstancesSuspensionStateBuilderImpl($batchConfiguration->getIds()),
                $batchConfiguration->getSuspended()

The method getSuspended() does not exist on Jabe\Engine\Impl\Batch\BatchConfiguration. It seems like you code against a sub-type of Jabe\Engine\Impl\Batch\BatchConfiguration such as Jabe\Engine\Impl\Batch\Update\UpdateProcessInstancesSuspendStateBatchConfiguration.

            )
        );
    }
}