Jabe\Impl\Batch\BatchJobDeclaration

Complexity

Total Complexity

6

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	newJobInstance()	0	3	1
A	resolveExecution()	0	3	1
A	resolveJobDefinitionId()	0	3	1
A	resolveJobHandlerConfiguration()	0	3	1
A	__construct()	0	3	1
A	getJobPriorityProvider()	0	5	1

<?php

namespace Jabe\Impl\Batch;

use Jabe\Impl\Context\Context;
use Jabe\Impl\Core\Variable\Mapping\Value\{
    ConstantValueProvider,
    ParameterValueProviderInterface
};
use Jabe\Impl\JobExecutor\{
    JobDeclaration,
    JobHandlerConfigurationInterface
};
use Jabe\Impl\Persistence\Entity\{
    ExecutionEntity,
    JobEntity,
    MessageEntity
};

class BatchJobDeclaration extends JobDeclaration
{
    public function __construct(string $jobHandlerType)
    {
        parent::__construct($jobHandlerType);
    }

    protected function resolveExecution(/*BatchJobContext*/$context): ?ExecutionEntity
    {
        return null;
    }

    protected function newJobInstance($context = null): JobEntity
    {
        return new MessageEntity();
    }

    protected function resolveJobHandlerConfiguration(/*BatchJobContext*/$context): JobHandlerConfigurationInterface
    {
        return new BatchJobConfiguration($context->getConfiguration()->getId());
    }

    protected function resolveJobDefinitionId(/*BatchJobContext*/$context): string
    {
        return $context->getBatch()->getBatchJobDefinitionId();
    }

    public function getJobPriorityProvider(): ParameterValueProviderInterface
    {
        $batchJobPriority = Context::getProcessEngineConfiguration()
            ->getBatchJobPriority();

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

        return new ConstantValueProvider($batchJobPriority);
    }
}