Jabe\Engine\Impl\Batch\ExternalTask\SetExternalTaskRetriesJobHandler

Complexity

Total Complexity

6

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

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

<?php

namespace Jabe\Engine\Impl\Batch\ExternalTask;

use Jabe\Engine\Batch\BatchInterface;
use Jabe\Engine\Impl\Batch\{
    AbstractBatchJobHandler,

The type Jabe\Engine\Impl\Batch\AbstractBatchJobHandler was not found. Maybe you did not declare it correctly or list all dependencies?

    BatchJobConfiguration,

The type Jabe\Engine\Impl\Batch\BatchJobConfiguration was not found. Maybe you did not declare it correctly or list all dependencies?

    BatchJobContext,

The type Jabe\Engine\Impl\Batch\BatchJobContext was not found. Maybe you did not declare it correctly or list all dependencies?

    BatchJobDeclaration

The type Jabe\Engine\Impl\Batch\BatchJobDeclaration was not found. Maybe you did not declare it correctly or list all dependencies?

};
use Jabe\Engine\Impl\Cmd\{
    SetExternalTasksRetriesCmd,
    UpdateExternalTaskRetriesBuilderImpl
};
use Jabe\Engine\Impl\Interceptor\CommandContext;
use Jabe\Engine\Impl\JobExecutor\{
    JobDeclaration,
    JobHandlerConfigurationInterface
};
use Jabe\Engine\Impl\Persistence\Entity\{
    ByteArrayEntity,
    ExecutionEntity,
    MessageEntity
};

class SetExternalTaskRetriesJobHandler extends AbstractBatchJobHandler
{
    public static $JOB_DECLARATION;

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

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

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

The method getConfigurationByteArrayId() does not exist on Jabe\Engine\Impl\JobExecutor\JobHandlerConfigurationInterface.

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

        $commandContext->executeWithOperationLogPrevented(
            new SetExternalTasksRetriesCmd(
                new UpdateExternalTaskRetriesBuilderImpl(
                    $batchConfiguration->getIds(),
                    $batchConfiguration->getRetries()
                )
            )
        );

        $commandContext->getByteArrayManager()->delete($configurationEntity);
    }

    protected function createJobConfiguration(SetRetriesBatchConfiguration $configuration, array $processIdsForJob): SetRetriesBatchConfiguration

The type Jabe\Engine\Impl\Batch\ExternalTask\SetRetriesBatchConfiguration was not found. Maybe you did not declare it correctly or list all dependencies?

    {
        return new SetRetriesBatchConfiguration($processIdsForJob, $configuration->getRetries());
    }

    protected function getJsonConverterInstance(): SetExternalTaskRetriesBatchConfigurationJsonConverter
    {
        return SetExternalTaskRetriesBatchConfigurationJsonConverter::instance();
    }
}