Jabe\Engine\Impl\Repository\UpdateProcessDefinitionSuspensionStateBuilderImpl

Complexity

Total Complexity

18

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	processDefinitionTenantId()	0	7	1
A	getProcessDefinitionKey()	0	3	1
A	isTenantIdSet()	0	3	1
A	getProcessDefinitionTenantId()	0	3	1
A	getProcessDefinitionId()	0	3	1
A	validateParameters()	0	10	3
A	executionDate()	0	4	1
A	activate()	0	6	1
A	includeProcessInstances()	0	4	1
A	byProcessDefinitionKey()	0	5	1
A	byProcessDefinitionId()	0	5	1
A	processDefinitionWithoutTenantId()	0	5	1
A	__construct()	0	3	1
A	isIncludeProcessInstances()	0	3	1
A	getExecutionDate()	0	3	1
A	suspend()	0	6	1

<?php

namespace Jabe\Engine\Impl\Repository;

use Jabe\Engine\Impl\ProcessEngineLogger;
use Jabe\Engine\Impl\Cmd\{
    ActivateProcessDefinitionCmd,
    CommandLogger,
    SuspendProcessDefinitionCmd
};
use Jabe\Engine\Impl\Interceptor\CommandExecutorInterface;
use Jabe\Engine\Impl\Util\EnsureUtil;
use Jabe\Engine\Repository\{
    UpdateProcessDefinitionSuspensionStateBuilderInterface,
    UpdateProcessDefinitionSuspensionStateSelectBuilderInterface,
    UpdateProcessDefinitionSuspensionStateTenantBuilderInterface
};

class UpdateProcessDefinitionSuspensionStateBuilderImpl implements UpdateProcessDefinitionSuspensionStateBuilderInterface, UpdateProcessDefinitionSuspensionStateSelectBuilderInterface, UpdateProcessDefinitionSuspensionStateTenantBuilderInterface
{
    //private final static CommandLogger LOG = ProcessEngineLogger.CMD_LOGGER;

    protected $commandExecutor;

    protected $processDefinitionKey;
    protected $processDefinitionId;

    protected $includeProcessInstances = false;
    protected $executionDate;

    protected $processDefinitionTenantId;
    protected $isTenantIdSet = false;

    public function __construct(CommandExecutorInterface $commandExecutor = null)
    {
        $this->commandExecutor = $commandExecutor;
    }

    public function byProcessDefinitionId(string $processDefinitionId): UpdateProcessDefinitionSuspensionStateBuilderImpl
    {
        EnsureUtil::ensureNotNull("processDefinitionId", "processDefinitionId", $processDefinitionId);
        $this->processDefinitionId = $processDefinitionId;
        return $this;
    }

    public function byProcessDefinitionKey(string $processDefinitionKey): UpdateProcessDefinitionSuspensionStateBuilderImpl
    {
        EnsureUtil::ensureNotNull("processDefinitionKey", "processDefinitionKey", $processDefinitionKey);
        $this->processDefinitionKey = $processDefinitionKey;
        return $this;
    }

    public function includeProcessInstances(bool $includeProcessInstance): UpdateProcessDefinitionSuspensionStateBuilderImpl
    {
        $this->includeProcessInstances = $includeProcessInstance;
        return $this;
    }

    public function executionDate(string $date): UpdateProcessDefinitionSuspensionStateBuilderImpl
    {
        $this->executionDate = $date;
        return $this;
    }

    public function processDefinitionWithoutTenantId(): UpdateProcessDefinitionSuspensionStateBuilderImpl
    {
        $this->processDefinitionTenantId = null;
        $this->isTenantIdSet = true;
        return $this;
    }

    public function processDefinitionTenantId(string $tenantId): UpdateProcessDefinitionSuspensionStateBuilderImpl
    {
        EnsureUtil::ensureNotNull("tenantId", "tenantId", $tenantId);

        $this->processDefinitionTenantId = $tenantId;
        $this->isTenantIdSet = true;
        return $this;
    }

    public function activate(): void
    {
        $this->validateParameters();

        $command = new ActivateProcessDefinitionCmd($this);
        $this->commandExecutor->execute($command);

The method execute() does not exist on null.

    }

    public function suspend(): void
    {
        $this->validateParameters();

        $command = new SuspendProcessDefinitionCmd($this);
        $this->commandExecutor->execute($command);
    }

    protected function validateParameters(): void
    {
        EnsureUtil::ensureOnlyOneNotNull("Need to specify either a process instance id or a process definition key.", $this->processDefinitionId, $this->processDefinitionKey);

        if ($this->processDefinitionId !== null && $this->isTenantIdSet) {
            //throw LOG.exceptionUpdateSuspensionStateForTenantOnlyByProcessDefinitionKey();
            throw new \Exception("exceptionUpdateSuspensionStateForTenantOnlyByProcessDefinitionKey");
        }

        EnsureUtil::ensureNotNull("commandExecutor", "commandExecutor", $this->commandExecutor);
    }

    public function getProcessDefinitionKey(): string
    {
        return $this->processDefinitionKey;
    }

    public function getProcessDefinitionId(): string
    {
        return $this->processDefinitionId;
    }

    public function isIncludeProcessInstances(): bool
    {
        return $this->includeProcessInstances;
    }

    public function getExecutionDate(): string
    {
        return $this->executionDate;
    }

    public function getProcessDefinitionTenantId(): string
    {
        return $this->processDefinitionTenantId;
    }

    public function isTenantIdSet(): bool
    {
        return $this->isTenantIdSet;
    }
}